Watermill Watermill是一个Go库，用于有效处理消息流。 它旨在用于构建事件驱动的应用程序，启用事件源，消息上的RPC，sagas以及Watermill基本上提供的其他功能Watermill是一个Go库，用于有效地处理消息流。 它旨在用于构建事件驱动的应用程序，启用事件源，消息上的RPC，sagas以及您想到的其他任何东西。 您可以使用传统的pub / sub实现，例如Kafka或RabbitMQ，也可以使用HTTP或MySQL binlog（如果适合您的用例）。 目标易于理解。 通用-事件驱动的体系结构，消息传递，流处理，CQRS-将其用于任何用途