1、并發的 socketserver
實作程式的并發執行
Server
import time
from socketserver 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永遠運行下去，除非強制停止程式
Client 1
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
while True:
ret = sk.recv(1024)
print(ret)
Client 2
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
while True:
ret = sk.recv(1024)
print(ret)
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/224437.html
標籤：Python
上一篇：爬取某東購買豬肉的用戶評論，為生產經營提供了方向性參考
下一篇：感謝您的支持