导读 | asyncore库是python的一个标准库,提供了以异步的方式写入套接字服务的客户端和服务器的基础结构,这篇文章主要介绍了Python asyncore socket客户端开发基本使用,需要的朋友可以参考下 |
asyncore库是python的一个标准库,提供了以异步的方式写入套接字服务的客户端和服务器的基础结构。操作网络的时候可以直接使用socket等底层的库,但是asyncore使得我们可以更加方便的操作网络,避免直接使用socket,select,poll等工具时需要面对的复杂情况。
1.定义类并且继承 asyncore.dispatcherclass 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()运行结果
服务端:
客户端:
注意:本文章使用python3.7版本,3.10版本已经移除此模块,之后可使用asyncio模块。
至此结束,本文章只做了一个基本使用讲解,可以查看借鉴使用,若想要做消息还差的很多。
标签:handle,socket,Python,self,asyncore,True,def From: https://www.cnblogs.com/linuxprobe19/p/17338089.html