Python实现一个服务器监听多个客户端请求
学习Python网络通信的时候发现书上只有一个服务端对应一个客户端的情形，于是自己想自己动手实现一个服务端响应多个客户端。
首先建立服务器的socket来监听客户端的请求：
tcpSerSock=socket(AF_INET,SOCK_STREAM) tcpSerSock.bind(ADDR) tcpSerSock.listen(5)
这样服务器的监听socket就建好了。
接下来的思路是，如果要监听多个客户端，则
tcpSerSock.accept() #（accept()是阻塞式的）
必须放进一个while循环（不放进循环监听一次就没了）。然而，这里就有问题了。如果按照一对一的那种处理顺序，客户端A连进来后，程序顺序向下执行，服务端要再写一个while循环，用来处理客户端A的请求，如果此时客户端B再来请求，服务器将接收不到。于是，很自然想到，将监听和处理放到不同的线程进行处理。我选择将监听放入主线程，将处理放进子线程。该服务器功能为接收到客户端的数据加上时间戳后返回给客户端。服务端完整代码如下：
#coding=utf-8
#!/usr/bin/env python
'''''
author:Mr.Jing
created on Fri Sep 22 14:29:03 2017
platfrom:win10,python2.7
'''
from socket import *
from time import ctime
import threading
import time
HOST=''
PORT=2159
BUFSIZ=1024
ADDR = (HOST,PORT)
tcpSerSock=socket(AF_INET,SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)
socks=[] #放每个客户端的socket
def handle():
while True:
for s in socks:
data = s.recv(BUFSIZ)
if not data:
socks.remove(s)
continue
s.send('[%s],%s' % (ctime(), data)) #加上时间戳返回
t = threading.Thread(target=handle) #子线程
if __name__ == '__main__':
t.start()
print u'我在%s线程中 ' % threading.current_thread().name #本身是主线程
print 'waiting for connecting...'
while True:
clientSock,addr = tcpSerSock.accept()
print 'connected from:', addr
socks.append(clientSock)
两个客户端A和B同时连接，服务器输出：
可以看到服务端是可以相应多个客户端的。
客户端A发条消息试试？
服务器返回来了带时间戳的消息，goodjob。
那另一个呢？
很棒。服务器都能做出响应。
再发一条试试？
发现服务器没响应了，这是怎么回事呢?
经过仔细勘察发现是因为这句：
data = s.recv(BUFSIZ)
因为recv方法是阻塞的，也就是说，当轮训到某个客户端，比如A，这句等待A发消息，不发消息就不往下走，所以此时B再去发消息的话服务器就收不到了。
那该怎么办呢？
很容易想到，将其设为非阻塞就好了。但上网找了好久，虽然找到可以用setblocking(0) 将套接字设为非阻塞，然而具体怎么用却很少有人讲清楚。查资料后终于搞明白，非阻塞的recv方法会继续向下执行，若超时得不到数据则会抛出异常。
修改后的代码如下：
#coding=utf-8
#!/usr/bin/env python
'''''
author:Mr.Jing
created on Fri Sep 22 14:29:03 2017
platfrom:win10,python2.7
'''
from socket import *
from time import ctime
import threading
import time
HOST=''
PORT=2159
BUFSIZ=1024
ADDR = (HOST,PORT)
tcpSerSock=socket(AF_INET,SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)
socks=[] #放每个客户端的socket
def handle():
while True:
for s in socks:
try:
data = s.recv(BUFSIZ) #到这里程序继续向下执行
except Exception, e:
continue
if not data:
socks.remove(s)
continue
s.send('[%s],%s' % (ctime(), data))
t = threading.Thread(target=handle) #子线程
if __name__ == '__main__':
t.start()
print u'我在%s线程中 ' % threading.current_thread().name #本身是主线程
print 'waiting for connecting...'
while True:
clientSock,addr = tcpSerSock.accept()
print 'connected from:', addr
clientSock.setblocking(0)
socks.append(clientSock)
此时再去尝试：
客户端随便输都会得到响应。任务达成！
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本文主要介绍了numpy.unique()使用方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-02-02
字符串是 Python 中最常用的数据类型。我们可以使用引号('或")来创建字符串。创建字符串很简单，只要为变量分配一个值即可2021-11-11
Python flashtext文本搜索和替换操作库功能使用探索
本文将深入介绍Python flashtext库,包括其基本用法、功能特性、示例代码以及实际应用场景,以帮助大家更好地利用这个有用的工具2024-01-01
这篇文章主要介绍了Python实现判断并移除列表指定位置元素的方法,涉及Python针对列表的索引范围判断及元素删除等相关操作技巧,需要的朋友可以参考下2018-04-04
python opencv把一张图片嵌入（叠加）到另一张图片上的实现代码
这篇文章主要介绍了python opencv把一张图片嵌入（叠加）到另一张图片上,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-06-06
这篇文章主要介绍了python的XIsxWriter操作Excel示例详解,xlsxwriter是一个专门用于创建、写入和操作Excel文件的Python模块,它提供了丰富的功能和选项,能够创建复杂的Excel文档,需要的朋友可以参考下2023-09-09
这篇文章主要介绍了Python ini文件常用操作方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-04-04
本篇文章主要介绍了Python2中文处理纪要的实现方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-03-03
15个应该掌握的Jupyter Notebook使用技巧(小结)
这篇文章主要介绍了15个应该掌握的Jupyter Notebook使用技巧(小结)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-09-09
这篇文章主要为大家总结一下python 中常用的是个内置函数的使用方法，文中的示例代码讲解详细，对我们学习Python有一定的帮助，需要的可以参考一下2022-03-03
最新评论