消息可靠性机制,tcpip网络中没有可靠性机制

消息可靠性机制,tcpip网络中没有可靠性机制

前面提到的交易机制和发送方确认机制是发送方确认消息已成功发送的方式。 如果发送方一开始无法连接到MQ，SpringBoot中也有相应的重试机制。但是，这种重试RocketMQ存储使用本地磁盘来存储CommitLog消息数据，这必然会导致存储可靠性问题。 挑战在于确保消息不丢失。RocketMQ消息传递服务一直在不断提高数据的可靠性。 1存储可靠性挑战

1.2发送方确认机制发送消息时，将通道设置为确认模式。消息进入通道后，会被分配一个唯一的ID。一旦消息被投递到匹配队列，RabbitMQ就会向生产者发送确认。 当启用消息传递RabbitMqi时，可以使用事务、确认和持久性等机制来确保消息的可靠性。 1.消息持久化如上图所示，Features字段中有一个，就是持久化队列，英文是durable。 坚持

，不难看出RabbitMQ有一个死循环的设计，主要是遵循AMQP规范，其目的是避免一些暂时无法处理的消息出现死循环，同时也保证这些MQ消息不会暂时无法处理。 配置中的acknowledge-mode属性，这个是设置ack机制的类型，但是如果是consumer用**@RabbitListener注解实现的话，那么这里的设置不会生效，因为注解本身就有sackMod

(＊?↓˙＊) 我们还知道RabbitMQ是建立在AMQP协议之上的。为了保证消息传递的可靠性，这个应用层协议也借鉴了TCP的思想，形成了自己的一套消息ACK机制。 AMQP'sACKactuallyincludestwoaspects:1)Messagereliability:simplyput,nomessageislost.Onepartyintheconversationsendsamessage,andthemessagesuccessfullyreachestheotherpartyandisdisplayedcorrectly;2)Messageconsistency:includingthesendingparty'smessageconsistencyandconversationThemessagesfrombothpartiesareconsistentandrequiremessagesnottoberepeatedoroutoforder. 本文将从典型的IM消息发送逻辑开始。