首页 > 代码库 > Python网络编程之socketserver实现多并发

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

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


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

  1. #!/usr/bin/env python

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

  3. import socket

  4. # 创建一个socket对象

  5. obj = socket.socket()

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

  7. obj.connect((‘127.0.0.1‘, 999, ))

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

  9. ret_bytes = obj.recv(1024)

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

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

  12. # 输出内容

  13. print(ret_str)

  14. while True:

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

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

  17.    # 如果输出q则退出

  18.    if inp == "q":

  19.        # 把q发送给服务端

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

  21.        # 退出当前while

  22.        break

  23.    else:

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

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

  26.        # 等待服务端回答

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

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

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

  30.        # 输出结果

  31.        print(ret)

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

  33. obj.close()

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

  1. #!/usr/bin/env python

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

  3. import socketserver

  4. class MyServer(socketserver.BaseRequestHandler):

  5.    def handle(self):

  6.        conn = self.request

  7.        conn.sendall(bytes("你好,欢迎登陆!", encoding="utf-8"))

  8.        while True:

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

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

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

  12.            ret_bytes = conn.recv(1024)

  13.            # 转换成字符串类型

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

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

  16.            print(ret_str)

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

  18.            if ret_str == "q":

  19.                # 则退出循环,等待下个用户输入

  20.                break

  21.            # 给客户端发送内容

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

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

  24. if __name__ == "__main__":

  25.    server = socketserver.ThreadingTCPServer((‘127.0.0.1‘, 999, ), MyServer)

  26.    server.serve_forever()

效果图

技术分享

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


本文出自 “一盏烛光” 博客,谢绝转载!

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