rabbitMQ消息的可靠性投递分析和保证方案

ゞ浴缸里的玫瑰 2023-01-14 14:56 131阅读 0赞

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70]  
上面四个环节都会可能数据丢失

# 1.保证发送消息安全 #

## 第一种方式：服务端确认-transaction ##

// 将chnnel设置为事务模式  
channel.txSelect();  
// 提交事务  
channel.commit  
// 事务回滚  
channel.txRollback  
如果没有commit不会写入

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 1]  
这种模式浪费服务性能，一般不会用这种方式

## 第二种方式 ##

// 将channel设置为confirm 确认模式模式  
channel.comfirmSelect()  
// 判断，实际上是发送消息后得到broker的ack应答，如果producer收到应该，说明已经成功发送  
if(channel.waitForConfirms())\{  
// 发送消息成功  
\}  
这种方式，发一次确认一次，效率地下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 2]  
当然也可以全部发送完了再确认，只要中间没有异常  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 3]

批量存在的问题是，发送多少确认一次，设置多少是合理的。

## 第三种方式：异步确认 ##

一边发送一边确认  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 4]

# 2.路由保证（如何处理无法路由的消息） #

当消息发送失败，找不到指定的队列（如队列不存在，或者routing-key设置错误）的处理办法

*  1.添加回发监听器，此时将消息返回生产者，消息发送失败；
 *  2.将消息发送给备份交换机  
    ![在这里插入图片描述][20210420223320136.png]  
    1.第一种添加回发监听器案例：returnListener.(相当于快递被退回)  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 5]

2.备份交换机案例  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 7]

# 3.消息在队列里存储如何保证安全 #

保证queue安全。将持久化

*  队列持久化durable 生产环境设置为true  
    ![在这里插入图片描述][20210420224352545.png]
 *  交换机持久化
 *  消息持久化  
    消息持久化如何做？ （可能会存在这种情况，队列还在，消息却没了）  
    发送消息时候，可以设置属性。properties  
    ![在这里插入图片描述][20210420224517885.png]  
    properties如下： 2表示消息持久化  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 8]

# 4.保证消费者正确消费 #

保证消息准确发送到消费者手中。  
这是需要消费者返回一个ack给broker，然后队列删除这条消息  
发送ack发送有两种方式  
1.自动。没有特殊处理的情况下，是自动发送ack给broker。这里可能会存在，业务逻辑没开始处理，已经返回ack，可能导致消息没有被正常处理，就把消息删除了‘

2.手动basicAck就是手动发送，确保业务逻辑处理完成才返回ack

![在这里插入图片描述][20210420225322760.png]

# 生产者如何知道消费者已经消费了，可靠性分析 #

1.消费者回调:调用生产者预先定义好的api，消费者回复一条消息。  
2.补偿机制：定义超时时间，如果5分钟还没有收到回复的消息，那么就重发。创建一个定时任务，将消息重发。控制重发次数。保证消息幂等性（设置消息唯一标识）  
3.最终一致：如果一直得不到消费者状态（消费者挂掉），比如使用对账  
4.消息幂等性：消息幂等性（设置消息唯一标识），多次发送结果一致  
5.消息顺序性：消息的消费是有一定顺序。  
rabbitmq里面，只有当1队列只有1个消费者的时候，才会保证消息的顺序性

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70]: /images/20221022/01e95a3f9a7543f4af84be871b019690.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 1]: /images/20221022/7a987ea22ad2415da8db5267b934615b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 2]: /images/20221022/49f18b97187544b886a24e155dee390b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 3]: /images/20221022/d660006fa7974f9fa5ff281047739825.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 4]: /images/20221022/ebf9c5cb20324c6588306add385c2857.png
[20210420223320136.png]: /images/20221022/8ffebda703124fceaa056a1019993c23.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 5]: /images/20221022/d7140d6a6a1347b29f11c28aec4c8643.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 6]: /images/20221022/472fefe50cf94661b58156089a2d3d2d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 7]: /images/20221022/c8a1bc5c376049bba3c81bd034f8db0a.png
[20210420224352545.png]: /images/20221022/20f3c2525105498a9115f4423db38fbc.png
[20210420224517885.png]: /images/20221022/bc43b8e681c0463b9fed406c17d53eec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3MTg1MTUwMjg_size_16_color_FFFFFF_t_70 8]: /images/20221022/b7458a16c6a24f2e87f6db303cc73c07.png
[20210420225322760.png]: /images/20221022/87ee1f8e02804a3c92efb50ac902a80a.png