从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)
从零开始学activemq
ActiveMQ:使用Python访问ActiveMQ的方法windows 10家庭中文版,python 3.6.4,stomp.py 4.1.21
activemq支持python访问,提供了基于stomp协议(端口为61613)的库。
activemq的官文cross language clients中给出了更详细的介绍,并附有示例代码,如下图:
第一行为常规python访问,第二行为使用jython访问的方式,四个操作。
python访问activemq需要使用stomp.py,见其官网。。
下载官网的代码,解压,命令行进入其目录,使用pyhthon setup.py install即可安装好,然后就可以使用stomp.py了。
官方示例代码:给队列test发送一个消息,也可以把第7行的destination的“/queue/”去掉,只剩test。
|
import stomp conn = stomp.connection() conn.set_listener('', mylistener()) conn.start() conn.connect( 'admin' , 'password' , wait = true) conn.send(body = ' ' .join(sys.argv[ 1 :]), destination = '/queue/test' ) conn.disconnect() |
测试结果:test队列接收到消息数量增加了
stomp.connection()默认是connect.stompconnection11(协议1.1),还可以可以选择1.0、1.2。
在官方代码中,stomp.connection()的参数为空,实际上可以有很多参数,比如,设置broker的ip地址和端口,如下:其中的host_and_ports就是设置ip和端口的。
ip和端口设置示例:
c = stomp.connection([('127.0.0.1', 62613)])
这里我犯错了,端口我协程了8161(activemq的web访问的端口),经查询(百度搜索到stackoverflow.com)才知,stomp协议用的是61613(activemq的配置文件中):
activemq官网的四个测试:
发送消息到队列queue属于 点对点模式,不可以重复消费;
发送消息到主题topic属于 发布/订阅模式,可以重复消费;
|
# send a message to an apache activemq queue import stomp conn = stomp.connection10() conn.start() conn.connect() conn.send( 'samplequeue' , 'simples assim' ) conn.disconnect() # receive a message from an apache activemq queue import stomp import time class samplelistener( object ): def on_message( self , headers, msg): print (msg) conn = stomp.connection10() conn.set_listener( 'samplelistener' , samplelistener()) conn.start() conn.connect() conn.subscribe( 'samplequeue' ) time.sleep( 1 ) # secs conn.disconnect() # send a message to an apache activemq topic import stomp conn = stomp.connection10() conn.start() conn.connect() conn.send( '/topic/sampletopic' , 'simples assim' ) conn.disconnect() # receive a message from an apache activemq topic (1) import stomp import time class samplelistener( object ): def on_message( self , headers, msg): print (msg) conn = stomp.connection10() conn.set_listener( 'samplelistener' , samplelistener()) conn.start() conn.connect() conn.subscribe( '/topic/sampletopic' ) time.sleep( 1 ) # secs conn.disconnect() # receive a message from an apache activemq topic (2) import stomp import time class samplelistener( object ): def on_message( self , headers, msg): print (msg) conn = stomp.connection10() conn.set_listener( 'samplelistener' , samplelistener()) conn.start() conn.connect(headers = { 'client-id' : 'sampleclient' }) conn.subscribe(destination = '/topic/sampletopic' , headers = { 'activemq.subscriptionname' : 'samplesubscription' }) time.sleep( 1 ) # secs conn.disconnect() |
以上这篇activemq:使用python访问activemq的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持开心学习网。
原文链接:https://www.cnblogs.com/luo630/p/9188107.html
- python找出数组的最大值(Python查找数组中数值和下标相等的元素示例二分查找)
- python装饰器怎么编写(Python函数装饰器常见使用方法实例详解)
- python元组操作方法(Python元组常见操作示例)
- python的turtle库怎么进入(python的turtle库使用详解)
- 学python从零基础到开发游戏(python开发游戏的前期准备)
- python蓝牙knn算法(python使用KNN算法识别手写数字)
- python人脸识别库(python3人脸识别的两种方法)
- python模块学习之random模块(详解Python基础random模块随机数的生成)
- python按顺序遍历字典(Python字典遍历操作实例小结)
- python的4种数字变量(Python将字符串常量转化为变量方法总结)
- python csv文件读取方法(对python读取zip压缩文件里面的csv数据实例详解)
- python字符串找一个最大字符(Python查找最长不包含重复字符的子字符串算法示例)
- python参模块使用教程(Python参数解析模块sys、getopt、argparse使用与对比分析)
- python的三维画图(python处理DICOM并计算三维模型体积)
- 微信小程序企业微信打卡(使用Python实现企业微信的自动打卡功能)
- python数值基本运算方法(Python常见数字运算操作实例小结)
- 小米音乐与 QQ 音乐合作,便捷迁移会员(小米音乐与QQ音乐合作)
- 小米推出米兔儿童电话手表奥特曼版,799 元,支持微信 QQ(小米推出米兔儿童电话手表奥特曼版)
- 贾怀胤唱《白龙马》 炸场 了 没想到京剧还能这么玩(贾怀胤唱白龙马)
- 白龙马的改编学生版,快来看看(白龙马的改编学生版)
- 萌娃唱《白龙马》走红,那生动的小表情,网友直呼 简直是戏精(萌娃唱白龙马走红)
- 朱鹤松被不断认可,凤凰传奇玲花喊话岳云鹏,索要老朱演出门票(朱鹤松被不断认可)
热门推荐
- Sql Server profiler 分析器的理解
- stopPropagation、return false、preventDefault区别
- mysql数据库死锁原理(MySQL数据库锁机制原理解析)
- 阿里云域名解析地址写什么(阿里云 Linux 服务器内部无法解析域名问题解决方法)
- laravel 数据表格(Laravel自定义 封装便捷返回Json数据格式的引用方法)
- vue实现树形结构菜单(vue递归实现三级菜单)
- 云服务器带宽怎么测(如何检测云服务器的性能?)
- vue请求token无效(关于Vue 消除Token过期时刷新页面的重复提示问题)
- ASP.NET中XML和JSON互转
- 无法打开sql server的连接(由于系统错误 126 SQL Server,指定驱动程序无法加载)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9