python消息中间件activemq_python发送和接收ActiveMQ消息

ActiveMQ是java开发的消息中间件服务。可以支持多种协议(AMQP,MQTT,OpenWire,Stomp)&＃xff0c;默认的是OpenWire。而python与ActiveMQ的通信使用的是Stomp协议。而如果你的服务没有开启则需要配置开启。

首先需要安装python的stomp库。命令如下&＃xff1a;

pip install stomp.py

接着&＃xff0c;就是上代码了具体如下&＃xff1a;

# -*-coding:utf-8-*-

import stomp

import time

queue_name &＃61; &＃39;/queue/SampleQueue&＃39;

topic_name &＃61; &＃39;/topic/SampleTopic&＃39;

listener_name &＃61; &＃39;SampleListener&＃39;

class SampleListener(object):

def on_message(self, headers, message):

print &＃39;headers: %s&＃39; % headers

print &＃39;message: %s&＃39; % message

# 推送到队列queue

def send_to_queue(msg):

conn &＃61; stomp.Connection10([(&＃39;127.0.0.1&＃39;,61613)])

conn.start()

conn.connect()

conn.send(queue_name, msg)

conn.disconnect()

#推送到主题

def send_to_topic(msg):

conn &＃61; stomp.Connection10([(&＃39;127.0.0.1&＃39;,61613)])

conn.start()

conn.connect()

conn.send(topic_name, msg)

conn.disconnect()

##从队列接收消息

def receive_from_queue():

conn &＃61; stomp.Connection10([(&＃39;127.0.0.1&＃39;,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 &＃61; stomp.Connection10([(&＃39;127.0.0.1&＃39;,61613)])

conn.set_listener(listener_name, SampleListener())

conn.start()

conn.connect()

conn.subscribe(topic_name)

while 1:

send_to_topic(&＃39;topic&＃39;)

time.sleep(3) # secs

conn.disconnect()

if __name__&＃61;&＃61;&＃39;__main__&＃39;:

# send_to_queue(&＃39;len 123&＃39;)

# receive_from_queue()

receive_from_topic()

但是上述只是发送文本类型的消息&＃xff0c;除此之外&＃xff0c;ActiveMQ还支持MapMessage、ObjectMessage、BytesMessage、和StreamMessage等多个消息类型。

想学习更多Python技巧&＃xff0c;请扫描如下二维码&＃xff01;&＃xff01;&＃xff01;