Python实现一个服务器监听多个客户端请求

概述学习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().@R_404_6889@ #本身是主线程  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,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],data))  t = threading.Thread(target=handle)    #子线程 if __name__ == '__main__':  t.start()  print u'我在%s线程中 ' % threading.current_thread().@R_404_6889@ #本身是主线程  print 'waiting for connecting...'  while True:   clIEntSock,addr   clIEntSock.setblocking(0)   socks.append(clIEntSock) 

此时再去尝试：

客户端随便输都会得到响应。任务达成！

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程小技巧。

您可能感兴趣的文章:python使用socket创建tcp服务器和客户端Python实现的FTP通信客户端与服务器端功能示例Python实现基于多线程、多用户的FTP服务器与客户端功能完整实例python3实现UDP协议的服务器和客户端python3实现TCP协议的简单服务器和客户端案例(分享)Python socket网络编程TCP/IP服务器与客户端通信利用Python中SocketServer 实现客户端与服务器间非阻塞通信python实现TCP服务器端与客户端的方法详解Python实现的简单文件传输服务器和客户端C++、python和go语言实现的简单客户端服务器代码示例 总结

以上是内存溢出为你收集整理的Python实现一个服务器监听多个客户端请求全部内容，希望文章能够帮你解决Python实现一个服务器监听多个客户端请求所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。