讲解 可靠性投递,我们就需要知道 这个MQ 的投递过程 与 消费者接收过程
投递:首先 producer 发送 到 rabbitMQ boker ,接下来 boker 发送至 exchange ,然后由 exchange 路由发送到 queue中
接收:consumer 监听 queue 即可
消息 在producer 发送的时候 指定一个 callback 方式。 等到消息到 exchange的时候 无论是否成功都要返回一个 confirmCallback 如果为true 就为发送成功
消息从 exchange 路由 queue 投递 失败就会返回 returnCallback
利用好上述2种模式 ,就可以保证消息 可靠性投递了。
特殊说明: 解决问题的光鲜,藏着磕Bug的痛苦。 万物皆入轮回,谁也躲不掉! 以上文章,均是我实际操作,写出来的笔记资料,不会出现全文盗用别人文章!烦请各位,请勿直接盗用!