UDP聊天小程序+多线程（Python）

import socketdef send_msg(udp_socket):dest_ip=input("输入对方ip：")dest_port=int(input("输入对方端口："))send_data=input("输入消息：")udp_socket.sendto(send_data.encode("utf-8"),(dest_ip,dest_port)) # encocde为编码 def recv_msg(udp_socket):rev_data=udp_socket.recvfrom(1024)print("%s:%s"%(str(rev_data[1]),rev_data[0].decode("utf-8"))) # decode为解码def main():# 建立套接字udp_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)# 绑定端口udp_socket.bind(('',7788))while True:# 发送消息send_msg(udp_socket)# 接收消息recv_msg(udp_socket) if __name__ == '__main__':main()

多线程版，能同时收发消息：

import socket import threadingdef recv_msg(udp_socket):while True:recv_data=udp_socket.recvfrom(1024)print("接收到的消息：%s"%str(recv_data[0].decode("utf-8")))def send_mag(udp_socket,dest_ip,dest_port):while True:send_data=input("输入发送的消息：")udp_socket.sendto(send_data.encode("utf-8"),(dest_ip,dest_port)) def main():udp_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)udp_socket.bind(("",7890))dest_ip='输入主机的IP地址'dest_port=8080t_recv=threading.Thread(target=recv_msg,args=(udp_socket,))t_send=threading.Thread(target=send_mag,args=(udp_socket,dest_ip,dest_port))t_recv.start()t_send.start()if __name__ == '__main__':main()

总结

以上是生活随笔为你收集整理的UDP聊天小程序+多线程（Python）的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。