十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
小编给大家分享一下Python如何实现一个服务器监听多个客户端请求,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!
成都创新互联公司是一家集成都做网站、网站制作、成都外贸网站建设、网站页面设计、网站优化SEO优化为一体的专业的建站公司,已为成都等多地近百家企业提供网站建设服务。追求良好的浏览体验,以探求精品塑造与理念升华,设计最适合用户的网站页面。 合作只是第一步,服务才是根本,我们始终坚持讲诚信,负责任的原则,为您进行细心、贴心、认真的服务,与众多客户在蓬勃发展的市场环境中,互促共生。首先建立服务器的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)
此时再去尝试:
客户端随便输都会得到响应。任务达成!
看完了这篇文章,相信你对“Python如何实现一个服务器监听多个客户端请求”有了一定的了解,如果想了解更多相关知识,欢迎关注创新互联成都网站设计公司行业资讯频道,感谢各位的阅读!
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。