NSQ 客户端 1、创建topic curl -X POST 'http://nsq-lookup.infrastructure.svc.cluster.local:4161/topic/create?topic=flyele-nsq-socket-multicast-release&partition_num=2&replicator=1&extend=true&disable_channel_auto_create="true"&orderedmulti=true' 2、创建channel curl -X POST 'http://nsq-lookup.infrastructure.svc.cluster.local:4161/channel/create?topic=flyele-nsq-socket-multicast-release&channel=XXXX.

NewBalancedPusher returns a BalancedPusher.

NewMultiPusher returns a MultiPusher.

NewQueue returns a Queue.

ErrNoAvailablePusher indicates no pusher available.

A BalancedPusher is used to push messages to multiple pusher with round robin algorithm.

A MultiPusher is a pusher that can push messages to multiple underlying pushers.

A MessageQueue interface represents a message queue.