本文实例为大家分享了python实现多任务版的udp聊天器,供大家参考,具体内容如下
一、案例示例
二、案例说明
1、编写一个有2个线程的程序。
2、线程1用来接收数据然后显示。
3、线程2用来检测键盘数据然后通过udp发送数据。
三、参考代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
import socket
import threading
def send_msg(udp_socket):
"""获取键盘数据,并将其发送给对方"""
while true:
# 1. 从键盘输入数据
msg = input ( "\n请输入要发送的数据:" )
# 2. 输入对方的ip地址
dest_ip = input ( "\n请输入对方的ip地址:" )
# 3. 输入对方的port
dest_port = int ( input ( "\n请输入对方的port:" ))
# 4. 发送数据
udp_socket.sendto(msg.encode( "utf-8" ), (dest_ip, dest_port))
def recv_msg(udp_socket):
"""接收数据并显示"""
while true:
# 1. 接收数据
recv_msg = udp_socket.recvfrom( 1024 )
# 2. 解码
recv_ip = recv_msg[ 1 ]
recv_msg = recv_msg[ 0 ].decode( "utf-8" )
# 3. 显示接收到的数据
print ( ">>>%s:%s" % ( str (recv_ip), recv_msg))
def main():
# 1. 创建套接字
udp_socket = socket.socket(socket.af_inet, socket.sock_dgram)
# 2. 绑定本地信息
udp_socket.bind(("", 7890 ))
# 3. 创建一个子线程用来接收数据
t = threading.thread(target = recv_msg, args = (udp_socket,))
t.start()
# 4. 让主线程用来检测键盘数据并且发送
send_msg(udp_socket)
if __name__ = = "__main__" :
main()
|
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://blog.csdn.net/qq_44034384/article/details/108012650