如何让 Python 应用程序保持活跃并监听 ActiveMQ？

Question

我是 Python 新手，所以也许这是一个微不足道的问题，但我还没有找到我正在寻找的答案。

我正在使用消息代理 (ActiveMQ) 和 STOMP 对数据运行不同的 Python 应用程序。我能够构建和运行一个应用程序，该应用程序将消息发送到它订阅的通道并触发侦听器方法。现在我正在尝试从一个 Python 应用程序（“发送者”）向队列发送一条消息，并从另一个 Python 应用程序（“接收者”）订阅它。但是，在接收器中设置连接/订阅者后，我如何使其保持活动状态并无限期地监听来自发送者的消息？

我发现的其他线程使用sleep 语句在技术上确实阻止了应用程序退出，但它也阻止了应用程序，因此它也不做任何事情。

Answer 1

听起来您需要添加一个带有 keep_running() 类型检查的循环以允许您跳出循环。此外，通常最好有办法发出重新连接以刷新连接（在 n 条消息和/或时间段之后）。

伪代码：

while keep_running():
  // check if we need to setup or reset connection & register listener
  sleep(0.2) // make this short 

// disconnect

keep_running()

def keep_running():

// some reasons to return 'false'
   return False

// else 
   return True

参考：STOMP Python library