有关broker的问题

[bluedragonflyliu]

我看到transport 有用到 nats的例子，但是broker没有nats的例子, examples 里的broker好像即使没安装RabbitMQ，和NATS 也能工作，但是如果指定使用nats呢？我尝试用go-micro/broker/nats 没能成功，不知道正确用法是什么样的。
1 .在192.168.1.3 上启动nats
nats-server -m 8222
2.在192.168.1.4和192.168.1.5 上运行修改后的 broker/consumer 和 broker/producer

   _ "github.com/micro/go-micro/broker/nats

    br := nats.NewBroker(broker.Addrs("nats://192.168.1.3:4222"))
if err := br.Connect(); err != nil {
	log.Fatalf("Broker Connect error: %v", err)
}

[bluedragonflyliu]

即便是同一个机器
consumer.go

package main

import (
"fmt"
"log"

"github.com/micro/go-micro/broker"
"github.com/micro/go-micro/config/cmd"
// To enable rabbitmq plugin uncomment
_ "github.com/micro/go-micro/broker/nats"

)

var (
topic = "go.micro.topic.aaa"
)

// Example of a shared subscription which receives a subset of messages
func sharedSub() {
_, err := broker.Subscribe(topic, func(p broker.Event) error {
fmt.Println("[sub] received message:", string(p.Message().Body), "header", p.Message().Header)
return nil
}, broker.Queue("consumer"))
if err != nil {
fmt.Println(err)
}
}

// Example of a subscription which receives all the messages
func sub() {
_, err := broker.Subscribe(topic, func(p broker.Event) error {
fmt.Println("[sub] received message:", string(p.Message().Body), "header", p.Message().Header)
return nil
})
if err != nil {
fmt.Println(err)
}
}

func main() {
cmd.Init()
if err := broker.Init(); err != nil {
log.Fatalf("Broker Init error: %v", err)
}
if err :=broker.Connect(); err != nil {
log.Fatalf("Broker Connect error: %v", err)
}

sub()
select {}

}

启动 go run consumer.go --broker=nats --broker_address=127.0.0.1:4222
producer.go
package main

import (
"fmt"
"log"
"time"

"github.com/micro/go-micro/broker"
"github.com/micro/go-micro/config/cmd"
// To enable rabbitmq plugin uncomment
_ "github.com/micro/go-micro/broker/nats"

)

var (
topic = "go.micro.topic.aaa"
)

func pub() {
tick := time.NewTicker(time.Second)
i := 0
for _ = range tick.C {
msg := &broker.Message{
Header: map[string]string{
"id": fmt.Sprintf("%d", i),
},
Body: []byte(fmt.Sprintf("%d: %s", i, time.Now().String())),
}
if err := broker.Publish(topic, msg); err != nil {
log.Printf("[pub] failed: %v", err)
} else {
fmt.Println("[pub] pubbed message:", string(msg.Body))
}
i++
}
}

func main() {
cmd.Init()
if err := broker.Init(); err != nil {
log.Fatalf("Broker Init error: %v", err)
}

if err := broker.Connect(); err != nil {
	log.Fatalf("Broker Connect error: %v", err)
}

pub()

}

启动go run producer.go --broker=nats --broker_address=127.0.0.1:4222
能看到 producer.go 在发消息但是consumer却没接收

[bluedragonflyliu]

得到解决
需要引入 github.com/micro/go-plugins/broker/nats
而非 "github.com/micro/go-micro/broker/nats"
这两个有点混乱

[printfcoder]

混乱是指我们示例没有写好还是指？如果没有写好还请指示一下，我们好改进或者您帮忙修正一下

[bluedragonflyliu]

这个问题要从"github.com/micro/go-micro/config"说起，以前这个在go-plugins 搞得我问很久，各种实验，才知道换地方了，我还以为go-plugins 已经放弃不在使用了，于是在练习broker的时候也用了go-micro 里的broker 关键里面确实有而且还有nats，最关键的是还能生成消息，nats里也能看到，但是却不消费消息。昨天我看go-plugins仍在更新所以知道之前的理解有误并没放弃go-plugins我就尝试修改用go-plugins里的broker和nats 一实验成了，说起来都是泪啊。