深入剖析使用Python通过STOMP协议吸取ActiveMQ消息

哈喽，各人好，我是木头左！
在今世分布式体系中，消息通报是实现体系组件之间解耦和异步通讯的关键。Apache ActiveMQ是一个广泛使用的开源消息署理，它支持多种消息通报协议，包罗STOMP（Simple Text Oriented Messaging Protocol）。本文将具体表明怎样使用Python通过STOMP协议与ActiveMQ举行交互，并展示怎样吸取和发送消息。
  初始化毗连

须要初始化与ActiveMQ的毗连。这涉及到创建一个stomp.Connection对象，并设置相干的参数。

1. import stomp
2. from util import log_util, pwd_util
3. log = log_util.get_logger()
4. listener_name

复制代码