cometd 的Python消息缓存？

Question

我可以通过简化版本的示例来最好地描述我正在寻找的内容。 Tornado 的演示之一是一个简单的聊天服务器:

https://github.com/facebook/tornado/blob/master/demos/chat/chatdemo.py

我对此处的 MessageMixin 类感兴趣。它保留静态长度的消息积压，当新消息可用时，它返回新消息列表的切片。或者这就是它看起来的作用。我知道我之前在编写一个简单的 cometd 应用程序时已经实现了类似的东西。

那么有人概括了这一点并添加了一些奇特的东西吗？我对管理多种沟通 channel 并删除一段时间未使用的沟通 channel 的方法特别感兴趣。坚持不懈也可能有用。

这是 MQ 可以做的事情吗？

Answer 1

Redis有一个publish/subscribe功能，以及附加 data structure-oriented commands您可以使用它来保存和过期消息积压、列出给定房间中的用户或与他们关联的其他属性。该协议(protocol)基于文本，是 Memcached 命令的超集。

这里是使用chat as an example of pub/sub的描述以及 Ruby example using Websocket ，以及 Python 中使用 Websocket, Tornado and Redis pub/sub 的代码片段实现一个简单的聊天室。

根据您问题中的信息，专用消息队列(如 RabbitMQ )可能对您也有用。如果不知道您在消息量、容错、复制等方面的需求，就很难说。Redis 也可能是您正在寻找的，但如果没有其他的话，它非常简单，可以帮助您获得原型(prototype)快速运行以进一步确定您的应用程序的要求。