README
¶
golang nsq
golang nsq消费队列封装，提供如下功能点
1、初始化生产者
2、初始化消费者
3、提供不同方式的消费者消费模式
4、当调用InitProducer,InitConsumer后可以直接调用nsq上底层方法
也可以使用本包提供的方法，其实也是调用nsq底层方法
5、关于优雅退出生产者和消费者，请看nsq_test.go
6、通过直接连接到nsqd进行消费，速度快，但不方便拓展，建议通过lookupd查找节点进行消费
Documentation
¶
Overview ¶
* golang nsq消费队列封装，提供如下功能点
1、初始化生产者 2、初始化消费者 3、提供不同方式的消费者消费模式 4、当调用InitProducer,InitConsumer后可以直接调用nsq上底层方法 也可以使用本包提供的方法，其实也是调用nsq底层方法 5、关于优雅退出生产者和消费者，请看nsq_test.go 6、通过直接连接到nsqd进行消费，速度快，但不方便拓展，建议通过lookupd查找节点进行消费
Index ¶
- func ConsumerConnectToNSQD(c *nsq.Consumer, address string, h nsq.Handler, nums int) error
- func ConsumerConnectToNSQDs(c *nsq.Consumer, addressList []string, h nsq.Handler, nums int) error
- func ConsumerConnectToNSQLookupd(c *nsq.Consumer, address string, h nsq.Handler, nums int) error
- func ConsumerConnectToNSQLookupds(c *nsq.Consumer, addressList []string, h 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 ¶
ConsumerConnectToNSQDs 消费者直接连接到多个nsqd进行消费 hander消费者回调句柄是一个接口
func ConsumerConnectToNSQLookupd ¶
ConsumerConnectToNSQLookupd 通过lookupd找到nsqd中的节点，进行消费 nums是nsqd消费者内部指定goroutine个数
func ConsumerConnectToNSQLookupds ¶
func ConsumerConnectToNSQLookupds(c *nsq.Consumer, addressList []string, h 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.