java - 数据扇出 Java 库

Question

这个问题涉及一个非常普遍的问题，我一直无法找到常规解决方案。

这是设置:

1. 您有许多消费者，每个消费者都订阅了一组符号
2. 您有许多生产者，每个生产者都为这些符号的一个不相交的子集生产数据
3. 消费者可能会因为太慢而无法消费对符号的所有更改已订阅，因此您可能需要节流
4. 消费者只对每个商品的最新数据感兴趣象征。如果消费者错过了符号的更新，并且更新数据可用，则只应发送最新的数据。

我经常遇到这个问题，每次都不得不重新发明轮子，例如实现一个队列，其中未使用的数据可以用更新的数据替换。我想知道是否有一些库可以有效地解决这个问题。

Answer 1

听起来像是您发布市场数据提要并且您希望客户订阅特定的提要，除此之外，您不需要队列，因为您不需要处理每条数据消息。使用 UDP 作为您的传输协议(protocol)来发布市场数据，因为 UDP 不需要在发送下一个数据包之前确认其数据包已被接收。客户端应该只缓存他们收到的最后一个值，不需要维护队列。然后，您可以让观察者观察最后一个值，并在它发生变化时将其发布到您的其他应用程序。