如何只订阅 nsq 某个 topic下的特定channel?

发布于 2022-09-07 08:11:00 字数 1165 浏览 13 评论 0

本地环境:
testtopic下 有 两个channel: testchannel1, testchannel2,通过nsq_to_http的方式把数据消费到http接口上
e.g:
消费者1:
/usr/local/opt/nsq/bin/nsq_to_http --topic=testtopic --channel=testchannel1 --lookupd-http-address=127.0.0.1:4161 --post=http://xx.xx.xx/index.php?typ... --content-type=application/x-www-form-urlencoded
消费者2:
/usr/local/opt/nsq/bin/nsq_to_http --topic=testtopic --channel=testchannel2 --lookupd-http-address=127.0.0.1:4161 --post=http://xx.xx.xx/index.php?typ... --content-type=application/x-www-form-urlencoded

测试执行:
curl -d "hello=world&a=1" 'http://127.0.0.1:4151/pub topic=testtopic&channel=testchannel1'

结果:
http://xx.xx.xx/index.php 中 可以接收到 type=consumer2 的请求

问题:
我不管往哪个channel下push数据, 我的两个消费者都会同事接收到数据。 那我的业务逻辑就乱套了。我不明白nsq 多个channel 到底是怎么用的? 我知道应该是我使用的问题,所以请各位指导一下 如何 只消费特定 channel下的数据?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

姜生凉生 2022-09-14 08:11:00

思维走入误区

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文