关于MQ发布/订阅输出结果的疑问

老师，发布/订阅的代码，为啥输出的结果是从 message 2开始的？
c: message 2
c: message 2
c: message 3
c: message 3
c: message 4
c: message 4
c: message 5
c: message 5

不是应该从 message 1开始的，message 1是丢失了吗？

lieh1203 2022-11-05

源自：租辆酷车-实时位置服务 2-3 使用go语言实现pub-sub

11

收起

1回答

ccmouse 回答被采纳获得+3积分 2022-11-13 11:49:49

这是个好问题。的确是丢了。因为我在Publish的时候是这么设置的。

err := ch.Publish(
exchange,
"", // key
false, // mandatory
false, // immediate
amqp.Publishing{
Body: []byte(fmt.Sprintf("message %d", i)),
},
)

当immediate和mandatory都为false时，收不到的消息就会被丢掉。当其中一个为true，消息会通过Channel.NotifyReturn返还给消费者。immediate和mandatory的区别很细微，而且最新的更新中immediate已经被去掉了。所以可以不深究它们的区别。

最后这里为什么会丢掉，我们在go subscribe(conn, exchange)之后立刻就开始了发送，此时订阅(subscribe)方由于是在并行执行的goroutine中，还没来得及准备好接收。可以通过额外的go channel来让接收方通知发送方表示已经准备好，这样就不会丢。

lieh1203 提问者 #1
老师，"您说可以通过额外的go channel来让接收方通知发送方表示已经准备好"，这块只能通过自己写代码实现是吧？
amqp库内部没有封装通知发送方已经准备好的方法是吧？

例如我下面的写法，consume创建成功后，发个消息给confirmCh，然后在publish之前等待confirmCh收到消息。
```
consume(consumer string, ch *amqp.Channel, q string, confirmCh *confirmConsume) {
   msgs, err := ch.Consume(
      q,
      consumer, ,     ,    ,    ,    nil,      )
   err != nil {
      panic(err)
   }

   confirmCh <- &confirmConsume{}

   msg := msgs {
      fmt.Printf(, consumer, msg.Body)
   }
}
```
2022-11-13 15:23:40

相似问题

关于发布订阅。

基于MQ的分布式事务的疑问

关于发布订阅模式

关于9-6订阅发布的几个问题

广播的实现机理是消息发布/订阅模式的事件驱动模型怎么理解呢

登录后可查看更多问答，登录/注册

Go开发工程师

参与学习人
提交作业 65 份
解答问题 1404 个

Google架构师ccmouse联合大厂架构师合作推出。两位架构师，跨行业项目，共享租车项目面向未来，三端分离电商立足当下，助你吃透Go全栈开发。抓住当下，面向未来蓝海行业，提前突破35岁职业瓶颈！

本课精华内容

问答作业

造车运动

176 1

代码不一样，不知道怎么继续下去了

252 3

添加`bson:"inline"`后的数据库数据结构依然跟老师不同

40 1

button的样式写到wxss中不起作用

37 1

5-2 13:22，示范小BUG

37 1

查看更多本课问答

请稍等 ...

意见反馈帮助中心 APP下载