34 lines
1.2 KiB
Python
34 lines
1.2 KiB
Python
import socket #引入套接字
|
||
import threading #引入并行
|
||
udp_data = None
|
||
def udp_send(udp_socket):
|
||
|
||
while True:
|
||
num1 = '192.168.4.1'
|
||
num2 = 2333
|
||
send_data = input('请输入要发送的数据：')
|
||
send_data = send_data.encode('utf-8')
|
||
udp_socket.sendto(send_data,(num1,num2)) #sendto（发送数据，发送地址）
|
||
|
||
def udp_recv(udp_socket):
|
||
global udp_data
|
||
while True:
|
||
recv_data = udp_socket.recv(1024)
|
||
recv_data = recv_data.decode('utf-8')
|
||
udp_data = recv_data
|
||
print('收到信息为:%s'%recv_data)
|
||
|
||
def main():
|
||
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) #创建套接字
|
||
ip = '192.168.4.2' #服务器ip和端口
|
||
port = 2333
|
||
udp_socket.bind(("192.168.4.2",2333)) #服务器绑定ip和端口
|
||
#发送数据
|
||
t=threading.Thread(target=udp_send,args=(udp_socket,)) # Thread函数用于并行
|
||
#接收数据
|
||
t1=threading.Thread(target=udp_recv,args=(udp_socket,))
|
||
t.start() #并行开始
|
||
t1.start()
|
||
|
||
if __name__ == '__main__':
|
||
main() |