上篇文章简单介绍了nsq writer部分的使用:http://guotie.sinaapp.com/?p=533 ,本文介绍一下reader的使用。
与writer类似,nsq提供了一个高层接口:reader。不过,reader部分还需要提供一个Handler,用来处理收到的消息。
nsq reader的Handler是一个接口,定义如下:
type Handler interface { HandleMessage(message *Message) error }
我们所做的主要就是实现这个接口。
reader的基本步骤如下:
1、新建一个nsq reader;
NewReader的定义如下:
func NewReader(topic string, channel string) (*Reader, error)
topic是nsqd的topic,channel可以理解为这个reader的名称。一个topic可以有多个reader同时去读,每个reader都是一个channel。
2、使用AddHandler将具体处理消息的Handler加入到reader;
除了AddHandler函数外,还有AddSyncHandler,增加一个异步处理消息的函数到reader,详细信息可以参考文档。
3、reader连接Nsqd;搞定!
当reader连接到Nsqd后,go-nsq收到消息后,会调用我们的Handler处理消息。
package nsqexample import ( "github.com/bitly/go-nsq" "fmt" ) var _ = fmt.Printf var ( rd *nsq.Reader ) type ClickHandler struct { nsqaddr string } func NsqClick(nsqaddr string) { rd, err := nsq.NewReader("clicks", "ch1") if err != nil { panic(err.Error()) } click := ClickHandler{nsqaddr: nsqaddr} rd.AddHandler(&click) err = rd.ConnectToNSQ(click.nsqaddr) if err != nil { panic(err.Error()) } } func (c *ClickHandler) HandleMessage(msg *nsq.Message) error { // 处理消息代码 fmt.Println(string(msg.Body)) return nil }
go-nsq的官方文档:http://godoc.org/github.com/bitly/go-nsq#Reader
有疑问加站长微信联系(非本文作者)