Python访问ActiveMQ：使用stomp.py库的教程

本文主要介绍了如何使用Python访问Apache ActiveMQ，这是一种流行的开源消息代理，它支持多种协议，包括STOMP（Simple Text Oriented Message Protocol）。在Windows 10家庭中文版环境下，通过Python 3.6.4和stomp.py库（版本4.1.21），我们可以实现与ActiveMQ的交互。 首先，ActiveMQ允许Python客户端通过STOMP协议（默认端口61613）进行连接。在ActiveMQ的官方文档"Cross Language Clients"中，提供了详细的介绍和示例代码，分别展示了使用Python和Jython进行访问的步骤。Python访问时，主要依赖于stomp.py这个第三方库。 要使用stomp.py，需要从其官方网站下载源码，解压缩后，在命令行界面进入该目录，运行`python setup.py install`来安装。安装完成后，便可以开始编写Python代码与ActiveMQ进行通信。 以下是一个简单的官方示例代码，用于向名为"test"的队列发送一条消息： ```python import stomp class MyListener: # 定义监听器类，此处省略具体实现 conn = stomp.Connection() conn.set_listener('', MyListener()) # 设置监听器 conn.start() conn.connect('admin', 'password', wait=True) # 使用默认用户名和密码连接 conn.send(body='', destination='/queue/test') # 向队列发送消息 conn.disconnect() # 断开连接 ``` 在这个例子中，`stomp.Connection()`创建了一个连接对象，默认使用STOMP协议1.1。如果需要指定特定版本，可以在创建连接时传入相应的参数。此外，还可以通过传递参数来设置Broker的IP地址和端口，如`c = stomp.Connection([('127.0.0.1', 61613)])`。 值得注意的是，STOMP协议通常使用端口61613，而不是ActiveMQ的Web管理界面的端口8161。在实际应用中，应确保正确配置端口号，以免出现连接错误。 ActiveMQ提供了四种基本的测试场景，包括向队列（Queue）发送消息，这是点对点模式，消息只能被一个消费者接收且不可重复消费；向主题（Topic）发送消息，属于发布/订阅模式，允许多个消费者重复消费同一消息。 总结来说，Python开发者可以通过stomp.py库轻松地与ActiveMQ进行交互，实现消息的发送和接收，从而构建分布式系统中的异步通信机制。了解并掌握这些知识，将有助于在实际项目中有效利用消息队列来处理高并发和解耦问题。