NSQ笔记

Part 0 前言

NSQ 是一种实时分布式消息（队列）平台，提供 Go 的官方版本。

参考资料：

• NSQ 官网
• NSQ 官方 GitHub
• NSQ 官方快速开始
• NSQ 安装

Part 1 服务

nsqlookupd

服务发现和协调的守护进程，充当 NSQ 集群中的服务发现机制，允许生产者和消费者发现可用的 NSQ 实例

nsqd

NSQ 中的守护进程，负责接收、缓冲、投递和处理消息，是核心组件

nsqadmin

监控和管理 NSQ 集群的 web 界面

Part 2 认证

Part 3 生产者

生产者客户端：与 NSQD 节点通信，将消息发布到 NSQ 中的 topic

使用 out.config 配置。

Part 4 消费者

消费者客户端：订阅 topic 并指定一个 channel

使用 in.config 配置

Part 5 消息传递流

生产者发布消息到 topic：

• 生产者将消息发布到特定的 topic。
• 例如，一个生产者发布订单消息到 order_topic。

消费者订阅 topic 和 channel：

• 消费者订阅一个 topic，并指定一个 channel。
• 例如，一个消费者订阅 order_topic 的 order_processing_channel。

消息分发：

• 所有订阅了相同 topic 但不同 channel 的消费者都会各自接收到该 topic 的完整消息副本。
• 不同 channel 的消息相互独立，不会互相干扰。

---

• ← Previous Post
• Next Post →

---