RabbitMQ 与 Websocket 和 Gevent

Question

我期待使用 Websocket 为我的 Web 应用程序开发实时 API。为此，我使用 RabbitMQ 作为代理，我的后端基于 python (gevent + websocket)，Pika/Puka 作为rabbitmq 客户端。

我在这里面临的问题是，我们如何使用websocket与rabbitMQ连接。初始websocket连接建立后，socket对象等待来自客户端的新消息，对于rabbitMQ，我们需要为其设置一个消费者，因此它会在收到消息时处理该消息。我们可以这样理解，

1. 客户端通过全双工 websocket 与服务器建立连接。
2. 在初始 websocket 握手后，所有客户端都应充当 RabbitMQ 的消费者，因此当客户端收到某些消息时，它们都会获得更新。
3. 当新消息到达websocket时，该客户端会将其发送到RabbitMQ，因此此时该客户端充当发布者。

问题是 Websocket 等待新消息，而 RabbitMQ 消费者在其通道上等待新消息，我无法链接这两种情况。

我不确定这是否是一个错误的方法......

我无法找到实现这种情况的方法。如果我走错了路或者有任何替代方法吗？请帮我解决这个问题。

谢谢你，

哈里达斯·N.

Answer 1

我用 Tornado + websocket + RabbitMQ + Pika 实现了类似的要求。

我认为这是已知的方法。这是我的这个网络聊天应用程序的 git 存储库。

https://github.com/haridas/RabbitChat

与 gevent/twisted 类似的事情似乎很难因为rabbitMQ客户端不支持gevent/twisted的事件循环。

鼠兔有龙卷风适配器，因此设置起来很容易。 Pika 开发团队也在开发扭曲适配器。我希望他们很快就会发布它。

谢谢，

Haridas N.

http://haridas.in。

Answer 2

一个简单的解决方案是使用 gevent.queue.Queue 实例进行 greenlet 间的通信。