我在用:
最后一点与我当前的问题相关:负载平衡器将在主集群和次集群之间共享通信量。这意味着每个应用程序同时运行2个事件监听器。因此,他们只是对事件做出反应,但有时他们使用来自事件中心的相同事件,这会导致一些重复的通知邮件。
最后,我的问题是:我如何避免在同一时间两次阅读同一事件?我认为事件中心指数总是在增加,但从同一时刻开始并不是“安全的”。
发布于 2020-07-08 08:24:48
您将需要在avoid EPOCH error的每个荚中使用单独的使用者组。
也就是说,两个吊舱将读取相同的事件,因此您有两个选项。
幂等处理,其中处理相同的消息多次产生相同的结果,是好的做法,无论采取什么方法。这将允许您重播一批错误且不会对数据完整性产生不利影响的事件。
我会选择第一个选项,一个事件中心读取器每秒将处理数千个事件,并将工作传递给您的微服务。
如果您的消息数量较少,并且需要有保证的消息处理,那么使用Service可能是一个更好的选择,在那里可以锁定、完成和放弃消息。
https://stackoverflow.com/questions/62790232
复制相似问题