在 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使用者发送和接收临时队列

Spring AMQP - 发送和接收消息

Spring AMQP项目

如何使用 JMS 和 AMQP 1.0 设置 RabbitMQ?

用PHP尝试RabbitMQ(amqp扩展)实现消息的发送和接收