python 通過stomp操作ActiveMQ

最近用到了這個，記錄一下。

python通過stomp協議與ActiveMQ通信。

首先要確認下ActiveMQ是否開啟了stomp服務（默認是開啟的）：

端口號默認為：61613

發送與接收消息：

class MyListener(object):

    def __init__(self, conn):
        self.conn = conn

    def on_error(self, headers, message):
        print '$$$ received an error: %s from MQ' % message

    def on_message(self, headers, message):
        print '$$$ received a message: %s from MQ' % message
        # print headers
        self.conn.ack(id=headers['message-id'], subscription=headers['subscription']) # 消費消息記錄

        prepare_folder()
        self.write_record(config_file, message)

def messagequeue_invoker():
    dest = '/queue/TestPysoider'
    #logging.basicConfig()

    conn = stomp.Connection([('127.0.0.1', 61613)])
    conn.set_listener('', MyListener(conn)) # 注冊消息監聽者
    conn.start()
    conn.connect(username='admin', passcode='admin', wait=True, headers={'tcpNoDelay': 'true'})
    conn.send(destination=dest, body='I am a test message.', headers={'type': 'textMessage'}) # 發送消息
    print "$$$ send one message"

    conn.subscribe(destination=dest, id=123, ack='client') # 開始監聽接收消息
    print 'start to receive message......'
    while True:
        try:
            time.sleep(1)
        except:
            break

由於python各種庫的版本變化較快，調用參數與方式可能有變化。之前在網上找資料就發現好多有不能執行。

可以通過查看源代碼以及注釋的方法校准方法調用方式（參數列表）；

通過打印傳入參數查看監聽方法的使用以及消費消息記錄的調用方式。

技巧很弱，僅作總結。

歡迎大神指教。