python中asyncore异步模块的实现
作者:TypicalSpider 发布时间:2023-10-23 00:50:07
asyncore即是一个异步的socket封装,特别是dispatcher类中包含了很多异步调用的socket操作方法。
模块常见方法
这个模块是socket的异步实现,此模块中的一些类和方法:
asyncore.core
输入一个轮询循环直到通过计数或打开的通道已关闭
asyncore.dispatcher
dispatcher类是一个底层socket类的包装对象。要使它更有用, 它有一部分事件处理方法被异步循环调用。否则它就是一个标准的非阻塞socket对象。
底层的事件在特定事件或特定的连接状态告诉异步循环,某些高级事件发生了。例如,我们要求一个socket连接到另一个主机。
handle_connected():第一次读或写事件。
handle_close():读事件没有数据可用。
handle_accept():读事件监听一个socket。
handle_read():在异步循环察觉到通道呼叫read()时调用。
handle_write():在异步循环检测到一个socket可写时调用,例如:
def handle_write(self):
sent = self.send(self.buff)
self.buffer = self.buffer[sent:]
handle_expt():当有OOB数据套接字(socket)连接,这几乎永远不会发生,因为OOB精细地支持和很少使用。
handle_connect():当socket创建一个连接时调用。
handle_close():当socket连接关闭时调用。
handle_error():当引发一个异常并没有其他处理时调用。
handle_accept:当本地监听通道与远程端建立连接(被动连接)时调用。
readable():每次在异步循环确定是否添加一个通道socket到读事件列表时调用,默认都为True。
writable():每次在异步循环确定是否添加一个通道socket到写事件列表时调用, 默认为True。
create_socket():与创建标准socket的时候相同。
connect():与标准socket的端口设置是相同, 接受一个元组第一个参数为主机地址,第二个参数是端口号。
send():向远程端socket发送数据。
recv():从远程端socket读取最多buffer_size的数据。一个空的字符串意味着从另一端通道已关闭。
listen():监听socket连接。
bind():将socket绑定到地址。
accept():接受一个连接,必须绑定到一个socket和监听地址。
close():关闭socket。
asyncore.dispatcher_with_send
dispatcher子类添加了简单的缓冲输出功能用于简单的客户,更复杂的使用asynchat.async_chat。
asyncore.file_dispatcher
file_dispatcher需要一个文件描述符或文件对象地图以及一个可选的参数,包装,使用调查()或循环()函数。如果提供一个文件对象或任何fileno()方法,该方法将调用和传递到file_wrapper构造函数。可用性:UNIX。
asyncore.file_wrapper
file_wrapper需要一个整数文件描述符并调用os.dup()复制处理,这样原来的处理可能是独立于file_wrapper关闭。这个类实现足够的方法来模拟一个套接字使用file_dispatcher类。可用性:UNIX。
asyncore 实例
一个http client的实现
import socket
import asyncore
class Client(asyncore.dispatcher):
def __init__(self, host, path):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((host,80))
self.buffer = 'GET %s HTTP/1.0\r\n\r\n' % path
def handle_connect(self):
pass
def handle_close(self):
self.close()
def handle_read(self):
print self.recv(8192)
def writable(self):
return (len(self.buffer) >0)
def handle_write(self):
sent= self.send(self.buffer)
self.buffer = self.buffer[sent:]
client= Client('www.python.org','/')
asyncore.loop()
服务器接受连接和分配任务
import socket
import asyncore
class EchoHandler(asyncore.dispatcher_with_send):
def handle_read(self):
data= self.recv(8192)
if data:
self.send(data)
class EchoServer(asyncore.dispatcher):
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.set_reuse_add()
self.bind((host, port))
self.listen(5)
def handle_accept(self):
pair= self.accept()
if pair is not None:
sock, addr= pair
print 'Incoming connection from %s' % repr(addr)
handler= EchoHandler(sock)
server= EchoServer('localhost',8080)
asyncore.loop()
利用asyncore的端口映射(端口转发)
import socket,asyncore
class forwarder(asyncore.dispatcher):
def __init__(self, ip, port, remoteip,remoteport,backlog=5):
asyncore.dispatcher.__init__(self)
self.remoteip=remoteip
self.remoteport=remoteport
self.create_socket(socket.AF_INET,socket.SOCK_STREAM)
self.set_reuse_addr()
self.bind((ip,port))
self.listen(backlog)
def handle_accept(self):
conn, addr= self.accept()
# print '--- Connect --- '
sender(receiver(conn),self.remoteip,self.remoteport)
class receiver(asyncore.dispatcher):
def __init__(self,conn):
asyncore.dispatcher.__init__(self,conn)
self.from_remote_buffer=''
self.to_remote_buffer=''
self.sender=None
def handle_connect(self):
pass
def handle_read(self):
read= self.recv(4096)
# print '%04i -->'%len(read)
self.from_remote_buffer+= read
def writable(self):
return (len(self.to_remote_buffer) >0)
def handle_write(self):
sent= self.send(self.to_remote_buffer)
# print '%04i <--'%sent
self.to_remote_buffer= self.to_remote_buffer[sent:]
def handle_close(self):
self.close()
if self.sender:
self.sender.close()
class sender(asyncore.dispatcher):
def __init__(self, receiver, remoteaddr,remoteport):
asyncore.dispatcher.__init__(self)
self.receiver=receiver
receiver.sender=self
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((remoteaddr, remoteport))
def handle_connect(self):
pass
def handle_read(self):
read= self.recv(4096)
# print '<-- %04i'%len(read)
self.receiver.to_remote_buffer+= read
def writable(self):
return (len(self.receiver.from_remote_buffer) >0)
def handle_write(self):
sent= self.send(self.receiver.from_remote_buffer)
# print '--> %04i'%sent
self.receiver.from_remote_buffer= self.receiver.from_remote_buffer[sent:]
def handle_close(self):
self.close()
self.receiver.close()
if __name__=='__main__':
import optparse
parser= optparse.OptionParser()
parser.add_option(
'-l','--local-ip',
dest='local_ip',default='127.0.0.1',
help='Local IP address to bind to')
parser.add_option(
'-p','--local-port',
type='int',dest='local_port',default=80,
help='Local port to bind to')
parser.add_option(
'-r','--remote-ip',dest='remote_ip',
help='Local IP address to bind to')
parser.add_option(
'-P','--remote-port',
type='int',dest='remote_port',default=80,
help='Remote port to bind to')
options, args= parser.parse_args()
forwarder(options.local_ip,options.local_port,options.remote_ip,options.remote_port)
asyncore.loop()
来源:https://blog.csdn.net/qq_41962612/article/details/128712838
猜你喜欢
- 写接口case时,有时需要对cae做一些共性的操作,最典型的场景如:获取case执行时间、打印log等。有没有一种办法来集中处理共性操作从而
- 本文实例为大家分享了python实现opencv+scoket网络实时图传的具体代码,供大家参考,具体内容如下服务器分析:1.先通过在服务器
- 漏斗图漏斗图是由Light等在1984年提出,一般以单个研究的效应量为横坐标,样本含量为纵坐标做的散点图。效应量可以为RR、OR和死亡比或者
- 本文实例讲述了Python进阶之使用selenium爬取淘宝商品信息功能。分享给大家供大家参考,具体如下:# encoding=utf-8_
- Pyqt5安装并配置到pycharm方法:教你如何用pycharm安装pyqt5及其相关配置一、简介QLabel是界面中的标签类,继承自QF
- 目录1、封装1.1 私有属性和私有方法2、继承2.1 方法的重写2.2 在子类方法中调用父类方法2.3 多继承2.4 新式类和经典类3、多态
- 2021年7月1日,官方正式发布了1.0Datatable版本。1.0版本支持windows和linux,以及Macos。 具体文档可以见:
- python使用qq邮箱(个人邮箱)发送邮件需开启qq邮箱的SMTP服务在设置中开启pop3/SMTP服务,返回的密码就是之后代码中登录使用
- 目录1.程序结构2.选择语句2.1最简单的if语句2.2.if …… else 语句2.3.if…elif…else语句2.4 if 语句的
- 在Python中,语法错误可以被Python解释器发现,但逻辑上错误或变量使用错误却不容易发现,如果结果没有符合预期,则需要调试,一个很好的
- Python 语言里有许多(而且是越来越多)的高级特性,是 Python 发烧友们非常喜欢的。在这些人的眼里,能够写出那些一般开发者看不懂的
- 代码如下#encoding:utf-8import requestsfrom lxml import etreeimport xlwtimp
- 项目地址:https://github.com/chen0495/pythonCrawlerForJSU环境python 3.5即以上req
- 1、标识符与关键字在了解数据类型之前,先了解一下go的标识符和关键字1.1 标识符在编程语言中标识符就是定义的具有某种意义的词,比如变量名、
- 今天看了篇关于Web Form Design的成功案例,虽然讲的事情很简单,但总结了一些方法,翻译过来做个原始积累吧,以后写东西举例子时也好
- 视频地址我用20行代码,帮女神破解相册密码一、事情是这样的今早上班,公司女神小姐姐说,她去年去三亚旅游的照片打不开了好奇问了一下才知道。原来
- 如果使用默认的数据库 SQLite3,则无需配置settings.py使用其他数据库,则需要配置settings.py,这里以Mysql为例
- 正在看的ORACLE教程是:Oracle数据库集复制方法浅议。前言 日益增长的分布式应用需求要求实现更好分布式的软件环境,不断推动着分布式技
- Microsoft SQL Server 7.0安全问题Microsoft Corporation【「Microsoft SQL Serve
- 一、背景 PyCharm执行Python时,找不到自己安装的package,例如pandas、numpy、scipy、scikit等,在执行