首页 > 编程语言 >Python asyncore socket客户端开发基本使用

Python asyncore socket客户端开发基本使用

时间:2023-05-06 09:03:06浏览次数:66  
标签:handle socket Python self asyncore True def

导读 asyncore库是python的一个标准库,提供了以异步的方式写入套接字服务的客户端和服务器的基础结构,这篇文章主要介绍了Python asyncore socket客户端开发基本使用,需要的朋友可以参考下
介绍

asyncore库是python的一个标准库,提供了以异步的方式写入套接字服务的客户端和服务器的基础结构。操作网络的时候可以直接使用socket等底层的库,但是asyncore使得我们可以更加方便的操作网络,避免直接使用socket,select,poll等工具时需要面对的复杂情况。

1.定义类并且继承 asyncore.dispatcher
class SocketClient(asyncore.dispatcher):
2.实现类中的回调代码 调用父类方法

asyncore.dispatcher.__init__(self)

创建 socket 对象
self.create_socket()
连接服务器
address = (host, port)
self.connect(address)
实现 handle_connect 回调函数

当socket 连接服务器成功时回调该函数

def handle_connect(self):
    print('连接成功')
实现 writable 回调函数

描述是否有数据需要被发送到服务器。返回值为True表示可写,False 表示不可写。

如果不识闲默认返回为 True,当返回True时,回调函数handle_write将被触发

def writable(self):
    return False
实现 handle_write 回调函数

当有数据需要发送时 (writable 回调函数返回 True时),

该函数被触发,通常情况下在该函数中编写send方法发送数据

def handle_write(self):
    # 内部实现对服务器发送数据
    # 调用 send 方法,参数是字节数据
    self.send('hello world'.encode('utf-8'))
实现 readable 回调函数

描述是否有数据从服务端读取。返回True标识有数据需要读取,

False表示没有数据需要被读取,当不实现默认返回True,

当返回True时,handle_read将被触发

def readable(self):
    # 表示有数据需要读取
    return True
实现 handle_read 回调函数

当有数据需要读取时(readable 回调函数返回True时),

该函数被触发,通常情况下在该函数中编写recv方法接收数据

def handle_read(self):
    # 主动读取接收数据 参数是需要接收数据长度
    result = self.recv(8000)
    print(result)
实现 handle_error 回调函数

当程序运行过程发生异常时回调

def handle_error(self):
    # 编写处理错误方法
    t, e, trace = sys.exc_info()
    print(t, e, trace)
实现 handle_close 回调函数

当连接被关闭时触发

def handle_close(self):
    print('连接关闭')
    # 执行关闭
    self.close()
3.创建对象并且执行 asyncore.loop 进入运行循环

timeout为一次循环所用的时间,也就是超时时间。

client = SocketClient('127.0.0.1', 9000)
# 开始启动运行循环
asyncore.loop(timeout=10)
服务端示例代码
import asyncore
import socket
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_addr()
        self.bind((host, port))
        # 监听连接参数指定排队的最大连接数和应至少为1; 最大值取决于系统(通常为5)。
        self.listen(5)
  
    '''
    当与发起对本地端点的 connect() 调用的新远程端点已建立连接时会在侦听通道(被动打开方)上被调用。 
    sock 是可被用于在连接上发送和接收数据的 新建 套接字对象,
    而 addr 是绑定到连接另一端的套接字的地址。
    '''
    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print('连接来自于 %s' % repr(addr))
            # 连接成功后 给客户端发送消息
            handler = EchoHandler(sock)
            handler.send('hello world'.encode('utf-8'))
  
if __name__ == '__main__':
    server = EchoServer('127.0.0.1', 9000)
    asyncore.loop()
运行结果

服务端:

Python asyncore socket客户端开发基本使用Python asyncore socket客户端开发基本使用

客户端:

Python asyncore socket客户端开发基本使用Python asyncore socket客户端开发基本使用

注意:

本文章使用python3.7版本,3.10版本已经移除此模块,之后可使用asyncio模块。

