网站免费加速器,wordpress 密码错误,wordpress 环保公益主题,网站建设公司网站模板一、如何保证生产者生产消息100%的投递成功
保障消息的成功发出保障MQ节点的成功接收发送端收到MQ节点#xff08;Broker#xff09;确认应答完善的消息进行补偿机制
1. 理解Confirm确认消息机制
消息的确认#xff0c;是指生产者投递消息后#xff0c;如果Broker收到消…一、如何保证生产者生产消息100%的投递成功
保障消息的成功发出保障MQ节点的成功接收发送端收到MQ节点Broker确认应答完善的消息进行补偿机制
1. 理解Confirm确认消息机制
消息的确认是指生产者投递消息后如果Broker收到消息则会给我们生产者一个应答。生产者进行接收应答用来确定这条消息是否正常的发送到了Broker,这种方式也是消息可靠性投递的核心保障
1.1 Confirm确认消息流程解析 2. 理解Return消息机制
Return Listener 用于处理一些不可路由的消息 我们的消息生产者通过指定一个Exchange和RoutingKey把消息送达到某一个队列中去然后我们的消费者监听队列进行消费处理操作。 但是在某些情况下如果我们在发送消息的时候当前的exchange不存在或者指定的路由key路由不到这个时候如果我们需要监听这种不可达的消息就需要使用 Return Listener。
二、如何保证消费者消费消息成功
1.消费端的手工ACK和NACK
消费端进行消费的时候如果由于业务异常我们可以进行日志的记录然后进行补偿如果由于服务器宕机等严重问题那我们就需要手工进行ACK保障消费端消费成功
2.消费端的重回队列
消费端重回队列是为了针对没有成功处理掉消息把消息重新投递给Broker一般实际应用中都会关闭重回队列也就是设置为false。
三、如何保证MQ挂掉消息还在
可以设置交换机、队列、消息的持久化。
四、消息的限流
1.什么事消费端限流
假设一个场景我们的RabbitMQ服务器上有上万条未处理的消息我们随便打开一个消费者客户端。会出现下面情况
巨量的消息瞬间全部推送过来但是我们单个客户端无法同时处理这么多数据导致服务死掉。
RabbitMQ提供了一种qos服务质量保证功能既在非自动确认消息的前提下如果一定数目的消息通过基于consume或者channel设置的Qos的值未被确认前不进行消费新的消息。
void basicQos(int prefetchSize, int prefetchCount, boolean global) throws IOExceptionprefetchSize0prefetchCount告诉RabbitMQ不要同时给一个消费者推送多少条消息既一旦有N个小希还没有ack则该消费者将block掉直到有消息ackglobaltrue / false 是否将上面设置应用于 channel 简单点来说就是上面限制是 channel级别的还是consumer(消费者)级别的。
五、延迟消息 延迟交换机也就是说的定时消息
常见的应用场景比如商城下单每个订单有个30分钟倒计时30分钟到了后关闭订单。
延迟消息、可靠性消息 都在下面代码中。
代码地址
