从零开始学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 dict 操作(Python中dict和set的用法讲解)
- python技巧图解(Python魔法方法功能与用法简介)
- python3循环使用教程(Python3.5常见内置方法参数用法实例详解)
- python pyqt 教程(Python+PyQt5实现美剧爬虫可视工具的方法)
- 最简单python的100个代码(20条非常实用的Python代码实例)
- python用pyqt5制作登录界面(python3+pyqt5+itchat微信定时发送消息的方法)
- python里import的是什么(python中import与from方法总结推荐)
- python怎么去掉字符串的空格(Python切片操作去除字符串首尾的空格)
- python中可以改变的数据类型(Python常见数据类型转换操作示例)
- python图片aes加密(python实现AES加密和解密)
- python3字符串格式化怎么操作(python3实现字符串操作的实例代码)
- python指定路径创建txt文件(python根据txt文本批量创建文件夹)
- python函数使用方法高级用法(Python函数的参数常见分类与用法实例详解)
- python实现网络爬虫的步骤(Python实现的爬取小说爬虫功能示例)
- python开源协议简介(对python 自定义协议的方法详解)
- python一组数字求和(Python3数字求和的实例)
- 弄清楚了销 售 买 卖这四个字,母婴生意做起来就没那么难了(弄清楚了销售买)
- 数读 买首饰金是 投资黄金 吗 买金容易卖金难(数读买首饰金是)
- 销 售 买 卖 你真的了解这四个字了吗(销售买)
- 谢娜是得罪快乐大本营造型师了吗 全场被黑化(谢娜是得罪快乐大本营造型师了吗)
- 前《iLOOK》时装总监 《快乐大本营》御用造型师上线(快乐大本营御用造型师上线)
- 释小龙晒杀青照片 多重身份惹观众期待(释小龙晒杀青照片)
热门推荐
- laravel队列不超时(在laravel中实现事务回滚的方法)
- vue加element ui弹窗(Vue中ElementUI分页组件Pagination的使用方法)
- linux系统的组成架构(Linux输入子系统框架原理解析)
- mysql完全快速清空一个表(浅谈MySQL如何优雅的做大表删除)
- WCF与WebService的区别
- sql注入防范有哪些方法(如何有效防止sql注入的方法)
- iis7.5怎么安装(IIS7.5打开启用GZip压缩功能的设置教程方法)
- js的异步请求(浅谈JS三座大山之异步和单线程)
- python操作redis(Python获取Redis所有Key以及内容的方法)
- electronvue最新版本(Vue3和Electron实现桌面端应用详解)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9