使用 Kafka 和 MongoDB 进行 Go 异步处理

在这个示例中，我将数据的保存和 MongoDB 分离，并创建另一个微服务去处理它。我还添加了 Kafka 为消息层服务，这样微服务就可以异步处理它自己关心的东西了。 下面是这个使用了两个微服务的简单的异步处理示例的上层架构图。           微服务 1 —— 是一个 REST 式微服务，它从一个 /POST http 调用中接收数据。接收到请求之后，它从 http 请求中检索数据，并将它保存

>>阅读原文<<