RocketMQ 的消息可靠性知道吗?

生产者的可靠性保证:

生产者发送消息后返回SendResult,如果isSuccess返回true,则表示消息已经确认发送到服务器并被服务器接收保存;整个发送过程是一个同步过程;

服务器的可靠性:

消息生产者发送的消息,RocketMQ 服务收到后在做必要的校验和检查之后马上保存到磁盘,写入成功后返回给生产者;因此可以确认每条发送结果为成功的消息都会被消息服务器写入磁盘;

消费者的可靠性:

消费者是一条一条顺序消费的,之后在成功消费一条后才会消费吓一跳;如果在消费某一条消息时失败则会重试消费这条消息,默认为5次,如果超过最大次数仍然无法消费,则将消息保存到本地,后台线程继续重试消费,主线程则会继续往后走,消费队列后面的消息;