• 1. Watermill 快速入门

  Watermill提供了一组发布/订阅的实现，本章介绍Watermill快速入门例子

• 2. 消息组件

  消息是Watermill的核心部分之一。消息通过“发布者”发布并由“订阅者”接收。当处理消息时，如果处理失败，您应该发送一个`Ack()`（表示成功处理）或一个`Nack()`（表示处理失败）。

• 3. 发布&订阅

  发布者和订阅者。

• 4. 消息路由

  发布者和订阅者是Watermill的比较底层的部分。在实际应用中，你通常希望使用高级接口和功能，比如关联、指标、毒消息队列、重试、限流等。

• 5. Watermill 转发器组件（消息事务）

  在一个事务中同时存储数据和发布事件，本章主要讲解事务消息机制。

• 6. CQRS

  Golang实现的Watermill中的CQRS机制。

• 7. 自定义消息队列

  自定义发布/订阅的底层使用什么消息队列。

• 8. Watermill 监控

  实时使用Prometheus监控Watermill。

• 9. Watermill 中间件

  中间件用于扩展事件框架，增加自定义功能，提供了对主处理程序的逻辑不相关但重要的功能。例如，在返回错误后重试处理程序，或者在处理程序中从恐慌中恢复并捕获堆栈跟踪。