Python ActiveMQ入门教程

Myth丶恋晨 2022-05-15 10:55 292阅读 0赞

ActiveMQ 是Apache出品，最流行的. 功能强大的即时通讯和集成模式的开源服务器。

--------------------

*  **Windows下ActiveMQ下载与安装**
    
    ActiveMQ 由于是基于Java开发的，所以必须先配置JDK环境，而且ActiveMQ 必须与JDK版本匹配才可以。本文是[ActiveMQ 5.10.0 Release][]，JDK版本为1.8。  
    解压下载的文件到指定的位置。
 *  **ActiveMQ目录及启动**

bin 存放的是脚本文件 里面分32 位 64 位，可以选择启动
    conf 存放的是基本配置文件(可以通过修改jetty-realm.properties 进行配置用户名密码等等)
    data 存放的是日志文件
    docs 存放的是说明文档
    examples 存放的是简单实例
    lib 存放的是activemq 所需jar 包
    webapps 用于存放项目的目录

解压下载的文件到指定的位置，进入bin\win64目录，点击activemq.bat启动即可

启动截图如下  
![截图1][1]  
打开浏览器输入：[http://localhost:8161][http_localhost_8161] ，进入管理页面。默认登陆账号和密码都为admin  
可进入控制台  
![截图2][2]  
导航菜单中

Queues 是队列方式消息
    Topics 是主题方式消息
    Subscribers 消息订阅监控查询
    Connections 可以查看链接数，分别可以查看xmpp、ssl、stomp、openwire、ws和网络链接
    Network 是网络链接数监控
    Send 可以发送消息数据。

*  **python安装stomp**

输入如下命令安装stomp
    pip install stomp.py
    安装完成之后，可以做一个简单的连接测试了。

在conf目录下，修改activemq.xml,注册账号和密码  
添加如下代码:

<plugins>
                <simpleAuthenticationPlugin>
                    <users>
                        <authenticationUser username="manbuzhe" password="20180725" groups="users,admins"/>
                    </users>
                </simpleAuthenticationPlugin>
            </plugins>
             
            <transportConnectors>
                <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
                <transportConnector uri="stomp://localhost:61613"/>
            </transportConnectors>

**发送端**

import stomp
    import time
    # 推送到主题
    __topic_name1 = '/topic/FirstTopic'
    __topic_name2 = '/topic/SecondTopic'
    __host = '127.0.0.1'
    __port = 61613
    __user = 'manbuzhe'
    __password = '20180725'
    
    def send_to_topic(topic, msg):
    
        if topic == 1:
            conn.send(__topic_name1, msg)
        else:
            conn.send(__topic_name2, msg)
    
    
    if __name__ == '__main__':
        conn = stomp.Connection10([(__host, __port)])
        conn.start()
        conn.connect(__user, __password, wait=True)
        for i in range(10):
            send_to_topic(1, 'topic1: 测试信息1...')
            send_to_topic(2, 'topic2: 测试信息2...')
            time.sleep(5)
        conn.disconnect()

**接收端**

# -*-coding:utf-8-*-
    import stomp
    
    __listener_name = 'SampleListener'
    __topic_name1 = '/topic/FirstTopic'
    __topic_name2 = '/topic/SecondTopic'
    __host = '127.0.0.1'
    __port = 61613
    __user = 'manbuzhe'
    __password = '20180725'
    
    class SampleListener(object):
    
        def on_message(self, headers, message):
            print('每5秒发送一次')
            print('headers: %s' % headers['destination'])
            print('message: %s\n' % message)
    
    
    ## 从主题接收消息
    def receive_from_topic():
    
        conn = stomp.Connection10([(__host, __port)])
        conn.set_listener(__listener_name, SampleListener())
        conn.start()
        conn.connect(__user, __password, wait=True)
        conn.subscribe(__topic_name1)
        conn.subscribe(__topic_name2)
        while True:
            pass
        conn.disconnect()
    
    
    if __name__ == '__main__':
    
        receive_from_topic()

结果截图:  
![截图3][3]

[ActiveMQ 5.10.0 Release]: http://activemq.apache.org/download-archives.html
[1]: /images/20220515/f16186d2e8c443138b8e1345b370ae08.png
[http_localhost_8161]: http://localhost:8161
[2]: /images/20220515/92258300c8b84220abc2bcf0c0efa304.png
[3]: /images/20220515/40b2bc03c6674ad2a1af54943af68c69.png