7.6 基于UDP的socket
无连接的,不必与对方建立连接,而是直接把数据发送给对方;
适用于一次传输销量数据结构,可靠性不高的应用环境,因为其传输速率快
# 服务端
import socket
server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) #这里的餐宿已经改成UDP格式了
server.bind(('127.0.0.1',9000))
while 1:
from_client_data = server.recvfrom(1024)
print(f"来自{from_client_data[1]}的消息:{from_client_data[0].decode('utf-8')}")
se = input('>>>').encode('utf-8')
server.sendto(se,from_client_data[1])
# 客户端
import socket
client = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) #这里的餐宿已经改成UDP格式了
while 1:
se = input('>>>').encode('utf-8')
client.sendto(se,('127.0.0.1',9000))
re = client.recvfrom(1024)
print(f"来自{re[1]}的消息:{re[0].decode('utf-8')}")
# 虽然可以实现能够与多个人进行数据交换,但实际上是在发送完数据后关闭了链接,并不是真正意义上的并行运行
7.7 socketserver实现并行运行
服务端
import socketserver
class Myserver(socketserver.BaseRequestHandler): # 定义的类名可以任意取,继承的父类固定格式
def handle(self): # 必须要使用handle这个名字
print('listening_in_handle')
while 1:
from_client_data = self.request.recv(1024).decode('utf-8')
print(from_client_data)
to_client_data = input('>>>').strip()
self.request.send(to_client_data.encode('utf-8'))
if __name__ == '__main__':
ip_port = ('127.0.0.1',8006)
# socketserver.TCPServer.allow_reuse_address = True # 允许端口重复使用
server = socketserver.ThreadingTCPServer(ip_port,Myserver) # 固定格式
# 对 socketserver.ThreadingTCPServer 类实例化对象,将ip地址,端口号以及自己定义的类名传入,并返回一个对象
server.serve_forever() # 固定格式,对象执行serve_forever方法,开启服务端
print('listening_begin')
客户端
可以设置多个客户端
import socket
client = socket.socket()
client.connect(('127.0.0.1',8006))
while 1:
se = input('>>>').strip()
client.send(se.encode('utf-8'))
re = client.recv(1024).decode('utf-8')
print(f"the massage from server:{re}")
client.close()
分析
在整个socketserver这个模块中,最主要的两件事情:
1、一个是循环建立链接的部分,每个客户端的链接都可以连接成功
2、一个通讯循环的部分,就是每个客户端链接成功之后,要循环的和客户端进行通信。
看代码中的:server=socketserver.ThreadingTCPServer(('127.0.0.1',8006),MyServer)
通过print(socketserver.ThreadingTCPServer.mro())查看对象继承的mro顺序,找到它的继承
查找属性的顺序:ThreadingTCPServer->ThreadingMixIn->TCPServer->BaseServer
建立循环连接
**实例化得到server,先找ThreadMinxIn中的__init__方法,发现没有init方法,然后找类ThreadingTCPServer的__init__,在TCPServer中找到,在里面创建了socket对象,进而执行server_bind(相当于bind),server_active(点进去看执行了listen)
**找server下的serve_forever,在BaseServer中找到,进而执行self._handle_request_noblock(),该方法同样是在BaseServer中
**执行self._handle_request_noblock()进而执行request, client_address = self.get_request()(就是TCPServer中的self.socket.accept()),然后执行self.process_request(request, client_address)
**在ThreadingMixIn中找到process_request,开启多线程应对并发,进而执行process_request_thread,执行self.finish_request(request, client_address)
建立通讯:
在BaseServer中找到finish_request,触发我们自己定义的类的实例化,去找__init__方法,其中:
tcp:
self.server即套接字对象
self.request即一个链接
self.client_address即客户端地址
udp:
self.request是一个元组(第一个元素是客户端发来的数据,第二部分是服务端的udp套接字对象),如(b'adsf', <socket.socket fd=200, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
self.client_address即客户端地址