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