nsq

Documentation

Overview

	//init
	 pu,err:=NewProducer("192.168.0.197",4150)
	 if err!=nil{
		//error
	 }
	 b,_:=json.Marshal(obj)
  	 //发送
	 err = pu.Publish("topic",b)
	 if err!=nil{
		//error
	 }

Index

• type MessageHandler
  • func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)
  • func (m *MessageHandler) Registry(topic string, ch chan []byte)
• type Producer
  • func NewProducer(addr string) (producer *Producer, err error)
  • func (m *Producer) Publish(topic string, data []byte) (err error)

Types

type MessageHandler

type MessageHandler struct {
	Channel string
	// contains filtered or unexported fields
}

MessageHandler MessageHandler

func NewMessageHandler

func NewMessageHandler(nsqServer string, channel string) (mh *MessageHandler, err error)

NewMessageHandler return new MessageHandler

func (*MessageHandler) Registry

func (m *MessageHandler) Registry(topic string, ch chan []byte)

Registry Registry

type Producer

type Producer struct {
	P *gnsq.Producer
}

Producer Producer

func NewProducer

func NewProducer(addr string) (producer *Producer, err error)

NewProducer init

func (*Producer) Publish

func (m *Producer) Publish(topic string, data []byte) (err error)

Publish publish