import socket

 # 发送数据

 def send_data(udp_socket, dest_ip, dest_port):

     send_msg = input('请输入要发送的数据: ')

     udp_socket.sendto(send_msg.encode('gbk'), (dest_ip, dest_port))  # encode(字符编码)

     return send_msg

 # 接收数据

 def recv_data(udp_socket):

     recv_msg, recv_ip_port = udp_socket.recvfrom(1024)  # recvfrom(一次可接收数据的大小)

     print(str(recv_ip_port) + ':' + recv_msg.decode('gbk'))

     return recv_msg.decode('gbk')

 def main():

     # 创建udp套接字

     udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 创建udp套接字

     # 绑定自身ip和port

     load_addr = ('', 8000)

     udp_socket.bind(load_addr)

     # 对方ip和port

     dest_ip = input('请输入对方ip: ')

     dest_port = int(input('请输入对方port: '))

     while True:

         # 发送数据

         exit1 = send_data(udp_socket, dest_ip, dest_port)

         if exit1 == 'exit':

             break

         # 接收数据

         exit2 = recv_data(udp_socket)

         if exit2 == 'exit':

             break

     # 关闭udp套接字

     udp_socket.close()

 if __name__ == '__main__':

     main()