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的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我们。
相关推荐
-
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 = '/que
-
Python RabbitMQ消息队列实现rpc
上个项目中用到了ActiveMQ,只是简单应用,安装完成后直接是用就可以了.由于新项目中一些硬件的限制,需要把消息队列换成RabbitMQ. RabbitMQ中的几种模式和机制比ActiveMQ多多了,根据业务需要,使用RPC实现功能,其中踩过的一些坑,有必要记录一下了. 上代码,目录结构分为 c_server.c_client.c_hanlder: c_server: #!/usr/bin/env python # -*- coding:utf-8 -*- import pika import
-
python RabbitMQ 使用详细介绍(小结)
上节回顾 主要讲了协程.进程.异步IO多路复用. 协程和IO多路复用都是单线程的. epoll 在linux下通过这个模块libevent.so实现 gevent 在底层也是用了libevent.so gevent可以理解为一个更上层的封装. 使用select或者selectors,每接收或发送数据一次都要select一次 twisted异步网络框架,强大又庞大,不支持python3 (代码量python中排top3).几乎把所有的网络服务都重写了一遍. 一.RabbitMQ 消息队列介绍
-
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
-
Windows和Linux下使用Python访问SqlServer的方法介绍
经常用Python写demo来验证方案的可行性,最近遇到了Python访问SqlServer的问题,这里总结下. 一.Windows下配置Python访问Sqlserver 环境:Windows 7 + Sqlserver 2008 1.下载并安装pyodbc 下载地址:http://code.google.com/p/pyodbc/downloads/list 2.访问SqlServer 复制代码 代码如下: >>> import pyodbc >>>cnxn = p
-
Spring Boot ActiveMQ如何设置访问密码
Apache ActiveMQ是Apache出品,是最流行的,能力很强的开源消息总线.默认情况下,程序连接ActiveMQ是不需要密码的,为了安装起见,需要设置密码,提高安全性.本文分享如何设置访问ActiveMQ的账号密码. 小编使用的ActiveMQ版本是apache-activemq-5.15.13. 一.设置控制台管理密码 ActiveMQ使用的是jetty服务器,找到 ActiveMQ安装目录下的\conf\jetty.xml文件: <bean id="adminSecurity
-
python访问类中docstring注释的实现方法
本文实例讲述了python访问类中docstring注释的实现方法.分享给大家供大家参考.具体分析如下: python的类注释是可以通过代码访问的,这样非常利于书写说明文档 class Foo: pass class Bar: """Representation of a Bar""" pass assert Foo.__doc__ == None assert Bar.__doc__ == "Representation of a B
-
python访问系统环境变量的方法
本文实例讲述了python访问系统环境变量的方法.分享给大家供大家参考.具体如下: #-------------------------------- # Name: enviroment_variables.py # Author: Kevin Harris # Last Modified: 02/13/04 # Description: This Python script demonstrates # how to acces enviroment variables. #--------
-
python访问mysql数据库的实现方法(2则示例)
本文实例讲述了python访问mysql数据库的实现方法.分享给大家供大家参考,具体如下: 首先安装与Python版本匹配的MySQLdb 示例一 import MySQLdb conn=MySQLdb.connect(user='root',passwd='123',db='example') cur=conn.cursor() cur.execute("select id,lastname,firstname, date_format(dob,'%Y-%m-%d %H-%i-%s'),pho
-
python统计日志ip访问数的方法
本文实例讲述了python统计日志ip访问数的方法.分享给大家供大家参考.具体如下: import re f=open("/tmp/a.log","r") arr={} lines = f.readlines() for line in lines: ipaddress=re.compile(r'^#(((2[0-4]\d|25[0-5]|[01]?\d\d?)\.){3}(2[0-4]\d|25[0-5]|[01]?\d\d?))') match=ipaddres
-
在python中按照特定顺序访问字典的方法详解
最近使用python写一些东西,在参考资料的时候发现字典是没有顺序的,那么怎么样按照一定顺序访问字典呐,我找到了一个小方法: 假设一个字典是: D = {'a': '1', 'b': '2', 'c': '3'} 如果我们要按照a, b, c的顺序访问字典,可以借助一个列表,比如说: L = list(D.keys()) L.sort() for key in L: print(key, 'is' D[key]) 输出为: a is 1 b is 2 c is 3 需要倒序的话只需使用倒序函数排
-
Python访问MongoDB,并且转换成Dataframe的方法
如下所示: #!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2018/7/13 11:10 # @Author : baoshan # @Site : # @File : pandans_pymongo.py # @Software: PyCharm Community Edition import pymongo import pandas as pd def _connect_mongo(host, port, username
-
Python创建类的方法及成员访问的相关知识总结
一.创建类的方法与成员访问 1.1 创建实例方法并访问 实例方法是指在类中定义的函数.该函数是一种在类的实例上操作的函数. 同__init__()方法一样,实例方法的第一个参数必须是self,并且必须包含一个self参数. 1.2 创建数据成员(属性)并访问 数据成员是指在类中定义的变量,即属性(对象的特征).根据定义位置,属性(成员变量) 有两种:一种是实例属性,另一种是类属性(类变量). 1.2.1 添加与访问方式 类属性的添加与访问方式同对象属性,只是把self关键字换成类名 1.2.1.