Python网络编程之socketserver实现多并发

利用socketserver实现多并发，socketserver内部会调用socket模块进行功能上的实现

---

client.py客户端脚本文件内容

1. #!/usr/bin/env python

2. # _*_ coding:utf-8 _*_

4. import socket

6. # 创建一个socket对象

7. obj = socket.socket()

9. # 制定服务端的IP地址和端口

10. obj.connect(('127.0.0.1', 999, ))

12. # 阻塞，等待服务端发送内容，接受服务端发送过来的内容，最大接受1024字节

13. ret_bytes = obj.recv(1024)

15. # 因为服务端发送过来的是字节，所以我们需要把字节转换为字符串进行输出

16. ret_str = str(ret_bytes, encoding="utf-8")

18. # 输出内容

19. print(ret_str)

21. while True:

22.    # 当进入连接的时候，提示让用户输入内容

23.    inp = input("Client请输入要发送的内容>>> ")

24.    # 如果输出q则退出

25.    if inp == "q":

26.        # 把q发送给服务端

27.        obj.sendall(bytes(inp, encoding="utf-8"))

28.        # 退出当前while

29.        break

30.    else:

31.        # 否则就把用户输入的内容发送给用户

32.        obj.sendall(bytes(inp, encoding="utf-8"))

33.        # 等待服务端回答

34.        print("正在等待Server输入内容......")

35.        # 获取服务端发送过来的结果

36.        ret = str(obj.recv(1024), encoding="utf-8")

37.        # 输出结果

38.        print(ret)

40. # 连接完成之后关闭链接

41. obj.close()

server.py服务端脚本文件内容

1. #!/usr/bin/env python

2. # _*_ coding:utf-8 _*_

4. import socketserver

6. class MyServer(socketserver.BaseRequestHandler):

8.    def handle(self):

10.        conn = self.request

12.        conn.sendall(bytes("你好，欢迎登陆！", encoding="utf-8"))

14.        while True:

15.            # 输出等待客户端发送内容

16.            print("正在等待Client输入内容......")

17.            # 接收客户端发送过来的内容

18.            ret_bytes = conn.recv(1024)

19.            # 转换成字符串类型

20.            ret_str = str(ret_bytes, encoding="utf-8")

21.            # 输出用户发送过来的内容

22.            print(ret_str)

24.            # 如果用户输入的是q

25.            if ret_str == "q":

26.                # 则退出循环，等待下个用户输入

27.                break

28.            # 给客户端发送内容

29.            inp = input("Service请输入要发送的内容>>> ")

30.            conn.sendall(bytes(inp, encoding="utf-8"))

32. if __name__ == "__main__":

33.    server = socketserver.ThreadingTCPServer(('127.0.0.1', 999, ), MyServer)

34.    server.serve_forever()

效果图

同时打开多个客户端，服务端也不会出现错误