域事件的可靠异步处理

Question

在并发系统中，域事件通常是异步处理的。在 Go 中，可以通过channels实现一种简单的异步事件处理方法，但问题是如果处理事件发生了不好的事情，或者最坏的情况是，对于整个程序来说，事件将会丢失。

在 Go 程序中如何正确处理异步领域事件，即：

• 当事件处理程序失败时，不应从事件队列中清除该事件，以便稍后妥善处理。

• 如果整个程序宕机，则必须恢复事件并进行相应处理。

• 
  

Answer 1

第一个相对容易；您可以在工作人员中有一个错误处理程序，在发生错误时重新排队工作。第二个要难得多；你的选择是 a) 推出你自己的防弹机制，将事件写入磁盘并在它们以线程安全的方式完成时清除它们，或者 b) 使用许多已经证明可靠的流行系统之一，例如 RabbitMQ 或Kafka，具有适当的复制和冗余以确保您需要的可靠性级别。我强烈推荐后者。