同上篇日记一样,上一篇写了 TCP/IP 的通信,这一篇则是 UDP 通信,基本内容同 TCP 差不多。
UDP 服务器不需要 TCP 服务器那么多设置,因为他不是面向连接的,除了等待传入的连接之外,几乎不需要做其他工作。
创建服务器套接字的伪代码,创建及工作流程
ss = socket() #创建服务器套接字
ss.bind() #绑定服务器套接字
inf_loop: #服务器无限循环
cs = ss.recvfrom()/ss.sendto() #接收和发送消息
ss.close() #关闭服务器套接字
完整的 UDP 时间戳服务器,接受客户端发送来的消息,并将加了时间戳的消息返回给客户端
#!/usr/bin/env python
# -*- coding: utf-8 -*-
from socket import *
from time import ctime
'''
HOST,PORT,BUFSIZ 同之前一样,对于socket()的调用与之前不同在于现在需要一个数据报/UDP 套接字类型,
bind()的调用与 TCP 一样,由于 UDP 是无连接的,所以这里没有调用’监听接入的连接‘
'''
HOST = ''
PORT = 21580
BUFSIZ = 1024
ADDR = (HOST,PORT)
udpSerSock = socket(AF_INET,SOCK_DGRAM)
udpSerSock.bind(ADDR)
'''
进入服务器无限循环中,等待消息(数据报),当一条消息到达时,添加一个时间戳,并将其发送回客户端,然后等待另一条消息
'''
while True:
print('waiting for message...')
data,addr = udpSerSock.recvfrom(BUFSIZ)
ss = '[%s] %s' % (ctime(), data)
print(ss)
udpSerSock.sendto(str.encode(ss),addr)
print('...received from and returned to:',addr)
udpSerSock.close()
创建 UDP 客户端的伪代码,UDP 客户端的代码很短
cs = socket() #创建客户端套接字
comm_loop: #通信循环
cs.sendto()/cs.recvfrom() #对话(发送/接收)
cs.close() #关闭客户端套接字
一旦创建了套接字对象,就进入对话循环,与服务器进行信息交换,当通信结束时,关闭客户端套接字
完整的客户端
#!/usr/bin/env python
# -*- coding: utf-8 -*-
from socket import *
'''
由于是在本地计算机上运行服务器,所以使用‘localhost’及与服务器相同的端口号
缓冲区大小为1kb,与 UDP 服务器相同的方法分配套接字对象
'''
HOST = 'localhost'
PORT = 21580
BUFSIZ = 1024
ADDR = (HOST,PORT)
udpCliSock = socket(AF_INET,SOCK_DGRAM)
'''
客户端循环,将用户输入的内容发送给服务器,并等待服务器返回信息,当服务器返回信息后,将信息打印出来
'''
while True:
data = input('> ')
if not data:
break
data = str.encode(data)
udpCliSock.sendto(data,ADDR)
data,ADDR = udpCliSock.recvfrom(BUFSIZ)
if not data:
break
print(type(data))
print(data.decode())
udpCliSock.close()
分别运行服务器和客户端
服务器端
客户端
当客户端什么都不输入时,关闭套接字连接