Python asyncore socket客户端开发基本使用教程
作者:JSON_L 发布时间:2021-01-25 11:06:39
介绍
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
![](https://www.aspxhome.com/images/zang.png)
![](https://www.aspxhome.com/images/jiucuo.png)
猜你喜欢
- 本文实例为大家分享了python xlsxwriter创建excel图表的具体代码,供大家参考,具体内容如#coding=utf-8 imp
- 前言今天,在网上发现一款很棒的python画图工具库。很简单的api调用就能生成漂亮的图表。并且可以进行一些互动。pyecharts 是一个
- 以下代码是保存视频# coding:utf-8import cv2import sysreload(sys)sys.setdefaulten
- 核心播放模块(pygame内核)import time import pygameimport easygui as guifile = r
- 本文实例讲述了php实现mysql备份恢复分卷处理的方法。分享给大家供大家参考。具体分析如下:分卷处理就是把握们要处理的数据分成一个个小文件
- 这是支持的下载版本,去官网下载2020.3及以上(2021-03-18测试破解有效)官网下载地址:https://www.jetbrains
- 1. 数据处理中很恶心,出现 RuntimeWarning: divide by zero encountered in divide发现自
- 项目有时要用一些Ajax的效果,因为比较简单,也就没有去用什么Ajax.net之类的东西,手写代码也就实现了。 第二天,有人反馈错
- 首先声明:本人虽然在web前端岗位干了好多年,但无奈岗位对技术要求不高。html,css用的比较多,JavaScript自己原创的很少,基本
- 今天跟大家分享一下,如何通过Python实现一个轻量级的库来获取电脑上连接的Android设备信息,为什么说轻量呢因为整个库也就4KB,相比
- 导语:使用 python-plotly 模块来进行压测数据的绘制,并且生成静态 html 页面结果展示。不少小伙伴在开发过程中都有对模块进行
- 反射是在PHP运行状态中,扩展分析PHP程序,导出或提取出关于类、方法、属性、参数等的详细信息,包括注释。这种动态获取的信息以及动态调用对象
- $n=round(1.95583, 2); 这是四舍五入法保留2位小数
- 01 实现我们几乎每个人都用过计算器,大家对于计算器应该都是比较熟悉的,计算器整体也是比较简单的,主要包括:显示器、键盘、运算的逻辑处理等,
- 同质化的网站越来越多,往往你还没发展起来,就已有许多站点抄袭走了你的成果,如何留下用户?——让用户有更好的使用体验。一些网页上的小技巧,可以
- 大家一定使用过 phpmyadmin 里面的数据库导入,导出功能,非常方便。但是在实际应用中,我发现如下几个问题: 1、数据库超过一定尺寸,
- 知识点: 1、拼接SQL 2、UNION ALL 3、EXEC 其代码如下: 代码如下:--测试示例 declare @sql
- 一、人脸图像特征提取方法https://www.jb51.net/article/219446.htm二、对笑脸数据集genki4k进行训练
- 异常(exceptions)是Python中一种非常重要的类型,它和语法错误不同,是在程序运行期间引发的错误。Python中内置了很多异常,
- SSI是英文Server Side Includes的缩写,翻译成中文就是服务器端包含的意思。从技术角度上说,SSI就是在HTML文件中,可