gnsq

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

Functions

func ConsumerConnectToNSQD

func ConsumerConnectToNSQD(c *nsq.Consumer, address string, h nsq.Handler, nums int) error

ConsumerConnectToNSQDs 消费者直接连接到单个nsqd进行消费 hander消费者回调句柄是一个接口

func ConsumerConnectToNSQDs

func ConsumerConnectToNSQDs(c *nsq.Consumer, addressList []string, h nsq.Handler, nums int) error

ConsumerConnectToNSQDs 消费者直接连接到多个nsqd进行消费 hander消费者回调句柄是一个接口

func ConsumerConnectToNSQLookupd

func ConsumerConnectToNSQLookupd(c *nsq.Consumer, address string, h nsq.Handler, nums int) error

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

func InitConsumer(topic string, channel string, conf *nsq.Config) (*nsq.Consumer, error)

InitConsumer 初始化消费者 新建一个消费者

func InitProducer

func InitProducer(address string, conf *nsq.Config) (*nsq.Producer, error)

InitProducer 初始化生产者 address是nsqd连接的tcp地址

func NewConfig

func NewConfig() *nsq.Config

NewConfig 初始化nsq config

func Publish

func Publish(producer *nsq.Producer, topic string, msgBytes []byte) error

Publish 发布消息 当消息发送完毕后，需要producer.Stop() 让生产者优雅退出