如何正确设置金字塔和ZeroMQ以提供简单的聊天/消息传递界面？
我正在尝试构建一个金字塔应用程序，它使用ZeroMQ提供一个非常简单的聊天/消息传递界面，但我似乎无法找到正确的设置/工作流程。
对我来说，这个结构似乎足够简单，最简单的形式可以用两个金字塔“视图”来描述：
- 客户端SSE“显示消息”视图：此视图/路由将对客户端保持打开状态（在客户端使用服务器发送的事件，在服务器端使用Pyramid的
响应.app_iter），监听来自ZeroMQ的消息，并在接收到消息时将其转发给客户端
然而，由于某种原因，我一直未能想出实现这一壮举的正确方法。谷歌似乎很少提到0MQ和金字塔的配方，我自己的所有黑客攻击要么导致Python/金字塔线程/进程问题，要么0MQ永远无法发送或接收任何消息（这可能与我的线程问题有关）。
那么，如何正确地构建这种具有金字塔的应用程序呢？
另外，你可以在回答中假设Python/Pyramid等的任何版本。关键是要得到像上面描述的那样有效的东西。
共有1个答案
几年前我就证明了这一点。
https://github.com/antoineleclair/zmq-sse-chat
-
我正在使用socket在Python3中创建一个简单的聊天 这是密码 客户 服务器 当用户连接时，如何向服务器打印字符串？ 在您插入名称后，我尝试添加此字符串 但对我来说，输出是不可靠的 另一个问题：为什么我在发送消息时会得到这样的东西？
-
问题内容： 我已经浏览了一些有关如何以及为何akka无法保证消息传递的帖子。该文档，这个讨论和小组其他讨论做解释它做好。 我对akka来说还很陌生，希望了解适合表壳的设计。例如说我有3个不同的角色，都在不同的机器上。一个负责食谱，另一个负责历史，最后一个负责技术书籍。 我在另一台机器上有个主要演员。假设对主角有一个查询，以搜索是否有可用的书。主参与者将请求发送到3个远程参与者，并期望结果。所以我这
-
我正在尝试用Java实现一个简单的生产者-->Kafka-->消费者应用程序。我能够成功地生成和使用消息，但是当我重新启动消费者时，问题就出现了，其中一些已经使用的消息再次被消费者从Kafka中拾取（不是所有的消息，而是最近使用的一些消息）。 我已在我的使用者中设置了，并且我的属性设置为1000毫秒。 “重新传递一些已使用的消息”是一个已知的问题，还是有任何其他设置，我没有在这里？ 基本上，有没有
-
本文向大家介绍jsp输出金字塔的简单实例，包括了jsp输出金字塔的简单实例的使用技巧和注意事项，需要的朋友参考一下 jsp输出金字塔的简单实例 以上就是小编为大家带来的jsp输出金字塔的简单实例全部内容了，希望大家多多支持呐喊教程~
-
我将不折不扣地学习以下教程：https://www.rabbitmq.com/tutorials/tutorial-two-java.html。 我以这样的方式启动RabbitMQ服务器： 我生成了两个消费者，当我Ctrl+C其中一个时，另一个正在运行的消费者不会接收到最初发往前一个消费者的消息。如何在Ctrl+C'ing从一个消费者中重新传递消息？ 编辑：我现在正在通过'brew'安装Rabbi
-
我正在使用AWS sdk开发基于SQS的队列pub-sub。 在非常基本的原型中，我将消息并发地推送到我已经创建的队列中。但是，如何才能确定我的消息正在被推送到队列中呢？