延遲隊列

當(dāng)一個隊列中的消息滿足下列情況之一，可以成為死信：
（1）消費者使用basic.reject或basic.nack聲明消費失敗，并且消息的requeue參數(shù)設(shè)置為false
（2）消息是一個過期消息，超時無人消費
（3）要投遞的隊列消息堆積滿了，最早的消息可能成為死信
如果該隊列配置了dead-letter-exchange屬性，指定了一個交換機，那么隊列中的死信就會投遞到這個交換機中，而這個交換機稱為死信交換機。
如何給隊列綁定死信交換機？
（1）給隊列設(shè)置dead-letter-exchange屬性，指定一個交換機
（2）給隊列設(shè)置dead-letter-routing-key屬性，設(shè)置死信交換機與死信隊列的RoutingKey

TTL(Time-To-Live)。如果一個隊列中的消息TTL結(jié)束仍未消費，則會變?yōu)樗佬?，TTL超時分為兩種情況：
（1）消息所在的隊列設(shè)置了存活時間
（2）消息本身設(shè)置了存活時間

利用TTL結(jié)合死信交換機，實現(xiàn)了消息發(fā)出后，消費者延遲收到消息的效果。這種消息模式就稱為延遲隊列模式。
延遲隊列的使用場景包括：
（1）延遲發(fā)送短信
（2）用戶下單，如果用戶在15 分鐘內(nèi)未支付，則自動取消
（3）預(yù)約工作會議，20分鐘后自動通知所有參會人員

DelayExchange的本質(zhì)還是官方的三種交換機，只是添加了延遲功能。因此使用時只需要聲明一個交換機，交換機的類型可以是任意類型，然后設(shè)定delayed屬性為true即可。
基于注解的方式：

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "DelayQueue",durable = "true"),exchange = @Exchange(name = "delay-mq-exchange_B",delayed = "true"),key = "routingKey_delay"))
@Component
@Slf4j
public class DirectConsumer {
	......
}

基于Java代碼的方式：

	@Bean
    public Exchange orderExchange(){
        return ExchangeBuilder.topicExchange(RabbitMQExchanges.EXCHANGE_B.getExchange()).delayed().durable(true).build();

    }

向delay為true的交換機中發(fā)送消息，一定要給消息添加一個header：x-delay，值為延遲的時間，單位為毫秒：

Message message= MessageBuilder.withBody(String.valueOf(content).getBytes(StandardCharsets.UTF_8)).setHeader("delay-one",500000).build();

惰性隊列

**消息堆積問題：**當(dāng)生產(chǎn)者發(fā)送消息的速度超過了消費者處理消息的速度，就會導(dǎo)致隊列中的消息堆積，直到隊列存儲消息達(dá)到上限。最早接收到的消息，可能就會成為死信，會被丟棄，這就是消息堆積問題。

惰性隊列的特征如下：
（1）接收到消息后直接存入磁盤而非內(nèi)存
（2）消費者要消費消息時才會從磁盤中讀取并加載到內(nèi)存
（3）支持?jǐn)?shù)百萬條的消息存儲
而要設(shè)置一個隊列為惰性隊列，只需要在聲明隊列時，指定x-queue-mode屬性為lazy即可。用SpringAMQP聲明惰性隊列分兩種方式：
基于注解的方式：

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "DelayQueue",durable = "true",arguments = @Argument(name = "x-dead-letter-exchange",value = "lazy")),exchange = @Exchange(name = "delay-mq-exchange_B",delayed = "true"),key = "routingKey_delay"))

基于Java代碼的方式：

	@Bean
    public Queue orderQueue(){
        return QueueBuilder.durable(RabbitMQQueue.RABBIT_MQ_QUEUE_A.getQueue()).lazy().build();
    }

到此這篇關(guān)于java實現(xiàn)Rabbitmq延遲隊列和惰性隊列的文章就介紹到這了,更多相關(guān)java Rabbitmq延遲隊列和惰性隊列內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！ 

最新評論