可靠性投递需要四个部分:
- 保障消息的成功发出
- 保障 MQ 节点成功接收
- 生产者收到 MQ 节点(Broker)确认应答
- 消息补偿机制
方案一:
消息先入库,对消息的状态进行标记。
- 消息先入库,对消息的状态进行标记。例如:status1
- 向 MQ 发送消息。
- MQ 将应答发送给生产端,生产端要监听 MQ 的应答。
- 如果收到了确认的应答。那么修改消息的状态为发送成功。
- 如果没有收到 MQ 应答,需要有一个定时任务捞取 status1 状态的消息再次发送。这个时候消息需要有最大的重试次数的限制。
流程如下图所示:
方案一.png
方案二:
消息的延迟投递,做二次确认,回调检查。
- 先把消息发送给 MQ 的队列 A。
- 延迟一定的时间第二次发送一样的消息给 MQ 队列 B。B 是 A 的备份。
- 有一个单独的服务(callback service)监听 MQ 队列 A 的响应。并且接受队列 B 的消息。
- 如果 callback service 收到了队列 A 的消息确认,那么入库标记。
- 延迟投递的消息开始发送到 B 队列。
- callback service 收到队列 B 中的数据,去数据库里查询这个消息的状态
- 如果状态不是成功则 callback service 则通知生产者,该消息没有收到响应。
- 生产者如果收到 callback service 的消息。那么就走计数,补偿,告警等步骤。
流程如下图所示:
方案二.png
网友评论