水车 Watermill是一个Go库，用于有效处理消息流。 它旨在用于构建事件驱动的应用程序，启用事件源，消息之上的RPC，sagas以及您想到的其他任何东西。 您可以使用传统的pub / sub实现，例如Kafka或RabbitMQ，也可以使用HTTP或MySQL binlog（如果适合您的用例）。 目标 容易理解。 通用-事件驱动的体系结构，消息传递，流处理，CQRS-可以根据需要使用它。 快速（请参阅）。 灵活地使用中间件，插件和发布/订阅配置。 弹性-使用成熟的技术并通过压力测