from socketserver import BaseRequestHandler, ThreadingTCPServer
class Handler(BaseRequestHandler):
def setup(self) -> None:
self.request.settimeout(1)
def handle(self):
while 1:
try:
data = "这是主机端的信息"
self.request.sendall(data.encode("utf-8"))
except BaseException as e:
print(e)
print("关闭连接:{}".format(self.client_address[0]))
break
if __name__ == '__main__':
host = ("localhost", 8000)
server = ThreadingTCPServer(host, Handler)
server.serve_forever()
import socket
import time
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = ("localhost", 8000)
client.connect(host)
while 1:
data = client.recv(2000)
if len(data) <= 0:
break
print("从主机端接受信息:{}".format(data.decode()))
# time.sleep(1)
这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。
V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。
V2EX is a community of developers, designers and creative people.