Geschwindigkeit von Socket anpassen

Question

Ich versuche, Ethernet-Frames über eine Gigabit-Verbindung mit Python zu senden. Daher habe ich diesen Code verwendet:

while (package_count < packets): 
    package_count += 1 
    s.send(eth_header+eth_payload) 
    sleep(delay) 

Der Sockel ist zuvor geöffnet. Die Größe eines Frames (eth_header + eth_payload) beträgt 1500 Byte. Um die volle Gigabit-Verbindung zu verwenden, wäre die Verzögerungszeit weit von der minimalen Verzögerungszeit von einigen Millisekunden entfernt. Irgendeine Idee, wie man die Geschwindigkeit des Sendens von Daten unter Verwendung der vollen Gigabit über Sockets in Python steuert?

Answer 1

Es gibt keine explizite Möglichkeit, Sendrate zu steuern; Sie müssen es selbst durch sleep() für die entsprechende Zeit tun. Die Berechnung des geeigneten Wertes für die Übergabe in den Schlafmodus() ist der einzige schwierige Teil. Ich tue es, indem ich einen Zähler der Anzahl der Bytes halte, die bisher gesendet wurden, und subtrahiere von diesem Zähler die Anzahl der Bytes, die in der verstrichenen Zeit gesendet werden sollten. Auf diese Weise weiß ich zu jeder Zeit, wie viele Bytes ich vor dem Zeitplan bin, was sich direkt in die Anzahl der Sekunden einstellt, die ich vor dem Zeitplan habe, also wie lange ich schlafen sollte, um zurück zu sein "nach Plan".

Beispielcode ist unten; Es sendet UDP-Pakete statt Rohdaten, aber die Logik ist die gleiche.

import socket 
import time 

# We'll limit ourself to a 40KB/sec maximum send rate 
maxSendRateBytesPerSecond = (40*1024) 

def ConvertSecondsToBytes(numSeconds): 
    return numSeconds*maxSendRateBytesPerSecond 

def ConvertBytesToSeconds(numBytes): 
    return float(numBytes)/maxSendRateBytesPerSecond 

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 
sock.connect(('127.0.0.1', 8888)) 

# We'll add to this tally as we send() bytes, and subtract from 
# at the schedule specified by (maxSendRateBytesPerSecond) 
bytesAheadOfSchedule = 0 

# Dummy data buffer, just for testing 
dataBuf = bytearray(1024) 

prevTime = None 

while True: 
    now = time.time() 
    if (prevTime != None): 
     bytesAheadOfSchedule -= ConvertSecondsToBytes(now-prevTime) 
    prevTime = now 

    numBytesSent = sock.send(dataBuf) 
    if (numBytesSent > 0): 
     bytesAheadOfSchedule += numBytesSent 
     if (bytesAheadOfSchedule > 0): 
     time.sleep(ConvertBytesToSeconds(bytesAheadOfSchedule)) 
    else: 
     print "Error sending data, exiting!" 
     break