UDP服务器接收数据和发送数据

UDP协议时，不需要建立连接，只需要知道对方的IP地址和端口号，就可以直接发数据包。但是，能不能到达就不知道了。虽然用UDP传输数据不可靠，但它的优点是和TCP比，速度快，对于不要求可靠到达的数据，就可以使用UDP协议。

创建Socket时，SOCK_DGRAM指定了这个Socket的类型是UDP。绑定端口和TCP一样，但是不需要调用listen()方法，而是直接接收来自任何客户端的数据。recvfrom()方法返回数据和客户端的地址与端口，这样，服务器收到数据后，直接调用sendto()就可以把数据用UDP发给客户端。

UDP编程的实现

【示例】UDP接收数据

#coding=utf-8
from socket import *
s = socket(AF_INET, SOCK_DGRAM) #创建套接字
#绑定接收信息端口
s.bind(('127.0.0.1', 8888)) #绑定一个端口，ip地址和端⼝号
print("等待接收数据！")
redata = s.recvfrom(1024) #1024表示本次接收的最⼤字节数
print(redata)
print(f'收到远程信息:{redata[0].decode("gbk")}, from {redata[1]}')
s.close()

【示例】UDP发送数据

from socket import *
s = socket(AF_INET, SOCK_DGRAM) #创建套接字
addr = ('127.0.0.1', 8888) #准备接收方地址
data = input("请输入：")
#发送数据时，python3需要将字符串转成byte
s.sendto(data.encode('gbk'),addr) #默认的网络助手使用的编码是gbk
s.close()

UDP持续通信

【示例】UDP接收数据

#coding=utf-8
from socket import *
​
s = socket(AF_INET,SOCK_DGRAM) #创建UDP类型的套接字
s.bind(("127.0.0.1",8888)) #绑定端口,ip可以不写
print("等待接收数据！")
while True:recv_data = s.recvfrom(1024)  #1024表示本次接收的最大字节数recv_content = recv_data[0].decode('gbk')print(f"收到远程信息:{recv_content},from {recv_data[1]}")if recv_content == "88":print("结束聊天！")break
​
s.close()

【示例】UDP发送数据

#coding=utf-8
from socket import *
​
s = socket(AF_INET,SOCK_DGRAM) #创建UDP类型的套接字
addr = ("127.0.0.1",8888)
​
while True:data = input("请输入：")s.sendto(data.encode("gbk"),addr)if data == "88":print("结束聊天！")break
​
s.close()

UDP多线程结合自由通信

结合多线程实现UDP双向自由通信

UDP 不同于 TCP，不存在请求连接和受理过程，因此在某种意义上无法明确区分服务器端和客户端，只是因为其提供服务而称为服务器端。

如下服务端、客户端代码几乎一模一样，注意接收和发送端口对应，即可。

【示例】UDP实现多线程服务端

#coding=utf-8
from socket import *
from threading import Thread
udp_socket=socket(AF_INET,SOCK_DGRAM)
#绑定接收信息端口
udp_socket.bind(('127.0.0.1',8989))
​
#不停接收
def recv_data():while True:redata = udp_socket.recvfrom(1024)print(f'收到信息:{redata[0].decode("gbk")}, from {redata[1]}')
​
#不停发送
def send_data():while True:data=input('输入信息：')addr=('127.0.0.1',8080)udp_socket.sendto(data.encode('gbk'),addr)
​
if __name__=='__main__':# 创建两个线程t1=Thread(target=send_data)t2=Thread(target=recv_data)t2.start()t1.start()t1.join()t2.join()

【示例】UDP实现多线程客户端

#coding=utf-8
from socket import *
from threading import Thread
udp_socket=socket(AF_INET,SOCK_DGRAM)
#绑定接收信息端口
udp_socket.bind(('127.0.0.1',8080))
​
#不停接收
def recv_data():while True:redata = udp_socket.recvfrom(1024)print(f'收到信息:{redata[0].decode("gbk")}, from {redata[1]}')
​
#不停发送
def send_data():while True:data=input('输入信息：')addr=('127.0.0.1',8989)udp_socket.sendto(data.encode('gbk'),addr)
​
if __name__=='__main__':# 创建两个线程t1=Thread(target=send_data)t2=Thread(target=recv_data)t2.start()t1.start()t1.join()t2.join()