我可以通过简化版本的示例来最好地描述我正在寻找的内容。Tornado 的演示之一是一个简单的聊天服务器:
https://github.com/facebook/tornado/blob/master/demos/chat/chatdemo.py
我对MessageMixin
这里的课很感兴趣。它保留静态长度的消息积压,当有新消息可用时,它返回消息列表的新片段。或者这就是它看起来要做的事情。我知道我之前在编写一个简单的彗星应用程序时已经实现了类似的东西。
那么有没有人对此进行了概括并添加了一些花哨的东西呢?我对管理许多通信渠道和删除一段时间未使用的渠道的方法特别感兴趣。持久性也可能有用。
这是 MQ 可以做到的吗?