nsq 消息队列设计

消息传递设计

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

  • nsqadmin：前端管理web


    消息流向.png

特征

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

分布式和去中心化

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

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

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容