Avatar notebook default
golang NSQ 分布式消息队列
13篇文章 · 2659字 · 3人关注
  • Resize,w 360,h 240
    nsq 消息队列设计

    消息传递设计 nsqlookupd：作用类似nsqd的注册中心，也复制给消费者提供nsqd地址 nsqd：管理topic和channel的守护进...

    0.1 875 0 1
  • nsq源码(12) nsqd 延时消息的投递

    除了常规的PUB指令发布消息，nsq还支持延迟投递，例如发布一个延时消息：30秒后自动断开连接 支持DPUB延时投递消息 虽然官方文档中nsqd...

    0.2 5266 0 3
  • nsq源码(10) nsqlookupd 注册nsqd

    nsqlookupd 总共支持4种指令执行，分别是PING、IDENTIFY、REGISTER、UNREGISTER nsqlookupd运行日...

    541 0 1
  • nsq源码(11) nsqlookupd与消费者交互

    nsq一共提供了几种消费者客户端工具：nsq_to_file、nsq_to_http、nsq_to_nsq nsq_to_file 消息写入文件...

    1896 0 2
  • nsq源码(8) 生产和消费流程

    总览nsqd、nsqlookupd的启动过程，消息的生产到消费的过程 绑定注册 nsqd --lookupd-tcp-address=127.0...

    500 0 1
  • nsq源码(9) nsqlookupd与nsqd交互

    nsqlookupd与nsq交互 nsqd带参数启动 除了接收pub发布的topic，还可以通过硬盘备份的文件恢复创建topic 在nsqd启动...

    1020 0 1
  • nsq源码(7) nsqd messageID

    messageID 消息唯一标识 GenerateID()返回ID NewGUID()生成ID

    721 0 2
  • nsq源码(6) nsqd 通知消息完成

    通知nsqd执行完成操作 在客户端接收到消息并处理完成之后，按照协议会向nsqd 发送一个 "FIN" 命令通知nsqd，移除队列信息

    427 0 1
  • nsq源码(5) nsqd 消息投递

    保证成功投递 nsq保证了"至少一次"成功投递，而不是仅一次 通过client.subChannel.StartInFlightTimeout(...

    779 0 3

文集作者