请教一个 NATS-STRAMING 的问题，不知道是不是个 bug…如果先 publish 消息，然后再启动 QueueSubscriber 的话，相同队列中只有一个 Subscriber 能够消费消息？

PUBLISHER 代码：

func main() { nc,err := stan.Connect("test-cluster","idc",stan.NatsURL("nats://127.0.0.1:4222")) if err != nil{ panic(err) } fmt.Println("connect succ") for i:=0;i<10;i++{ fmt.Println("publishing:",i) err := nc.Publish("tp1",[]byte(strconv.Itoa(i))) if err != nil{ panic(err) } } nc.Close() } 

QueueSubscriber 代码：

func main() { nc,err := stan.Connect("test-cluster","subscriber",stan.NatsURL("nats://localhost:4222")) if err != nil{ panic(err) } defer nc.Close() subs := make([]stan.Subscription,3) for i:=0;i<3;i++{ workername := "worker"+strconv.Itoa(i) fmt.Println(fmt.Sprintf("QueueSubscribe %s start",workername)) sub,err := nc.QueueSubscribe("tp1","ch1", func(msg *stan.Msg) { fmt.Println(workername,"get msg:",string(msg.Data),"start doing something") time.Sleep(1*time.Second) },stan.DurableName("subscriber"),stan.AckWait(time.Hour*24)) if err != nil{ panic(err) } subs[i] = sub } c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt, os.Kill) select{ case <- c: fmt.Println("Subscriber CLOSE") for i,_ := range subs{ subs[i].Close() } nc.Close() fmt.Println("quit") } } 

Publisher 输出：

connect succ publishing: 0 publishing: 1 publishing: 2 publishing: 3 publishing: 4 publishing: 5 publishing: 6 publishing: 7 publishing: 8 publishing: 9 

QueueSubscriber 输出：

QueueSubscribe worker0 start QueueSubscribe worker1 start worker0 get msg: 0 start doing something QueueSubscribe worker2 start worker0 get msg: 1 start doing something worker0 get msg: 2 start doing something worker0 get msg: 3 start doing something worker0 get msg: 4 start doing something worker0 get msg: 5 start doing something worker0 get msg: 6 start doing something worker0 get msg: 7 start doing something worker0 get msg: 8 start doing something worker0 get msg: 9 start doing something 

请问朋友们是否有遇到过一样的问题呢？谢谢大家