脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 脚本专栏 → python → python asyncore异步模块

python中asyncore异步模块的实现

 更新时间：2023年01月18日 10:14:11   作者：TypicalSpider  
本文主要介绍了python中asyncore异步模块的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

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()

到此这篇关于python中asyncore异步模块的实现的文章就介绍到这了,更多相关python asyncore异步模块内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • Pandas修改DataFrame列名的两种方法实例

    Pandas修改DataFrame列名的两种方法实例

    这篇文章主要给大家介绍了关于Pandas修改DataFrame列名的两种方法,文中通过实例代码介绍的非常详细,对大家学习或者使用Pandas具有一定的参考学习价值,需要的朋友可以参考下
    2022-03-03
  • Matplotlib自定义图例(多张图共享一个图例)

    Matplotlib自定义图例(多张图共享一个图例)

    最近再用Matplotlib绘图,需要做两个子图都不需要设置图例,图例单独用一个figure来显示,本文就详细的来介绍一下,感兴趣的可以了解一下
    2023-08-08
  • python 如何把docker-compose.yaml导入到数据库相关条目里

    python 如何把docker-compose.yaml导入到数据库相关条目里

    这篇文章主要介绍了python 如何把docker-compose.yaml导入到数据库相关条目里？下面小编就为大家介绍一下实现方式，一起跟随小编过来看看吧
    2021-01-01
  • Python批量修改文件名操作指南(文件名的替换、前缀、后缀的添加)

    Python批量修改文件名操作指南(文件名的替换、前缀、后缀的添加)

    很多时候我们手上有一堆文件,需要修改名称时需要一个一个修改,太麻烦了,这篇文章主要给大家介绍了关于Python批量修改文件名的相关资料,包括文件名的替换、前缀、后缀的添加的相关资料,需要的朋友可以参考下
    2024-04-04
  • Python绘制茎叶图的示例代码

    Python绘制茎叶图的示例代码

    这篇文章主要为大家信息介绍了Python绘制茎叶图的相关知识,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起学习一下
    2024-01-01
  • Python GUI编程之tkinter模块Toplevel控件实现搭建父子窗口

    Python GUI编程之tkinter模块Toplevel控件实现搭建父子窗口

    这篇文章主要介绍了Python使用tkinter模块Toplevel控件搭建父子窗口的实现方法,Tkinter是Python的标准GUI库,Python使用Tkinter可以快速的创建GUI应用程序,用到相关控件的同学可以参考下
    2023-12-12
  • Pyspark获取并处理RDD数据代码实例

    Pyspark获取并处理RDD数据代码实例

    这篇文章主要介绍了Pyspark获取并处理RDD数据代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • 使用Python实现简单的数据备份

    使用Python实现简单的数据备份

    数据备份,即数据的复制和存储,是指将数据从一个位置复制到另一个位置,以防止原始数据丢失或损坏,下面我们就来了解一下用Python如何实现这一功能吧
    2025-03-03
  • Python实现绘制多角星实例

    Python实现绘制多角星实例

    这篇文章要给大家分享Python实现绘制多角星的实例,在具备一定的Python编程基础以后,我们可以结合for循环进行多角星的编写,只要简单的几次循环,即可以极大的解决重复编写相同代码方面的问题,下面小编将以三角星,五角星为例,进而引入如何绘制多角星,需要的朋友可以参考一下
    2021-11-11
  • python神经网络Keras构建CNN网络训练

    python神经网络Keras构建CNN网络训练

    这篇文章主要为大家介绍了python神经网络学习使用Keras构建CNN网络训练，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-05-05

最新评论