1、安装ActiveMQ
brew install activemq
2、启动ActiveMQ
activemq start
3、查看ActiveMQ版本
activemq --version
4、发送队列(queue)
import stomp
import sys
import time
conn = stomp.Connection()
conn.connect('admin', 'admin', wait=True)
# send queue name 'test'
conn.send(body=''.join(sys.argv[1:]), destination='/queue/SampleQueue')
# send message
for i in range(10):
# 第一个参数:队列的名称
# 第二个参数:消息的内容
conn.send("SampleQueue", "message{0}:{1}".format(i, i))
time.sleep(3)
conn.disconnect()
5、监听队列(queue)
import stomp
import time
import sys
class SampleListener(stomp.ConnectionListener):
def on_message(self, headers, msg):
print(msg)
def on_error(self, headers, message):
print("headers:{0['destination']}, message:{1}".format(headers, message))
conn = stomp.Connection10()
conn.set_listener('SampleListener', SampleListener())
conn.connect()
# queue name
conn.subscribe('SampleQueue')
time.sleep(1)
while True:
pass
# conn.disconnect()
6、注意事项
当监听器被启动(SampleListener),会指定一个队列,于是这个监听器会一直监听这个队列,此时该队列的pending message会一直是0,因为监听器一直在消费
class SampleListener(stomp.ConnectionListener):
def on_message(self, headers, message):
print("headers:{0}['destination'], message:{1}".format(headers, message))
destination = headers['destination']
destination = destination[7:]
print(destination)
def on_error(self, headers, message):
print("headers:{0['destination']}, message:{1}".format(headers, message))