翼度科技»论坛 编程开发 python 查看内容

【Socket】解决UDP丢包问题

6

主题

6

帖子

18

积分

新手上路

Rank: 1

积分
18
一、介绍

UDP是一种不可靠的、无连接的、基于数据报的传输层协议。相比于TCP就比较简单,像写信一样,直接打包丢过去,就不用管了,而不用TCP这样的反复确认。所以UDP的优势就是速度快,开销小。但是随之而来的就是不稳定,面向无连接的,无法确认数据包。会导致丢包问题。

二、丢包原因

1、服务未启动或出现故障,但是数据包依然发送出去,目标地址和端口没有任何进程在监听,这些数据包将被丢弃。
2、缓冲区满,数据包溢出丢失。在实际情况中,如果处理的速度比较慢,会导致数据包堆积在缓冲区,当缓冲区满时,发送的数据无处存放就会丢失。另一种情况是发送的数据包非常大时,可能这个数据包直接超出了缓冲区的大小,也会导致数据丢失。最后一种情况和第一种差不多,由于发送的速率过快,导致处理不及时。
Client
  1. import socket
  2. import time
  3. def main():
  4.     server_host = "127.0.0.1"
  5.     server_port = 8888
  6.     with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as client_sock:
  7.         i = 0
  8.         while True:
  9.             message = b"Hello, server!"
  10.             client_sock.sendto(message, (server_host, server_port))
  11.             i = i + 1
  12.             time.sleep(0.001)
  13.             if i == 100000:
  14.                 break
  15. if __name__ == "__main__":
  16.     main()
复制代码
Serevr
  1. import socket
  2. import time
  3. def main():
  4.     host = "127.0.0.1"
  5.     port = 8888
  6.     with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as server_sock:
  7.         server_sock.bind((host, port))
  8.         i= 0
  9.         while True:
  10.             data, client_addr = server_sock.recvfrom(1024)
  11.             print("接收来自", client_addr, "的消息:", data.decode())
  12.             if i==0:
  13.                 time.sleep(10)
  14.             i+=1
  15.             print(i)
  16. if __name__ == "__main__":
  17.     main()
复制代码
这里的客户端发送了100000个数据包,在服务端特意设置处理第一个数据包后停止10秒模拟数据处理时间。在这种情况下,就会因为速度过快,缓冲区满而导致数据包丢失。服务端最后的打印为

可以看到只接收到了96521个数据包,后面的因为缓冲区满的原因全部丢失。这里不会像TCP一样堆积数据包会粘包,UDP不会,而是会一次取一个,按顺序取。不同的设置的缓冲区大容量不同。
三、避免丢包

既然我们知道了丢包的原因,那么在好实际开发中我们应尽量避免丢包问题。
1、在接收端人为创建缓冲区,也即是说,如果一个数据包处理的时间很长,那么我们可以将接收和处理分开,将接收的数据存储到代码层面。
2、再遇见数据包很大时,可以采用分片多次传输,最后将数据在接收端汇总处理,避免数据堆积。
3、解决方案:接收处理分离
这里使用多进程来处理数据,与接收数据使用不同的线程,互不影响,这样不会导致数据包的接收速度,所以缓冲区不会堆积,避免数据包的丢失。手动创建了一个本地数据缓冲区,使用一个列表将接收的数据存储,使用多进程不断处理。这里相当于队列是一个本地缓冲区,可以避免数据丢包,但是需要注意的是本地缓冲区不能也不能超过大小。
Client
  1. import socket
  2. import time
  3. def main():
  4.     server_host = "127.0.0.1"
  5.     server_port = 8888
  6.     with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as client_sock:
  7.         i = 0
  8.         while True:
  9.             message = b"Hello, server!"
  10.             client_sock.sendto(message, (server_host, server_port))
  11.             i = i + 1
  12.             time.sleep(0.001)
  13.             if i == 100000:
  14.                 break
  15. if __name__ == "__main__":
  16.     main()
复制代码
Server
  1. from multiprocessing import Queue
  2. import socket
  3. import time
  4. from  multiprocessing import Process
  5. def task(data_list:Queue):
  6.     '''模拟处理处理'''
  7.     while True:
  8.         data = data_list.get()
  9.         time.sleep(10)
  10.      
  11. def main():
  12.     host = "127.0.0.1"
  13.     port = 8888
  14.     data_list = Queue()
  15.     i= 0
  16.     work = Process(target=task, args=(data_list,))
  17.     work.daemon = True
  18.     work.start()   
  19.     with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as server_sock:
  20.         server_sock.bind((host, port))
  21.         while True:
  22.             data, _ = server_sock.recvfrom(1024)
  23.             data_list.put(data)
  24.             i+=1
  25.             print(i)
  26. if __name__ == "__main__":
  27.     main()
复制代码
四、解决丢包

1、回复机制

Server
  1. import socket
  2. def main():
  3.     host = "127.0.0.1"
  4.     port = 8888
  5.     with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as server_sock:
  6.         server_sock.bind((host, port))
  7.         while True:
  8.             data, client_addr = server_sock.recvfrom(1024)
  9.             print("接收到来自", client_addr, "的消息:", data.decode())
  10.             ack_message = "ACK".encode()
  11.             server_sock.sendto(ack_message, client_addr)
  12. if __name__ == "__main__":
  13.     main()
复制代码
Client
[code]import socketimport timedef main():    server_host = "127.0.0.1"    server_port = 8888    message = ["Hello, server!"]*10    timeout = 2     i = 0    with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as client_sock:        client_sock.settimeout(timeout)        while i

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x

举报 回复 使用道具