linux udp流量

import socket

def send_udp_data(host, port, data):
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.sendto(data.encode(), (host, port))
    sock.close()

def receive_udp_data(port):
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.bind(('', port))
    data, addr = sock.recvfrom(1024)
    sock.close()
    return data.decode()

# 示例：发送和接收UDP数据
send_udp_data('127.0.0.1', 5000, 'Hello, UDP!')
print(receive_udp_data(5000))

import socket
import time

def send_udp_data_with_seq(host, port, data):
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    seq_num = 0
    for d in data.split():
        packet = f"{seq_num}:{d}".encode()
        sock.sendto(packet, (host, port))
        seq_num += 1
    sock.close()

def receive_udp_data_with_seq(port):
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.bind(('', port))
    packets = {}
    while True:
        data, addr = sock.recvfrom(1024)
        seq_num, msg = data.decode().split(':')
        packets[int(seq_num)] = msg
        if len(packets) == int(seq_num) + 1:
            break
    sock.close()
    return ' '.join(packets.values())

# 示例：发送和接收带有序列号的UDP数据
send_udp_data_with_seq('127.0.0.1', 5000, 'Hello UDP this is a test')
print(receive_udp_data_with_seq(5000))