import socket
import multiprocessing
def recv(udp_socket):
while True:
recv_data= udp_socket.recvfrom(1024)
print(recv_data[1],":",recv_data[0].decode("utf-8"))
def send(udp_socket,client_addr):
while True:
send_data= input("请输入要发送的消息:")
udp_socket.sendto(send_data.encode("utf-8"),client_addr)
def main():
udp_socket= socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
client_addr= ("127.0.0.1",7788)
udp_socket.bind(("127.0.0.1",8080))
p1=multiprocessing.Process(target=recv,args=(udp_socket,))
p2=multiprocessing.Process(target=send,args=(udp_socket,client_addr))
p1.start()
p2.start()
p1.join()
p2.join()
udp_socket.close()
if name == "__main__":
main()