至此结束,本文章只做了一个基本使用讲解,可以查看借鉴使用,若想要做消息还差的很多。

本文地址:https://www.linuxprobe.com/python-asyncore-socket.html

标签:handle,socket,Python,self,asyncore,True,def
From: https://www.cnblogs.com/linuxprobe19/p/17338089.html

相关文章

  • python练习-简单计算器
    #*_*coding:utf8*_*#简单计算器importtkinterfromfunctoolsimportpartial#按钮输入调用defget_input(entry1,argu):#从entry窗口展示中获取输入的内容input_data=entry1.get()#合法运算符:+-*/--**//+-#------------输入合法性判断的......
  • python基础学习-文件
    """文件操作open()打开open(name,mode,encoding)name:文件名,文件所在的路径mode:文件访问模式,只读r,写入w(文件存在,从开头开始编辑,原有内容会删除,不存在,创建),追加a(文件存在,从已有内容之后进行编辑,不存在,创建)读写encoding:编码格式"""#打开文件f=open("demo.txt","r",encoding="......
  • python基础学习-字典
    """字典dict定义:元素是键值对,key不能重复,不能使用下标索引,key是除字典外其他类型,value为任意类型,可嵌套,可修改,支持for循环,不支持while循环#字面量{key:value,key:value,key:value}#定义变量变量名称={key:value,key:value,key:value}#定义空列表变量名称=dict(......
  • python基础学习-异常
    """异常:捕获异常:基本语法:try:可能发生错误的代码except:出现异常执行代码else:没异常,执行finally:无论有无异常,都执行异常具有传递性"""#捕获指定异常try:print(name)exceptNameErrorase:print("出现未定义异常")print(e)#捕获多个异常try:......
  • python基础学习-容器
    """容器的通用功能:len(容器)统计容器元素个数max(容器)统计最大元素min(容器)统计最小元素类型转换list(容器)给定容器转换为liststr(容器)给定容器转换为strtuple(容器)给定容器转换为tupleset(容器)给定容器转换set通用排序:sorted(容器,[reverse=True])......
  • gitlab--python 操作 gitlab
    安装我们可以使用python-gitlab库来操作gitlabpipinstallpython-gitlabgitlabissue查询的api:https://docs.gitlab.com/ee/api/issues.html#list-issuesgitlabissue查询的api:https://docs.gitlab.com/ee/api/issues.html#list-issues创建令牌我们需要令牌进行访问......
  • Python中的抽象类解说
    1、什么是抽象类?如果说,类是对一堆对象共同内容的抽取,那么抽象类就是对一堆类共同内容的抽取,包括:属性和方法。2、抽象类的特点(1)抽象类必须包含一个或多个抽象方法,也可以包含普通方法。(2)抽象类的抽象方法,在抽象类中并不作实现。(3)抽象类不能被实例(4)抽象类的子类要想进行实例化,必......
  • python异步爬虫
    异步爬虫基础知识阻塞​ 阻塞状态指程序未得到所需计算资源时被挂起的状态。程序在等待某个操作完成期间,自身无法继续干别的事情,则该程序在操作上是阻塞的。​ 常见的阻塞形式有:网络I/O阻塞、磁盘I/O阻塞、用户输入阻塞等。阻塞是无处不在的,包括在CPU切换上下文时,所有进程都......
  • python 串口读取gps
    #coding:utf-8#lastmodified:20220824importtimeimportserialimportre utctime=''lat=''ulat=''lon=''ulon=''numSv=''msl=''cogt=''cogm='&#......
  • Python 脚本部署和发布 Django 应用程序的示例代码及注释
    代码说明:1、在脚本中定义了要部署的Django应用程序名称、Docker镜像名称和标签。2、使用字符串模板定义了KubernetesDeployment和Service的YAML文件。在字符串模板中使用了变量,用于替换实际的值。3、将Deployment和Service的YAML文件保存到本地文件中,并使用kube......