使用Kafka和MongoDB进行Go异步处理
发布时间：2018-08-26 01:01:09 所属栏目：编程 来源：Melvin Vivas
导读：技术沙龙 | 邀您于8月25日与国美/AWS/转转三位专家共同探讨小程序电商实战 在我前面的博客文章我的第一个 Go 微服务：使用 MongoDB 和 Docker 多阶段构建 中，我创建了一个 Go 微服务示例，它发布一个 REST 式的 http 端点，并将从 HTTP POST 中接收到的数
|
我们来演示一下，运行微服务 1。确保 Kafka 已经运行了。
我使用 Postman 向微服务 1 发送数据。
Screenshot-2018-04-29-22.20.33 这里是日志，你可以在微服务 1 中看到。当你看到这些的时候，说明已经接收到了来自 Postman 发送的数据，并且已经保存到了 Kafka。
Screenshot-2018-04-29-22.22.00 因为我们尚未运行微服务 2，数据被微服务 1 只保存在了 Kafka。我们来消费它并通过运行的微服务 2 来将它保存到 MongoDB。
现在，你将在微服务 2 上看到消费的数据，并将它保存到了 MongoDB。
Screenshot-2018-04-29-22.24.15 检查一下数据是否保存到了 MongoDB。如果有数据，我们成功了！
Screenshot-2018-04-29-22.26.39 完整的源代码可以在这里找到： https://github.com/donvito/learngo/tree/master/rest-kafka-mongo-microservice 【责任编辑：庞桂玉 TEL：（010）68476606】点赞 0 （编辑：核心网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
