4Python全栈之路系列之socketsesrver实现多并发
Python全栈之路系列之socketserver实现多并发
利用socketserver实现多并发，socketserver内部会调用socket模块进行功能上的实现
client.py客户端脚本文件内容
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
#!/usr/bin/env python# _*_ coding:utf-8 _*_import socket
# 创建一个socket对象obj = socket.socket()
# 制定服务端的IP地址和端口obj.connect(('127.0.0.1', 999, ))
# 阻塞，等待服务端发送内容，接受服务端发送过来的内容，最大接受1024字节ret_bytes = obj.recv(1024)
# 因为服务端发送过来的是字节，所以我们需要把字节转换为字符串进行输出ret_str = str(ret_bytes, encoding="utf-8")
# 输出内容print(ret_str)
while True:
# 当进入连接的时候，提示让用户输入内容
inp = input("Client请输入要发送的内容>>> ")
# 如果输出q则退出
if inp == "q":
# 把q发送给服务端
obj.sendall(bytes(inp, encoding="utf-8"))
# 退出当前while
break
else:
# 否则就把用户输入的内容发送给用户
obj.sendall(bytes(inp, encoding="utf-8"))
# 等待服务端回答
print("正在等待Server输入内容......")
# 获取服务端发送过来的结果
ret = str(obj.recv(1024), encoding="utf-8")
# 输出结果
print(ret)
# 连接完成之后关闭链接obj.close() |
server.py服务端脚本文件内容
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
#!/usr/bin/env python# _*_ coding:utf-8 _*_import socketserver
class MyServer(socketserver.BaseRequestHandler):
def handle(self):
conn = self.request
conn.sendall(bytes("你好，欢迎登陆！", encoding="utf-8"))
while True:
# 输出等待客户端发送内容
print("正在等待Client输入内容......")
# 接收客户端发送过来的内容
ret_bytes = conn.recv(1024)
# 转换成字符串类型
ret_str = str(ret_bytes, encoding="utf-8")
# 输出用户发送过来的内容
print(ret_str)
# 如果用户输入的是q
if ret_str == "q":
# 则退出循环，等待下个用户输入
break
# 给客户端发送内容
inp = input("Service请输入要发送的内容>>> ")
conn.sendall(bytes(inp, encoding="utf-8"))
if __name__ == "__main__":
server = socketserver.ThreadingTCPServer(('127.0.0.1', 999, ), MyServer)
server.serve_forever()
|
效果图
同时打开多个客户端，服务端也不会出现错误
本文转自 Edenwy 51CTO博客，原文链接：http://blog.51cto.com/edeny/1924867，如需转载请自行联系原作者