Python使用select实现异步通信

From: http://www.linuxidc.com/Linux/2014-02/97152.htm

 

当一个服务器需要与多个客户端进行通信时,可以使用多进程或者多线程的服务器,也可以使用select模块,它可以实现异步通信。Python中的select模块包含了poll()和select(),select的原型为(rlist,wlist,xlist[,timeout]),其中rlist是等待读取的对象,wlist是等待写入的对象,xlist是等待异常的对象,最后一个是可选对象,指定等待的时间,单位是s.  select()方法的返回值是准备好的对象的三元组,若在timeout的时间内,没有对象准备好,那么返回值将是空的列表。

下面是使用select的服务器:

#!/usr/bin/env python
import socket,select
server=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
server.bind(('',10000))
server.listen(5)
inputs=[server]
while 1:
    rs,ws,es=select.select(inputs,[],[],1)
    for r in rs:
        if r is server:
            clientsock,clientaddr=r.accept();
            inputs.append(clientsock);
        else:
            data=r.recv(1024);
            if not data:
                inputs.remove(r);
            else:
                print data

再编写客户端程序,就可以测试select服务器了,客户端代码为:

#!/usr/bin/env python
import socket
host='127.0.0.1';
port=10000;
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.connect((host,port))
s.send('hello from client')
s.close();

poll实现服务器时,需要用到register()和unregister()方法,作用是加入和移除对象,poll()的返回值包括了文件描述符和事件,polling的事件常量有POLLIN,POLLPRI,POLLPOUT,POLLERR,POLLHUP,POLLVAL,分别表示读取数据,读取紧急数据,文件描述符已经准备好,文件描述符出错,连接丢失,无效请求。

下面是使用poll的服务器程序:

#!/usr/bin/env python
import socket,select
s=socket.socket()
host=""
port=10000
s.bind((host,port))
fdmap={s.fileno():s}
s.listen(5)
p=select.poll()
p.register(s.fileno(),select.POLLIN|select.POLLERR|select.POLLHUP)
while 1:
    events=p.poll(5000)
    if len(events)!=0:
        if events[0][1]==select.POLLIN:
            sock,addr=s.accept()
            buf=sock.recv(8196)
            if len(buf)!=0:
                print buf
                sock.close()
    print "no data"

再编写客户端程序,即可以测试服务器程序,客户端为:

#!/usr/bin/env python
import socket
port=10000
s=socket.socket()
host=socket.gethostname()
s.connect((host,port))
s.send("hello from the client")
s.close()

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/403789.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ant design vue中通知提醒框Notification的使用

效果&#xff1a;点击接口&#xff0c;出现提示弹框&#xff0c;数据获取到后在消失 <template><a-button type"primary" click"openNotification">Open the notification box</a-button> </template> <script> const clo…

Cocos2d-3.x目录介绍分析

一、下载cocos2d的框架 1.下载地址&#xff1a;http://www.cocos2d-x.org/download/version#Cocos2d-x 我们还是选择v3.11吧 比较新的框架 2.下载之后解压这个文件夹就可以了 cocos2d-x-3.11.zip这使我们下载的文件 解压之后&#xff1a; 3. 文件夹目录如图 接下来我们逐步来介…

Mongodb Replica Configure

Mongodb Replica Configure我在配置replica的时候&#xff0c;文档中也把官网的中一些重要解释放在里面了但是并没有用中文做必要的解释&#xff0c;不过都是很容易理解的。说一下环境&#xff0c;这里的环境是&#xff1a;system:centos 64bit 生产环境不用说&#xff0c;直接…

网络IPC非阻塞和异步I/O

通常&#xff0c;recv函数没有数据可用时会阻塞等待。同样地。当套接字输出队列没有祖公空间用来发送消息时&#xff0c;函数send会阻塞。在套接字非阻塞模式下&#xff0c;行为会改变。这种情况下&#xff0c;这些函数不会阻塞而失败&#xff0c;设置errno为EWOULDBLOCK或者EA…

Python网络编程中的select 和 poll I/O复用的简单使用

From: http://www.cnblogs.com/coser/archive/2012/01/06/2315216.html 首先列一下&#xff0c;sellect、poll、epoll三者的区别 select select最早于1983年出现在4.2BSD中&#xff0c;它通过一个select()系统调用来监视多个文件描述符的数组&#xff0c;当select()返回后&…

深拷贝与浅拷贝Object.assign()

深拷贝与浅拷贝 Object.assign()会身拷贝一个复杂类型 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title…

TableView的优化

一&#xff1a;什么是TableView的优化以及为什么要优化 1&#xff09;CPU&#xff08;中央处理器&#xff09;和GPU&#xff08;图形处理器&#xff09;&#xff1a;CPU主要从事逻辑计算的一些工作&#xff1b;GPU主要从事图形处理方面的工作。 2&#xff09;CPU和GPU的共同点&…

