数据扇形Java库

Question

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

下面是设置：

您有许多用户，每个用户都订阅了一组符号( symbols

• Consumers

• )--每个生产者都为这些的一个不相交的子集生成数据--可能太慢了，无法使用他们订阅的符号的所有更改，因此您可能需要throttle

1. Consumers，因此您可能只对每个符号的最新数据感兴趣。如果用户错过了对符号的更新，并且可用更新的数据，则只应发送最新的数据。

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

Answer 1

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