python的mqtt循环发布(python 发送和接收ActiveMQ消息的实例)
类别:脚本大全 浏览量:2964
时间:2022-04-02 10:45:47 python的mqtt循环发布
python 发送和接收ActiveMQ消息的实例ActiveMQ是java开发的消息中间件服务。可以支持多种协议(AMQP,MQTT,OpenWire,Stomp),默认的是OpenWire。而python与ActiveMQ的通信使用的是Stomp协议。而如果你的服务没有开启则需要配置开启。
首先需要安装python的stomp库。
命令如下:
|
pip install stomp.py |
接着,就是上代码了具体如下:
|
# -*-coding:utf-8-*- import stomp import time queue_name = '/queue/SampleQueue' topic_name = '/topic/SampleTopic' listener_name = 'SampleListener' class SampleListener( object ): def on_message( self , headers, message): print 'headers: %s' % headers print 'message: %s' % message # 推送到队列queue def send_to_queue(msg): conn = stomp.Connection10([( '127.0.0.1' , 61613 )]) conn.start() conn.connect() conn.send(queue_name, msg) conn.disconnect() #推送到主题 def send_to_topic(msg): conn = stomp.Connection10([( '127.0.0.1' , 61613 )]) conn.start() conn.connect() conn.send(topic_name, msg) conn.disconnect() ##从队列接收消息 def receive_from_queue(): conn = stomp.Connection10([( '127.0.0.1' , 61613 )]) conn.set_listener(listener_name, SampleListener()) conn.start() conn.connect() conn.subscribe(queue_name) time.sleep( 1 ) # secs conn.disconnect() ##从主题接收消息 def receive_from_topic(): conn = stomp.Connection10([( '127.0.0.1' , 61613 )]) conn.set_listener(listener_name, SampleListener()) conn.start() conn.connect() conn.subscribe(topic_name) while 1 : send_to_topic( 'topic' ) time.sleep( 3 ) # secs conn.disconnect() if __name__ = = '__main__' : # send_to_queue('len 123') # receive_from_queue() receive_from_topic() |
但是上述只是发送文本类型的消息,除此之外,ActiveMQ还支持MapMessage、ObjectMessage、BytesMessage、和StreamMessage等多个消息类型。
以上这篇python 发送和接收ActiveMQ消息的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持开心学习网。
原文链接:https://blog.csdn.net/five3/article/details/79569587
您可能感兴趣
- python合并多个excel可以刷新吗(python 实现读取一个excel多个sheet表并合并的方法)
- python 提取微信消息(python实现文件助手中查看微信撤回消息)
- python实现网络爬虫的步骤(Python实现的爬取小说爬虫功能示例)
- wxpython控件如何移动(基于wxPython的GUI实现输入对话框1)
- python装饰器怎么编写(Python函数装饰器常见使用方法实例详解)
- python人脸识别库有几个(Python人脸识别第三方库face_recognition接口说明文档)
- python中内存管理机制(Python中整数的缓存机制讲解)
- python基本运算符编程(对Python3 * 和 ** 运算符详解)
- python模块都是自己的语法(详解Python_shutil模块)
- python实现数据的预测(Python基于scipy实现信号滤波功能)
- pythonredis列表(Python redis操作实例分析连接、管道、发布和订阅等)
- python调用支付宝支付接口(python实现支付宝转账接口)
- pythonflask系列教程(Python安装Flask环境及简单应用示例)
- python多线程和多进程应用场景(Python多线程处理实例详解单进程/多进程)
- python用列表实现一个定时器(python 定时器,实现每天凌晨3点执行的方法)
- python如何判断是否为回文数(对python判断是否回文数的实例详解)
- 医事文化谈屑 | 古人的名 字 号(医事文化谈屑古人的名)
- ()
- 网友很惭愧,自己写了很多年的字,到头来还不如一名小学生写的好(自己写了很多年的字)
- 中华第一楷 张瑞龄 86岁高龄,苦练楷书71年,一幅字卖593万(中华第一楷张瑞龄)
- 冯骥才 年意(冯骥才年意)
- ()
热门推荐
- mysql 加锁处理分析(mysql死锁和分库分表问题详解)
- python网页自动化selenium(python利用selenium进行浏览器爬虫)
- nginx服务器有什么用(Nginx的作用详解,为什么在Web服务器中Nginx的比例越来越高?)
- mysql事务级别设置(mysql在项目中怎么选事务隔离级别)
- sqlserver带参数的存储过程(SQL Server 日期和时间的内部存储过程)
- mysql索引分几种(MySQL 覆盖索引的优点)
- nginx动静分离的原理(Nginx动静分离实现案例代码解析)
- 移动端字号规范(吃透移动端 1px的具体用法)
- python在mysql创建数据库(python3对接mysql数据库实例详解)
- 宝塔面板windows新手教程(宝塔面板CPU负载过高使用opcache扩展的解决方法)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9