v3

Documentation

Index

• func InitConsumer(topic string, channel string, address string)
• func InitProducer(str string)
• func Publish(topic string, message string) error
• func RandString(len int) string
• func StartReceive(topic, channel, address string)
• func StartSend(n int)
• type ConsumerT
  • func (*ConsumerT) HandleMessage(msg *nsq.Message) error

Functions

func InitConsumer

func InitConsumer(topic string, channel string, address string)

初始化消费者

func InitProducer

func InitProducer(str string)

func Publish

func Publish(topic string, message string) error

发布消息

func RandString

func RandString(len int) string

func StartReceive

func StartReceive(topic, channel, address string)

func StartSend

func StartSend(n int)

Types

type ConsumerT

type ConsumerT struct{}

消费者

func (*ConsumerT) HandleMessage

func (*ConsumerT) HandleMessage(msg *nsq.Message) error

处理消息