From 63090d45ab6a8a32d21bcd9eea9775c95a333403 Mon Sep 17 00:00:00 2001 From: Xargin Date: Sat, 1 Sep 2018 02:06:51 +0800 Subject: [PATCH] update cr --- ch6-cloud/ch6-09-crawler.md | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ch6-cloud/ch6-09-crawler.md b/ch6-cloud/ch6-09-crawler.md index d2b8cb6..47eeb5c 100644 --- a/ch6-cloud/ch6-09-crawler.md +++ b/ch6-cloud/ch6-09-crawler.md @@ -125,6 +125,8 @@ hello world #### 消息生产 +生产消息只要指定 subject 即可: + ```go package main @@ -154,6 +156,10 @@ func main() { #### 消息消费 +直接使用 nats 的 subscribe api 并不能达到任务分发的目的,因为 pub sub 本身是广播性质的。所有消费者都会收到完全一样的所有消息。 + +除了普通的 subscribe 之外,nats 还提供了 queue subscribe 的功能。只要提供一个 queue group 名字(类似 kafka 中的 consumer group),即可均衡地将任务分发给消费者。 + ```go package main