0

我目前正在将消息传递给publish-subscribe-channel具有task-executor20 个消费者的线程池的分配的消息。

  • 这些入站消息描述实体的更新。
  • 我们会迅速收到有关许多实体的更新
  • 与同一实体相关的更新必须按照它们排队的顺序进行处理

显然，通过允许消息的并发处理，这消除了消息处理顺序的保证。

什么是允许并发处理不相关消息但确保对相关消息进行串行处理的适当拓扑？

4

1 回答 1

1

看起来这个DispatcherWorker是我想要实现的一个例子

于 2013-06-03T03:13:48.230 回答