socketserver实现并发（Python）

socketserver实现并发原理：给每一个前来链接的客户端开启一个线程执行通信。也就是给每一个连接“配备”了一个管家。

下面用一个简单的示例来演示socketserver实现并发（一个服务端，两个客户端）：

服务器端：

# Author : Kelvin
# Date : 2019/2/3 21:51
import socketserver
from socket import *

ip_conf = ("127.0.0.1", 8888)
buffer_capcity = 1024


class Mysocket(socketserver.BaseRequestHandler):
    def handle(self):
        print(self.request)
        print(self.client_address)

        while True:
            data = self.request.recv(buffer_capcity).decode("utf8")
            print("服务器收到信息：%s" % data)
            self.request.send("服务器收到信息！".encode("utf8"))


if __name__ == "__main__":
    s = socketserver.ThreadingTCPServer(ip_conf, Mysocket)
    s.serve_forever()

客户端一：

# Author : Kelvin
# Date : 2019/2/3 21:51
from socket import *

ip_conf = ("127.0.0.1", 8888)
buffer_capcity = 1024
client = socket(AF_INET, SOCK_STREAM)
client.connect(ip_conf)
while True:
    client.send(input("客户端1输入：").encode("utf8"))
    data = client.recv(buffer_capcity).decode("utf8")
    print(data)

客户端二：

# Author : Kelvin
# Date : 2019/2/3 21:51
from socket import *

ip_conf = ("127.0.0.1", 8888)
buffer_capcity = 1024
client = socket(AF_INET, SOCK_STREAM)
client.connect(ip_conf)
while True:
    client.send(input("客户端2输入：").encode("utf8"))
    data = client.recv(buffer_capcity).decode("utf8")
    print(data)

打印结果：

服务器输出：

客户端一：

客户端二：