您的位置:首页 > 文旅 > 美景 > 深圳品牌策划公司推荐_市场调研公司存在的意义_搜索大全引擎入口网站_志鸿优化设计答案

深圳品牌策划公司推荐_市场调研公司存在的意义_搜索大全引擎入口网站_志鸿优化设计答案

2025/4/29 11:40:10 来源:https://blog.csdn.net/lingsaner/article/details/147595933  浏览:    关键词:深圳品牌策划公司推荐_市场调研公司存在的意义_搜索大全引擎入口网站_志鸿优化设计答案
深圳品牌策划公司推荐_市场调研公司存在的意义_搜索大全引擎入口网站_志鸿优化设计答案

1. 需求

目前我们开发的TCP服务端程序只能服务于一个客户端,如何开发一个多任务版的TCP服务端程序能够服务于多个客户端呢?

完成多任务,可以使用线程,比进程更加节省内存资源。

2. 具体实现步骤

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

3. 实现代码:

# 导入socket模块,用于实现网络通信功能
import socket
# 导入threading模块,用于创建和管理线程
import threading# 定义处理客户端请求的函数
def handle_client_request(service_client_socket, ip_port):# 无限循环,持续接收客户端消息while True:# 接收来自客户端的数据,最大接收1024字节recv_data = service_client_socket.recv(1024)# 如果接收到的数据不为空if recv_data:# 打印客户端发送的消息,格式为“客户端IP:端口说:消息内容”print("客户端%s:%s说:%s" % (ip_port[0], ip_port[1], recv_data.decode()))# 向客户端发送响应消息“ok,问题正在处理中...”,并将其编码为utf-8格式service_client_socket.send("ok,问题正在处理中...".encode('utf-8'))else:# 如果没有接收到数据,说明客户端已断开连接print("客户端%s:%s已经退出聊天室" % (ip_port[0], ip_port[1]))# 跳出循环break# 关闭与客户端的连接service_client_socket.close()# 如果此脚本作为主程序运行
if __name__ == '__main__':# 创建一个TCP/IP套接字对象server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 绑定服务器地址和端口,此处使用的是本地地址和8080端口server_socket.bind(("", 8080))# 设置监听队列长度为128server_socket.listen(128)# 无限循环,等待客户端连接while True:# 接受客户端连接,返回一个新的套接字对象和客户端地址信息service_client_socket, ip_port = server_socket.accept()# 打印客户端连接信息,格式为“客户端IP:端口已经进入聊天室”print("客户端%s:%s已经进入聊天室" % (ip_port[0], ip_port[1]))# 创建一个新线程来处理客户端请求sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))# 设置线程为守护线程,主线程结束时子线程也会被终止sub_thread.daemon = True# 启动线程sub_thread.start()

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com