在 python 中使用 AMQP 库发送和接收消息
Posted
技术标签:
【中文标题】在 python 中使用 AMQP 库发送和接收消息【英文标题】:Sending and receiving messages using AMQP library in python 【发布时间】:2018-01-12 07:33:06 【问题描述】:我找到了 AMQP 协议的官方 python 客户端。这是链接:https://pypi.python.org/pypi/amqp/
但我找不到任何关于如何实现相同的确切示例。我从这里阅读了它的文档:https://amqp.readthedocs.io/en/master/_modules/amqp/connection.html#Connection
从文档中,我尝试了以下代码:
import amqp.connection as connection
connection.Connection.collect()
但它要求文档中提到的一些回调。那么如何计算回调呢?
任何人都可以发布一个向任何公共服务器发送和接收消息的示例吗?任何帮助将不胜感激。
我已经尝试在 Google 上搜索相同的内容,但找不到任何确切的示例。谢谢你。
【问题讨论】:
【参考方案1】:我不熟悉这个库,但它似乎是从 amqplib 派生出来的,所以 amqplib 中的一些说明可能仍然适用:参见 https://github.com/barryp/py-amqplib/blob/master/docs/overview.txt。
我还发现了这个可能有帮助的要点:https://gist.github.com/nathanborror/109521/a4e9c5ba349cc7bb965c1092c6ea124a6c9e65d7
如果您对如何使用该库有任何疑问,最好在 GitHub 存储库上创建问题以寻求帮助 - 他们可能会感谢您的反馈。
【讨论】:
谢谢。我试图运行 github 库。但是找不到要连接的 AMQP 公共代理。有什么想法吗?以上是关于在 python 中使用 AMQP 库发送和接收消息的主要内容,如果未能解决你的问题,请参考以下文章
Spring AMQP 使用 noLocal 消费者使用临时队列发送和接收
Spring AMQP使用noLocal使用者发送和接收临时队列