python实现socket+threading处理多连接的方法-创新互联

一.运行效果

先说两句，之前我在网上找的相关文章标题上写的是处理多连接，尼玛，全是假的。网上那些，根本不能异步处理多连接，不能主动给客户端发消息。

在服务端控制台输入1，查看在线人数。

给指定客户端发送消息。

二.开发思路

以下说的是服务端开发思路，客户端比较简单就不说了。

首先，需要明白的是socket的accept和recv这两个方法是阻塞线程的。这就意味着我们需要新开线程来处理这两个方法。

具体的程序流程大概是这样的：

1.新开一个线程用于接收新的连接（socket.accept()）

2.当有新的连接时，再新开一个线程，用于接收这个连接的消息（socket.recv()）

3.主线程做为控制台，接收用户的输入，进行其他操作

也就是说，服务端需要为每一个连接创建一个线程。

三.服务端代码

全局部分的代码：

import socket # 导入 socket 模块
from threading import Thread
 
ADDRESS = ('127.0.0.1', 8712) # 绑定地址
 
g_socket_server = None # 负责监听的socket
 
g_conn_pool = [] # 连接池

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。