Python网络编程使用select实现socket全双工异步通信功能示例
本文实例讲述了Python网络编程使用select实现socket全双工异步通信功能。分享给大家供大家参考,具体如下:
在前面一篇《Python网络编程之TCP套接字简单用法》中,我们实现了tcp客户端与服务器的通信,但是功能十分局限,发送消息与接收消息不能同时进行。
接下来我将通过select这个模块,来实现全双工通信(随时可以接收信息以及发送信息),当然,用多线程也可以完成,这是后话。
那么,select为何物?
select -在单线程网络服务中器程序中,管理多个套接字连接
select的原型为(rlist,wlist,xlist[,timeout]),其中rlist是等待读取的对象,wlist是等待写入的对象,xlist是等待异常的对象,最后一个是可选对象,指定等待的时间,单位是s.
select()方法的返回值是准备好的对象的三元组,若在timeout的时间内,没有对象准备好,那么返回值将是空的列表。
它采用的是轮询的方式来实现异步通信的。
在下面程序中,目前主要支持1对1通信,当双方任何一方发送字符串‘88'时,表示结束通信。
下面我们来看看具体实现:
首先是服务器。
#!/usr/bin/python 'test TCP server' from socket import * from time import ctime import select import sys HOST = '' PORT = 21567 BUFSIZ = 1024 ADDR = (HOST, PORT) tcpSerSock = socket(AF_INET, SOCK_STREAM) tcpSerSock.bind(ADDR) tcpSerSock.listen(5) input = [tcpSerSock, sys.stdin] #input是一个列表,初始有欢迎套接字以及标准输入 while True: print 'waiting for connection...' tcpCliSock, addr = tcpSerSock.accept() print '...connected from:',addr input.append(tcpCliSock) #将服务套接字加入到input列表中 while True: readyInput,readyOutput,readyException = select.select(input,[],[]) #从input中选择,轮流处理client的请求连接(tcpSerSock),client发送来的消息(tcpCliSock),及服务器端的发送消息(stdin) for indata in readyInput: if indata==tcpCliSock: #处理client发送来的消息 data = tcpCliSock.recv(BUFSIZ) print data if data=='88': input.remove(tcpCliSock) break else: #处理服务器端的发送消息 data = raw_input('>') if data=='88': tcpCliSock.send('%s' %(data)) input.remove(tcpCliSock) break tcpCliSock.send('[%s] %s' %(ctime(), data)) if data=='88': break tcpCliSock.close() tcpSerSock.close()
以下是客户端的代码,非常类似,只是与服务器相比不需要处理请求信息而已。
#!/usr/bin/python 'test tcp client' from socket import * from time import ctime import select import sys HOST = 'localhost' PORT = 21567 BUFSIZ = 1024 ADDR = (HOST, PORT) tcpCliSock = socket(AF_INET, SOCK_STREAM) tcpCliSock.connect(ADDR) input = [tcpCliSock,sys.stdin] while True: readyInput,readyOutput,readyException = select.select(input,[],[]) for indata in readyInput: if indata==tcpCliSock: data = tcpCliSock.recv(BUFSIZ) print data if data=='88': break else: data = raw_input('>') if data=='88': tcpCliSock.send('%s' %(data)) break tcpCliSock.send('[%s] %s' %(ctime(), data)) if data=='88': break tcpCliSock.close()
目前为止,已经实现了一对一全双工聊天通信啦。
下面当然要思考下,如何实现多对多通信呢?
我们知道,一个服务器可以为多个客户端服务,即,服务器与客户端本身有着一对多的关系,那么,我们是否可以利用服务器作为中间人,用来传达信息,从而实现多对多通信呢?
举个例子,A想要和B通信,则A将信息发送给服务器,然后再通过服务器转发给B。按照这个思路去写,完成多对多通信应该是可以的,有兴趣的可以尝试一下。
更多关于Python相关内容可查看本站专题:《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
您可能感兴趣的文章:
- python服务器与android客户端socket通信实例
- python实现简单socket通信的方法
- 结合Python的SimpleHTTPServer源码来解析socket通信
- Python与Java间Socket通信实例代码
- php实现与python进行socket通信的方法示例
- Python通过websocket与js客户端通信示例分析
- python网络编程之TCP通信实例和socketserver框架使用例子
- 利用Python中SocketServer 实现客户端与服务器间非阻塞通信
- Python socket网络编程TCP/IP服务器与客户端通信
- Python3 socket同步通信简单示例
- Python基于socket模块实现UDP通信功能示例
- Python socket实现的简单通信功能示例
- 示例:PHP使用socket协议实现的即时通信功能
- Python基于socket模块实现UDP通信功能示例
- python网络编程-使用socket实现S/C之间的UDP通信
- Python socket实现的简单通信功能示例
- python使用fcntl模块实现程序加锁功能示例
- iOS 使用 socket 实现即时通信示例(非第三方库)
- 使用select实现多并发的socket的功能
- python——使用socket模块实现客户端与服务端通信
- Linux中使用C语言实现基于UDP协议的Socket通信示例
- Python使用PyCrypto实现AES加密功能示例
- Python+Socket实现基于UDP协议的局域网广播功能示例
- Java开发实现的Socket双向通信功能示例
- Python Socket实现简单TCP Server/client功能示例
- Python网络编程基于多线程实现多用户全双工聊天功能示例
- python实现select和epoll模型socket网络编程 推荐
- Python+Socket实现基于TCP协议的客户与服务端中文自动回复聊天功能示例
- python网络编程-使用socket实现S/C之间的tcp通信
- Python的socket网络编程1 sock简单通信实现
- 使用python实现strcmp函数功能示例
- php实现与python进行socket通信的方法示例