nsq 消息队列设计

消息传递设计

• nsqlookupd：作用类似nsqd的注册中心，也复制给消费者提供nsqd地址
• nsqd：管理topic和channel的守护进程，处理发布、订阅等指令的具体进程

• nsqadmin：前端管理web

  
  消息流向.png

特征

• 消息不是持久的(默认情况下)
• 消息至少传递一次
• 接收的消息是无序的
• 消费者最终会找到所有的主题生产者

分布式和去中心化

• 消费者通过nsqlookupd和指定topic来获取对应nsqd地址
• nsqd之间的topic互不共享
• topic会在当前nsqd的每个channel拷贝

当多个nsqd服务都有相同的topic的时候，consumer要修改默认设置config.MaxInFlight才能连接