Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AfterMessagePublish ¶
AfterMessagePublish 定义在消息完成发送后的自定义事件
type ConsumerWorker ¶
type ConsumerWorker struct {
C *nsq.Consumer
ExitChan chan bool
// contains filtered or unexported fields
}
ConsumerWorker 消费者 Worker
func NewConsumerWorker ¶
func NewConsumerWorker(nsqdTCPAddrs []string, lookupdHTTPAddrs []string, topic string, channel string, handler func(topic string, message *nsq.Message), cfg *nsq.Config) (*ConsumerWorker, error)
NewConsumerWorker 创建消费者对象
func (*ConsumerWorker) HandleMessage ¶
func (w *ConsumerWorker) HandleMessage(m *nsq.Message) error
HandleMessage 处理消息,用于从NSD接收消息
type ProduceWorker ¶
type ProduceWorker struct {
// contains filtered or unexported fields
}
ProduceWorker 推送消息队列工作器
func NewProducer ¶
func NewProducer(addr string, cfg *nsq.Config) (*ProduceWorker, error)
NewProducer 新建推送队列工作器. 创建的实例将自动维护状态,如果cfg为空，则创建默认config.
func (*ProduceWorker) Publish ¶
func (w *ProduceWorker) Publish(topic string, message interface{}, afterWithargs ...interface{})
Publish 推送消息到Topic. topic 和 message 参数不能为空，如果为空，则忽略. 同时 Message 对象将转换为JSON格式发送，除非 Message 类型为[]byte.
type TopicDiscoverer ¶
type TopicDiscoverer struct {
// contains filtered or unexported fields
}
TopicDiscoverer Topic 集中管理
func NewTopicDiscoverer ¶
func NewTopicDiscoverer(cfg *nsq.Config, channel string, nsqdTCPAddrs, lookupdHTTPAddrs []string) *TopicDiscoverer
NewTopicDiscoverer 初始化创建主题订阅器.
func (*TopicDiscoverer) SubTopic ¶
func (td *TopicDiscoverer) SubTopic(topic string, handle nsq.HandlerFunc) error
SubTopic 订阅指定Topic. 订阅时不允许重复订阅，一个Topic只能被一个Handle接收并处理.
Source Files
Click to show internal directories.
Click to hide internal directories.