Python---静态Web服务器-面向对象开发

1. 以面向对象的方式开发静态Web服务器 实现步骤: 把提供服务的Web服务器抽象成一个类(HTTPWebServer)提供Web服务器的初始化方法&#xff0c;在初始化方法里面创建socket对象提供一个开启Web服务器的方法&#xff0c;让Web服务器处理客户端请求操作。 2. 静态Web服务器-面向…

Androidの网络Http之判断是否连接服务器

1.采用Http方式&#xff1a; public boolean isConnByHttp(){boolean isConn false;URL url;HttpURLConnection conn null;try {url new URL("ttp://wl.daishu001.com/YHDriver.asmx");conn (HttpURLConnection)url.openConnection();conn.setConnectTimeout(100…

linux字符设备驱动之字符之异步通知

在前面的博文中记录的都是应用层主动查询读取驱动按键状态。驱动可不可以在有信号之后&#xff0c;主动上报通知应用层事件呢&#xff1f;当然可以&#xff0c;linux如此博大精深。我们使用异步通信机制&#xff0c;signal的办法实现该功能。 所谓的异步&#xff0c;就是进程可…

【Linux开发】linux设备驱动归纳总结(二):模块的相关基础概念

linux设备驱动归纳总结&#xff08;二&#xff09;&#xff1a;模块的相关基础概念 系统平台&#xff1a;Ubuntu 10.04 开发平台&#xff1a;S3C2440开发板 xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx 一。初探linux内核模块 内…

2020-12-24

console.log()&#xff0c;对于一般对于基本类型number、string、boolean、null、undefined 的输出是可信的。但对于Object 等引用类型来说&#xff0c;则就会出现上述异常打印输出。&#xff08;调试复杂数据类型时候通过打断点来看即可&#xff09; 正常预期 <script>…

XAML实例教程系列 - 资源(Resources)

在Windows 8 Metro应用开发中&#xff0c;XAML主要用于应用界面设计&#xff0c;无论是开发人员还是设计人员经常会设计自定义用户界面或者控件行为&#xff0c;其中会涉及到不同方面的代码设计&#xff0c;例如控件模板&#xff0c;控件样式&#xff0c;动画设计等。为了方便设…

LCD显示深究day01 mmap知识补充

<div class"container clearfix"><main><article><h1 class"csdn_top">Linux中的mmap的使用</h1><div class"article_bar clearfix"><div class"artical_tag"><span class"origina…

Python 多线程抓取网页

From: http://www.cnblogs.com/coser/archive/2012/03/16/2402389.html 最近&#xff0c;一直在做网络爬虫相关的东西。 看了一下开源C写的larbin爬虫&#xff0c;仔细阅读了里面的设计思想和一些关键技术的实现。 1、larbin的URL去重用的很高效的bloom filter算法&#xff1…

解决vue的滚动条监听事件无效 解决vue的滚动条scrollTop距离总是为0无效问题

话不多说 直接上代码&#xff08;方法可以直接复制拿去&#xff0c; html部分需要改成你的元素的ref和点击回到顶部的方法名称&#xff09; html <section ref"scrollbox" class"inner-body"><div>这里放了很多内容 出现了滚动条</div&g…

动态规划练习 13

题目&#xff1a;Longest Ordered Subsequence (POJ 2533) 链接&#xff1a;http://acm.pku.edu.cn/JudgeOnline/problem?id2533 #include <iostream> #include <vector> using namespace std; int LIS(const vector<int> &data) { vector<int> n…

奔跑吧Linux内核初识

断更新博客有一段时间了。入职两年了一家创业公司&#xff0c;那是真心的累&#xff0c;当然了获得了技术上很大的提升。搞了两年的vr产品&#xff0c;唯一遗憾的是&#xff0c;平台是ST单片机&#xff0c;远离了系统级别的知识。回看刚出校园时的三年计划&#xff0c;和第一年…

装载问题

1、回溯法 (1)描述:回溯法是一种选优搜索法&#xff0c;按选优条件向前搜索&#xff0c;以达到目标。但当探索到某一步时&#xff0c;发现原先选择并不优或达不到目标&#xff0c;就退回一步重新选择&#xff0c;这种走不通就退回再走的技术为回溯法。 (2)原理: 回溯法在问题的…

android开发(13) 尝试在流布局中移动控件

我们常用的linearlayout,等都属于流布局&#xff0c;在流布局中如何移动控件呢&#xff1f; 我决定做个尝试。虽然可以使用绝对布局&#xff0c;但我不倾向使用这个布局。那么看看我的方式吧。 记得margin这个属性吗&#xff0c;我们就用来它来控制控件的位置&#xff0c;改动它…