README
¶
golang nsq
生产者和消费者封装，可以快速用于项目中
Documentation
¶
Index ¶
- func ConsumerConnectToNSQD(c *nsq.Consumer, address string, handler nsq.Handler, nums int) error
- func ConsumerConnectToNSQDs(c *nsq.Consumer, addressList []string, handler nsq.Handler, nums int) error
- func ConsumerConnectToNSQLookupd(c *nsq.Consumer, address string, handler nsq.Handler, nums int) error
- func ConsumerConnectToNSQLookupds(c *nsq.Consumer, addressList []string, handler nsq.Handler, nums int) error
- func InitConsumer(topic string, channel string, conf *nsq.Config) (*nsq.Consumer, error)
- func InitProducer(address string, conf *nsq.Config) (*nsq.Producer, error)
- func NewConfig() *nsq.Config
- func Publish(producer *nsq.Producer, topic string, msgBytes []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConsumerConnectToNSQD ¶
ConsumerConnectToNSQDs 消费者直接连接到单个nsqd进行消费 hander消费者回调句柄是一个接口
func ConsumerConnectToNSQDs ¶
func ConsumerConnectToNSQDs(c *nsq.Consumer, addressList []string, handler nsq.Handler, nums int) error
ConsumerConnectToNSQDs 消费者直接连接到多个nsqd进行消费 hander消费者回调句柄是一个接口
func ConsumerConnectToNSQLookupd ¶
func ConsumerConnectToNSQLookupd(c *nsq.Consumer, address string, handler nsq.Handler, nums int) error
ConsumerConnectToNSQLookupd 通过lookupd找到nsqd中的节点，进行消费 nums是nsqd消费者内部指定goroutine个数
func ConsumerConnectToNSQLookupds ¶
func ConsumerConnectToNSQLookupds(c *nsq.Consumer, addressList []string, handler nsq.Handler, nums int) error
ConsumerConnectToNSQLookupds 通过lookupd找到nsqd中的节点，进行消费 nums是nsqd消费者内部指定goroutine个数 addressList 表示有多个lookupd地址 hander消费者回调句柄是一个接口
func InitConsumer ¶
InitConsumer 初始化消费者 新建一个消费者
func InitProducer ¶
InitProducer 初始化生产者 address是nsqd连接的tcp地址
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.