将无法请求的实时消息传递给客户端的最佳方式是什么

Question

我们需要将实时消息传递给我们的客户，但他们的服务器在代理后面，我们无法初始化连接； webhook 变体不起作用。

考虑到以下情况，传递实时消息的最佳方式是什么：

• 代理后面的客户端
• 客户端可以长时间关闭，所有消息都必须投递
• 协议/方式必须足够通用，这样即使是 PHP 开发人员也可以轻松使用它

我想到了三种变体：

1. WebSocket - 客户端打开一个 websocket 连接，我们发送存储在 DB 中的消息，同时实时发送消息。
2. RabbitMQ - 所有消息都存储在一个持久的、持久的队列中。 如果合作伙伴在一段时间内不从队列中读取数据怎么办？
3. HTTP GET - 合作伙伴将按块提取消息。 在这种方法中，很难选择最佳的拉动间隔。

任何建议将不胜感激。谢谢！

Answer 1

由于您似乎必须在对等方未连接时存储消息，因此该问题同样适用于任何其他解决方案：如果对等方未连接并且消息正在排队，该怎么办？

如果您想要松散耦合，RabbitMQ 非常棒：分离生产者和消费者端。如果没有连接消费者，代理将为您存储消息。这确实会在一段时间后填满代理上的内存和/或磁盘空间 - 在这种情况下，RabbitMQ 将关闭。

一般来说，RabbitMQ 是一个非常棒的工具，可用于您所描述的基于消息传递的架构：

• 负载平衡：您可以使用多个发布者和/或消费者，从而分担负载。
• 灵活性：如果您的业务逻辑需要，您可以配置多个交换/队列/绑定。您可以轻松更改代理上的路由，而无需重新配置多个发布者/消费者应用程序。
• 流控制：RabbitMQ 还为您提供了一些用于流控制的内置方法 - 如果消费者速度太慢而无法跟上发布者，RabbitMQ 会减慢发布者的速度。
• 以后您可以轻松地重构架构。您可以设置多个代理并通过铲/联合将它们链接起来。如果您需要您的应用通过多个​​数据中心工作，这将非常有用。
• 您可以轻松发现一侧是否比另一侧慢，因为如果您的消费者无法以足够快的速度从队列中读取数据，队列就会开始增长。
• 高可用性和容错性。 RabbitMQ 非常擅长这些（感谢 Erlang）。

所以我会推荐它而不是其他两个（这对于小型应用程序可能有好处，但如果需求发生变化并且您需要扩大规模，您可能会快速发展它）。

编辑：我错过了一些东西 - 如果传递所有消息不是很重要，您可以使用 TTL（消息将在超时后丢弃）或限制（这限制队列中的消息数量，如果到达的新消息将被丢弃）。