行使Kafka和MongoDB举办Go异步处理赏罚

我们来演示一下，运行微处事 1。确保 Kafka 已经运行了。

$ go run rest-kafka-sample.go

我行使 Postman 向微处事 1 发送数据。

Screenshot-2018-04-29-22.20.33

这里是日记，你可以在微处事 1 中看到。当你看到这些的时辰，声名已经吸取到了来自 Postman 发送的数据，而且已经生涯到了 Kafka。

Screenshot-2018-04-29-22.22.00

由于我们尚未运行微处事 2，数据被微处事 1 只生涯在了 Kafka。我们来斲丧它并通过运行的微处事 2 来将它生涯到 MongoDB。

$ go run kafka-mongo-sample.go

此刻，你将在微处事 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

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!