位置: 编程技术 - 正文
Python的消息队列包SnakeMQ使用初探(python消息队列感知消息被消费)
编辑：rootadmin推荐整理分享Python的消息队列包SnakeMQ使用初探(python消息队列感知消息被消费)，希望有所帮助，仅作参考，欢迎阅读内容。
文章相关热门搜索词:python消息队列组件,python消息队列框架有哪些,python消息队列感知消息被消费,python消息队列框架,python消息队列组件,python消息队列感知消息被消费,python消息队列组件,python消息队列框架,内容如对您有帮助，希望把文章链接给更多的朋友！
一、关于snakemq的官方介绍SnakeMQ的GitHub项目页： 两种队列
5.支持异步 -- poll()
6.symmetrical -- 单个TCP连接可用于双工通讯
7.多数据库支持 -- SQLite、MongoDB……
8.brokerless - 类似ZeroMQ的实现原理
9.扩展模块：RPC, bandwidth throttling
以上都是官话，需要自己验证，动手封装了一下，感觉萌萌哒。
二、几个主要问题说明
1.支持自动重连，不需要自己动手写心跳逻辑，你只需要关注发送和接收就行
2.支持数据持久化，如果开始持久化，在重连之后会自动发送数据。
3.数据的接收，snakemq通过提供回调实现，你只需要写个接收方法添加到回调列表里去。
4.数据的发送，在此发送的都是bytes类型（二进制），因此需要转换。我在程序中测试的都是文本字符串，使用str.encode(‘utf-8')转换成bytes，接收时再转换回来。
5.术语解释，Connector：类似于socket的TcpClient，Lisenter：类似于socket的TcpServer，每个connector或者listener都一个一个ident标识，发送和接收数据时就知道是谁的数据了。
6.使用sqlite持久化时，需要修改源码，sqlite3.connect(filename,check_same_thread = False)，用于解决多线程访问sqlite的问题。（会不会死锁？）
7.启动持久化时，如果重新连上，则会自动发送，保证可靠。
8.为了封装的需要，数据接收以后，我通过callback方式传送出去。
三、代码
说明代码中使用了自定义的日志模块
可替换成logging的。
回调类（callbacks.py）：
Connector类（snakemqConnector.py）：
Listener类（snakemqListener.py）：
测试代码connector（testSnakeConnector.py）：
读取本地一个1M的文件，然后发送给listener，然后listener发回一个hello的信息。
Python+Pika+RabbitMQ环境部署及实现工作队列的实例教程 rabbitmq中文翻译的话，主要还是mq字母上：MessageQueue，即消息队列的意思。前面还有个rabbit单词，就是兔子的意思，和python语言叫python一样，老外还是蛮
Python通过RabbitMQ服务器实现交换机功能的实例教程 快速回顾一下RabbitMQ服务器的安装：sudoapt-getinstallrabbitmq-serverPython使用RabbitMQ需要Pika库：sudopipinstallpika好了，接下来我们先看交换机的工作原理：消息发
Python操作RabbitMQ服务器实现消息队列的路由功能 Python使用Pika库（安装：sudopipinstallpika）可以操作RabbitMQ消息队列服务器（安装：sudoapt-getinstallrabbitmq-server），这里我们来看一下MQ相关的路由功能。路由
上一篇：Python中线程的MQ消息队列实现以及消息队列的优点解析(python线程daemon)
