从零开始学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 在指定范围内随机生成不重复的n个数实例)
- python实用教程(Python简直是万能的,这5大主要用途你一定要知道!推荐)
- python爬虫模块教程(Python爬虫之UserAgent的使用实例)
- 推荐算法第三方python(GitHub 热门:Python 算法大全,Star 超过 2 万)
- python用于机器人(python实现nao机器人身体躯干和腿部动作操作)
- python3编程过程(Python3模拟登录操作实例分析)
- python中的数据类型和数字类型(Python数据类型之Number数字操作实例详解)
- python列表切片和分片(Python列表切片操作实例总结)
- python怎么判断文件大小(python3实现指定目录下文件sha256及文件大小统计)
- pythonmatplotlib怎么用(Python matplotlib画图与中文设置操作实例分析)
- pythontime模块有哪些(Python3.5内置模块之time与datetime模块用法实例分析)
- python创建进程的方法(Python多进程fork函数详解)
- python3标准库资源(Python3标准库总结)
- 怎么用python做随机矩阵(python实现杨氏矩阵查找)
- python分割字符串要用哪一个语句(python使用threading.Condition交替打印两个字符)
- python 读文件报错处理(解决python写入带有中文的字符到文件错误的问题)
- 招财化煞神兽,金蟾变了(招财化煞神兽金蟾变了)
- 26岁杨紫的白素贞遇上24岁鞠婧祎,哪个最美(26岁杨紫的白素贞遇上24岁鞠婧祎)
- 鞠婧祎和杨紫两种风格的女生,你心里谁比较美(鞠婧祎和杨紫两种风格的女生)
- 三千年第一美女鞠婧祎出演白素贞pk杨紫,颜值胜赵雅芝王祖贤(三千年第一美女鞠婧祎出演白素贞pk杨紫)
- 成都轨道交通13号线一期工程最新进展(成都轨道交通13号线一期工程最新进展)
- 越南没事(越南没事情做)
热门推荐
- sql server 字符串处理(SQL Server中利用正则表达式替换字符串的方法)
- dedecms屏蔽规则(织梦dedecms修改任意管理员漏洞处理方法)
- sql server中dense_rank和row_number的区别
- asp.net自定义分页控件
- Convert.ToInt32,int.Parse,int.TryParse,(int)的区别
- thinkphp5对接支付宝扫码支付(ThinkPHP框架下整合支付宝支付功能图文教程)
- 微信公众号文章 爬虫(python抓取搜狗微信公众号文章)
- python 文本分析 摘要(用Python逐行分析文件方法)
- mysql必知必会索引(MySQL索引知识的一些小妙招总结)
- dedecms简介(Linux操作系统下DedeCMS详细安全设置教程)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9