需求描述

目前我们开发的TCP服务端程序只能服务于一个客户端,如何开发一个多任务版的TCP服务端程序能够服务于多个客户端呢?
完成多任务,可以使用线程,比进程更加节省内存资源。

实现步骤

练习:多任务版TCP服务器 - 图1

  1. 编写一个TCP服务端程序,循环等待接受客户端的连接请求
  2. 当客户端和服务端建立连接成功,创建子线程,使用子线程专门处理客户端的请求,防止主线程阻塞
  3. 把创建的子线程设置成为守护主线程,防止主线程无法退出,避免主线程结束时,子线程还在运行。

    示例代码

    ```python import socket import threading

处理客户端的请求操作

def handle_client_request(service_client_socket, ip_port):

  1. # 循环接收客户端发送的数据
  2. while True:
  3. # 接收客户端发送的数据
  4. recv_data = service_client_socket.recv(1024)
  5. # 容器类型判断是否有数据可以直接使用if语句进行判断,如果容器类型里面有数据表示条件成立,否则条件失败
  6. # 容器类型: 列表、字典、元组、字符串、set、range、二进制数据
  7. if recv_data:
  8. print(recv_data.decode("gbk"), ip_port)
  9. # 回复
  10. service_client_socket.send("ok,问题正在处理中...".encode("gbk"))
  11. else:
  12. print("客户端下线了:", ip_port)
  13. break
  14. # 终止和客户端进行通信
  15. service_client_socket.close()

if name == ‘main‘:

  1. # 创建tcp服务端套接字
  2. tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  3. # 设置端口号复用,让程序退出端口号立即释放
  4. tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
  5. # 绑定端口号
  6. tcp_server_socket.bind(("", 9090))
  7. # 设置监听, listen后的套接字是被动套接字,只负责接收客户端的连接请求
  8. tcp_server_socket.listen(128)
  9. # 循环等待接收客户端的连接请求
  10. while True:
  11. # 等待接收客户端的连接请求
  12. service_client_socket, ip_port = tcp_server_socket.accept()
  13. print("客户端连接成功:", ip_port)
  14. # 当客户端和服务端建立连接成功以后,需要创建一个子线程,不同子线程负责接收不同客户端的消息
  15. sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
  16. # 设置守护主线程
  17. sub_thread.setDaemon(True)
  18. # 启动子线程
  19. sub_thread.start()
  20. # tcp服务端套接字可以不需要关闭,因为服务端程序需要一直运行
  21. # tcp_server_socket.close()
  1. **执行结果:**

客户端连接成功: (‘172.16.47.209’, 51528) 客户端连接成功: (‘172.16.47.209’, 51714) hello1 (‘172.16.47.209’, 51528) hello2 (‘172.16.47.209’, 51714)

  1. <a name="StcjF"></a>
  2. ### 4. 小结
  3. 编写一个TCP服务端程序,循环等待接受客户端的连接请求
  4. ```python
  5. while True:
  6. service_client_socket, ip_port = tcp_server_socket.accept()

当客户端和服务端建立连接成功,创建子线程,使用子线程专门处理客户端的请求,防止主线程阻塞

  1. while True:
  2. service_client_socket, ip_port = tcp_server_socket.accept()
  3. sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
  4. sub_thread.start()

把创建的子线程设置成为守护主线程,防止主线程退出后,子线程不结束。

  1. while True:
  2. service_client_socket, ip_port = tcp_server_socket.accept()
  3. sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
  4. sub_thread.daemon = True
  5. sub_thread.start()