Python asyncore socket客户端实现方法详解
作者:JSON_L 发布时间:2022-06-18 14:17:42
介绍
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()
运行结果
服务端:
客户端:
注意
本文章使用python3.7版本,3.10版本已经移除此模块,之后可使用asyncio模块。
至此结束,本文章只做了一个基本使用讲解,可以查看借鉴使用,若想要做消息还差的很多。
来源:https://blog.csdn.net/json_ligege/article/details/128389493
猜你喜欢
- 本文研究的主要是python删除过期log文件的相关内容,具体介绍如下。1. 用Python遍历目录os.walk方法可以很方便的得到目录下
- 采集文章给建站带来了很大的方便,特别是一些小网站,人员有限,资金有限,适当的使用采集功能可以很快丰富我们的网站,采集这么厉害可能你会觉的代码
- 我设计第一篇网页的时候,就遇到了字体的设置问题。我发现如果用软件约定的字体大小,则显示效果会很难看的。我是用FrontPage2000作网页
- 写入Excel中后有显示第一列客户款号总库存这些,开始写在第12行第一列开始写入,一行写入5个,然后再隔12行,再写入下边的数据,图片需要对
- 目录一个不那么方便的解决方案:实战演练网站在线转换Postman今天介绍个神奇的网站!堪称爬虫偷懒的神器!我们在写爬虫,构建网络请求的时候,
- 注意:安装时要保证Oracle安装目录不能带有中文字符(如果第一次安装出现“加载数据库错误areasQueries”的错误,一般是因为Ora
- cooper谈到用户的视觉路径一般是:从上到下,从左到右。好的视觉设计路径应该是顺应这样的用户习惯,糟糕的设计会让用户无所适从,焦点到处都是
- ob缓存介绍ob是output buffering的简称,输出缓冲区,缓冲区是通过php.ini中的output_buffering变量控制
- asp十进制转二进制;二进制转十进制;二进制转十六进制;十六进制转二进制;八进制转二进制'二进制转八进制;八进制转十进制;十六进制转
- sys模块提供了与python解释器紧密相关的一些变量和函数。sys部分常用函数函数说明path获取模块文件搜索路径的字符串,或临时指定新搜
- 常用的重定向方式有: 301 redirect, 302 redirect 与 meta fresh:301 redirect: 301代表
- 项目运行环境阿里云(单核CPU, 1G内存, Ubuntu 14.04 x64 带宽1Mbps), 具体购买和ssh连接阿里云本文不做描述。
- <? // 建立一个指向新COM组件的索引 $word = new C
- phpMyAdmin是一个用PHP编写的,可以通过互联网控制和操作MySQL。通过phpMyAdmin可以完全对数据库进行操作,例如建立、复
- 1. txt文件(1) 单位矩阵即主对角线上的元素均为1,其余元素均为0的正方形矩阵。在NumPy中可以用eye函数创建一个这样的二维数组,
- 有时候使用到获取本机IP,就采用以下方式进行。#!/usr/bin/python import socketimport stru
- 问题描述前端 vue 框架,后台 php,百度跨域问题后台加这段代码header("Access-Control-Allow-Or
- 前言网络爬虫(又被称为网页蜘蛛,网络机器人,在FOAF社区中间,更经常的称为网页追逐者),是一种按照一定的规则,自动地抓取万维网信息的程序或
- 在之前的文章中,我们介绍了PyQt5和PySide2中主窗口控件MainWindow的使用、窗口控件的4中基础布局管理。从本篇开始,我们来了
- 前言:K8s也提供API接口,提供这个接口的是管理节点的apiserver组件,apiserver服务负责提供HTTP API,以便用户、其