Python插座和Scapy嗅探UDP数据包

Question

Windows10。Python3.7.8。 Scapy 2.4.5 我需要传输几个兆字节的数据。例如，我以这种方式使用套接字：

收发器：

import socket
UDP_IP = "192.168.13.172"
UDP_PORT = 0x1111
MESSAGE = b"... 1000 bytes data ..."
print("UDP target IP: %s" % UDP_IP)
print("UDP target port: %s" % UDP_PORT)
print("message: %s" % MESSAGE)

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
for x in range(0, 1500):
    sock.sendto(MESSAGE, (UDP_IP, UDP_PORT))

接收器：

import socket
import select

UDP_IP = "192.168.13.172"
UDP_PORT = 0x1111
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # UDP
sock.bind((UDP_IP, UDP_PORT))

sock.setblocking(0)

total = b''
while True:
    reads, send, excepts = select.select([sock], [], [], 8)
    if reads:
        data, adr = sock.recvfrom(4000000)
        total += data
        print(len(total))
        if len(total) >= 1500000:
            break
    elif send:
        print(send)
    elif excepts:
        print(excepts)
    else:
        print('timeout')
        break

接收器输出：

162000
163000
164000
timeout

但是收发器发送了1500000字节。我在Wireshark日志中看到了它们。其他1500000-164000 = 1336000数据字节在哪里？

我也使用这样的Scapy：

data = sc.sniff(lfilter=lambda r: sc.UDP in r and sc.IP in r and r[sc.IP].src == ip_address, timeout=8)

Scapy还掉了一些数据包。我需要做什么才能获取所有发送的数据包？

Answer 1

UDP是一个不可靠的协议。如果您发送太多数据太快，它可能会在实现和删除数据包中溢出缓冲区。如果您编号发送的数据包并将其与收到的数据包进行比较，则可以看到此信息。以下代码显示了这一点。

import socket
import select
import threading

UDP_IP = 'localhost'
UDP_PORT = 0x1111

def sender():
    with socket.socket(type=socket.SOCK_DGRAM) as sock:
        for x in range(1500):
            # message is 4-byte packet number repeated
            sock.sendto(x.to_bytes(4,'big') * 250, (UDP_IP, UDP_PORT))

def receiver():
    with socket.socket(type=socket.SOCK_DGRAM) as sock:
        sock.bind((UDP_IP, UDP_PORT))
        sock.setblocking(0)

        count = 0
        while True:
            reads, send, excepts = select.select([sock], [], [], 1)
            if reads:
                data, adr = sock.recvfrom(4096)
                number = int.from_bytes(data[:4],'big')
                print(count, number)
                if count != number:
                    break
                count += 1

            else:
                print('timeout',count)
                break

threading.Thread(target=receiver).start()
sender()

输出（使用打印可能会有所不同）：

0 0
1 1
2 2
3 3
 .
 .
250 250
251 251
252 252
253 262           (dropped packets here)

有趣的是，请评论打印，并且仅在接收器中进行比较允许其跟上，至少在我的系统上。

输出（无打印）

timeout 1500

如果您需要可靠性，请使用TCP而非UDP。 UDP还可以接收到数据包，因此希望实现数据包编号，并在必要时请求删除数据包并重新订购。