1、并发的 socketserver
实现程序的并发执行
Server
<code class="language-python">import time from <a href="https://www.gaodaima.com/tag/socketserver" title="查看更多关于socketserver的文章" target="_blank">socketserver</a> import BaseRequestHandler,ThreadingTCPServer # BaseRequestHandler 基础请求操作符 # ThreadingTCPServer 线程实现的基于tcp协议的server class Myserver(BaseRequestHandler): # 创建一个Myserver类继承BaseRequestHandler def handle(self): n = 0 while True: self.request.send(str(n).encode("utf-8")) # self.request == conn(server的IP) n += 1 time.sleep(0.5) server = ThreadingTCPServer(("127.0.0.1",9001),Myserver) # 创建一个server将服务地址绑定到127.0.0.1:9001 server.serve_forever() # 让server永远运行下去,除非强制停止程序 </code>
www#gaodaima.com来源gaodai$ma#com搞$代*码网搞代码
Client 1
<code class="language-python">import socket sk = socket.socket() sk.connect(("127.0.0.1",9001)) while True: ret = sk.recv(1024) print(ret) </code>
Client 2
<code class="language-python">import socket sk = socket.socket() sk.connect(("127.0.0.1",9001)) while True: ret = sk.recv(1024) print(ret) </code>