server端伪代码:
ss = socket() ss.bind() inf_loop: cs = ss.recvfrom() / ss.sendto() ss.close()
server端:
# coding=utf-8 from socket import * import time HOST = 'localhost' PORT = 12345 BUFSIZ = 1024 ADDR = (HOST, PORT) udpSerSock = socket(type=SOCK_DGRAM) udpSerSock.bind(ADDR) while True: print('waiting for message...') data, addr = udpSerSock.recvfrom(BUFSIZ) udpSerSock.sendto(bytes(time.ctime(), 'utf-8'), addr) print('received from and returned to ', addr) udpSerSock.close()
client端:
伪代码:
cs = socket() comm_loop: msg = cs.sendto / recvfrom() cs.close()
# coding=utf-8 from socket import * HOST = 'localhost' PORT = 12345 BUFSIZ = 1024 ADDR = (HOST, PORT) udpClisock = socket(type=SOCK_DGRAM) while True: data = input('> ') if not data: break udpClisock.sendto(bytes(data, 'utf-8'), ADDR) data, ADDR = udpClisock.recvfrom(BUFSIZ) if not data: break print(data) udpClisock.close()
运行结果: