Nsq.md

Nsq消息队列插件

介绍

• 从Nsq中消费消息

依赖

• rabbit/nsq

配置

• Nsq组件配置

return [
    'nsq' => [
      '{}' => BaseManager::class
    ]
];

• 插件配置

source_nsq:
  type: Rabbit\Data\Pipeline\Sources\Nsq
  topics:
    name:channel:
        dsn: "localhost:4161"
        dsnd: "localhost:4151"
        pool:
          min: 5
          max: 5

sink_nsq:
  type: Rabbit\Data\Pipeline\Sink\Nsq
  topic: test
  dsn: "localhost:4161"
  dsnd: "localhost:4151"
  pool:
    min: 5
    max: 5

• topic消息主题，生产者配置
• topics消息主题，消费者配置，必填,[]类型,key为主题名称:通道名称
• dsnnsqlookupd http host:port
• dsndnsqd http host:port
• pool连接池配置['min', 'max', 'wait', 'retry']