nsq小试牛刀-0.3.0 API变更

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

NSQ是由知名短链接服务商bitly用Go语言开发的实时消息处理系统，具有高性能、高可靠、无视单点故障等优点，是一个非常不错的新兴的消息队列解决方案。

nsg易于配置和部署，所有参考都通过命令行指定，编译好的二进制文件，没有其它依赖项。而且支持多种消息格式。

关于nsq的介绍看这里：http://www.oschina.net/translate/day-22-a-journey-into-nsq

官网：http://nsq.io/overview/quick_start.html

相比之前，API更好用了。

对我来说，主要是部署简单，方便扩展。

直接上代码。

package mainimport (
"github.com/bitly/go-nsq"
"fmt"
"time"
)type Handle struct{
msgchan chan *nsq.Message
stop bool
}func (h *Handle) HandleMsg(m *nsq.Message) error {
if !h.stop{
h.msgchan <- m
}
return nil
}func (h *Handle) Process(){
h.stop = false
for{
select{
case m := <-h.msgchan:
fmt.Println(string(m.Body));
case <-time.After(time.Second):
if h.stop{
close(h.msgchan)
return
}
}
}
}func (h *Handle) Stop(){
h.stop = true
}func main(){
config := nsq.NewConfig()
consumer, err := nsq.NewConsumer("test", "my", config)
if err != nil{
panic(err)
}
h := new(Handle)
consumer.AddHandler(nsq.HandlerFunc(h.HandleMsg))
h.msgchan = make(chan *nsq.Message, 1024)
err = consumer.ConnectToNSQD("127.0.0.1:4150")
if err != nil{
panic(err)
}
h.Process()
}

另外，nsq的 topic和channel的关系：

http://word.bitly.com/post/38385370762/spray-some-nsq-on-it

Brief tangent: NSQ has the concept of topics and channels. Basically, think of a topic as a unique stream of messages (like our stream of API events above). Think of a channel as a copy of that stream of messages for a given set of consumers. Topics and channels are both independent queues, too. These properties enable NSQ to support both multicast (a topic copying each message to N channels) and distributed (a channel equally dividing its messages among N consumers) message delivery.

在代码里面：

consumer, err := nsq.NewConsumer("test", "my", config)

channel == my

如果有多个consumer是同一个channel的时候，消息只能被其中的一个consumer吃掉。如果多个consumer采用不同的channel，那么每个consumer都可以收到producer生产的同一个消息，这样很方便的支持了多播和分发。

=============================================================

NSQ 和 RabiitMQ的对比

一、RabbitMQ