欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot中RabbitMQ死信隊列的實現(xiàn)示例

 更新時間：2024年01月23日 10:06:30   作者：Java小生不才  
死信隊列是一種特殊的消息隊列,用來存儲無法被正常消費的消息,常被用來實現(xiàn)延遲處理,異常消息處理等,本文主要介紹了springboot中RabbitMQ死信隊列的實現(xiàn)示例,感興趣的可以了解一下

1. 死信隊列

死信隊列是一種特殊的消息隊列,用來存儲無法被正常消費的消息，常被用來實現(xiàn)延遲處理，異常消息處理等，提高了系統(tǒng)的可伸縮性和容錯性，能夠應(yīng)對高并發(fā)和異常消息。
死信隊列中的消息被稱為死信消息,用來分發(fā)死信消息的交換機被稱為死信交換機(Dead Letter Exchange,DLX)。
死信隊列在實際項目中的應(yīng)用場景有很多如:

  • 訂單超時未支付，將此消息放入死信隊列中，等待后續(xù)處理(延遲等待)
  • 消息消費失敗將消息放入死信隊列中進行重試(消息重試機制)

在這里插入圖片描述

2.正常消息成為死信消息的條件

  • 消息到了過期時間仍然未被消費者消費
  • 隊列已滿無法保存新消息
  • 消息被拒絕消費且未設(shè)置重新放入隊列

在這里插入圖片描述

3.消費者1

package com.hong.rabbitmq9;

import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;

import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;

/**
 * @Description: 死信隊列消費者1
 * @Author: hong
 * @Date: 2024-01-17 21:04
 * @Version: 1.0
 **/
public class Consumer1 {
    //正常交換機名稱
    public static final String NORMAL_EXCHANGE = "normal_exchange";
    //死信交換機名稱
    public static final String DEAD_EXCHANGE = "dead_exchange";
    //正常隊列名稱
    public static final String NORMAL_QUEUE = "normal_queue";
    //死信隊列名稱
    public static final String DEAD_QUEUE = "dead_queue";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtil.getChannel();
        channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);
        channel.exchangeDeclare(DEAD_EXCHANGE, BuiltinExchangeType.DIRECT);

        channel.queueDeclare(DEAD_QUEUE,false,false,false,null);
        channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");

        //正常隊列綁定死信隊列信息
        Map<String,Object> map = new HashMap<>();
        map.put("x-dead-letter-exchange",DEAD_EXCHANGE);
        map.put("x-dead-letter-routing-key", "lisi");
        //聲明正常隊列
        channel.queueDeclare(NORMAL_QUEUE,false,false,false,map);
        channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");

        System.out.println("Consumer1等待接收消息:");
        DeliverCallback deliverCallback = (comsumerTag, message) -> {
            System.out.println( "routingKey:" + message.getEnvelope().getRoutingKey() + ",消息:" + new String(message.getBody(), StandardCharsets.UTF_8));
        };

        CancelCallback cancelCallback = var -> {
        };

        channel.basicConsume(NORMAL_QUEUE,true,deliverCallback,cancelCallback);

    }
}

在這里插入圖片描述

在這里插入圖片描述

在這里插入圖片描述

4.生產(chǎn)者

package com.hong.rabbitmq9;

import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;

/**
 * @Description: 死信隊列消息生產(chǎn)者
 * @Author: hong
 * @Date: 2024-01-17 20:49
 * @Version: 1.0
 **/
public class Producer {
    public static final String NORMAL_EXCHANGE = "normal_exchange";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtil.getChannel();

        channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);

        //設(shè)置消息的 TTL 時間 10s
        AMQP.BasicProperties properties = new AMQP.BasicProperties()
                .builder().expiration("10000").build();

        //該信息是用作演示隊列個數(shù)限制
        for (int i = 1; i < 11; i++) {
            String message = "info" + i;
            channel.basicPublish(NORMAL_EXCHANGE, "zhangsan", properties, message.getBytes());
            System.out.println("生產(chǎn)者發(fā)送消息:" + message);
        }
    }

}

啟動消費者1后馬上關(guān)閉消費者1,模擬消費者1接收不到消息,再啟動生產(chǎn)者

在這里插入圖片描述

在這里插入圖片描述

生產(chǎn)者發(fā)送10條正常隊列中有10條消息

在這里插入圖片描述

10s后正常隊列中的消息由于沒有消費者消費進入死信隊列中

在這里插入圖片描述

5.消費者2

package com.hong.rabbitmq9;

import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;

import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;

/**
 * @Description: 死信隊列-死信消費者
 * @Author: hong
 * @Date: 2024-01-17 21:31
 * @Version: 1.0
 **/
public class Consumer2 {
    public static final String DEAD_EXCHANGE = "dead_exchange";
    public static final String DEAD_QUEUE = "dead_queue";
    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtil.getChannel();

        channel.exchangeDeclare(DEAD_EXCHANGE, BuiltinExchangeType.DIRECT);

        channel.queueDeclare(DEAD_QUEUE,false,false,false,null);
        channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");


        System.out.println("Consumer2等待接收死信消息:");
        DeliverCallback deliverCallback = (comsumerTag, message) -> {
            System.out.println( "routingKey:" + message.getEnvelope().getRoutingKey() + ",消息:" + new String(message.getBody(), StandardCharsets.UTF_8));
        };

        CancelCallback cancelCallback = var -> {
        };

        channel.basicConsume(DEAD_QUEUE,true,deliverCallback,cancelCallback);
    }
}

啟動消費者2,使其消費死信隊列中的消息

在這里插入圖片描述

6.隊列達到最大長度

以上代碼是TTL,隊列達到最大長度只要將上述代碼稍微改動一下即可

6.1.注釋掉生產(chǎn)者代碼中的ttl部分

package com.hong.rabbitmq9;

import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;

/**
 * @Description: 死信隊列消息生產(chǎn)者
 * @Author: hong
 * @Date: 2024-01-17 20:49
 * @Version: 1.0
 **/
public class Producer {
    public static final String NORMAL_EXCHANGE = "normal_exchange";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtil.getChannel();

        channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);

        //設(shè)置消息的 TTL 時間 10s
//        AMQP.BasicProperties properties = new AMQP.BasicProperties()
//                .builder().expiration("10000").build();

        //該信息是用作演示隊列個數(shù)限制
        for (int i = 1; i < 11; i++) {
            String message = "info" + i;
            channel.basicPublish(NORMAL_EXCHANGE, "zhangsan", null, message.getBytes());
            System.out.println("生產(chǎn)者發(fā)送消息:" + message);
        }
    }
}

6.2.消費者1代碼中加最大長度

package com.hong.rabbitmq9;

import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;

import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;

/**
 * @Description: 死信隊列消費者1
 * @Author: hong
 * @Date: 2024-01-17 21:04
 * @Version: 1.0
 **/
public class Consumer1 {
    //正常交換機名稱
    public static final String NORMAL_EXCHANGE = "normal_exchange";
    //死信交換機名稱
    public static final String DEAD_EXCHANGE = "dead_exchange";
    //正常隊列名稱
    public static final String NORMAL_QUEUE = "normal_queue";
    //死信隊列名稱
    public static final String DEAD_QUEUE = "dead_queue";

    public static void main(String[] args) throws Exception {
        Channel channel = RabbitMQUtil.getChannel();
        channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);
        channel.exchangeDeclare(DEAD_EXCHANGE, BuiltinExchangeType.DIRECT);

        channel.queueDeclare(DEAD_QUEUE,false,false,false,null);
        channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");

        //正常隊列綁定死信隊列信息
        Map<String,Object> map = new HashMap<>();
        map.put("x-dead-letter-exchange",DEAD_EXCHANGE);
        map.put("x-dead-letter-routing-key", "lisi");
        map.put("x-max-length",8);
        //聲明正常隊列
        channel.queueDeclare(NORMAL_QUEUE,false,false,false,map);
        channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");

        System.out.println("Consumer1等待接收消息:");
        DeliverCallback deliverCallback = (comsumerTag, message) -> {
            System.out.println( "routingKey:" + message.getEnvelope().getRoutingKey() + ",消息:" + new String(message.getBody(), StandardCharsets.UTF_8));
        };

        CancelCallback cancelCallback = var -> {
        };

        channel.basicConsume(NORMAL_QUEUE,true,deliverCallback,cancelCallback);

    }
}

啟動消費者1后立馬關(guān)閉，模擬隊列已滿

在這里插入圖片描述

在這里插入圖片描述

在這里插入圖片描述

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

相關(guān)文章

  • Java面試必考的關(guān)鍵字的用法匯總

    Java面試必考的關(guān)鍵字的用法匯總

    這篇文章主要為大家詳細介紹了Java中的幾種關(guān)鍵字相關(guān)知識，本文比較適合剛?cè)肟覬ava的小白以及準備秋招的大佬閱讀，需要的小伙伴快收藏起來吧
    2023-06-06
  • Spring Cloud基于zuul實現(xiàn)網(wǎng)關(guān)過程解析

    Spring Cloud基于zuul實現(xiàn)網(wǎng)關(guān)過程解析

    這篇文章主要介紹了Spring Cloud基于zuul實現(xiàn)網(wǎng)關(guān)過程解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-12-12
  • SpringBoot 使用 @Value 注解讀取配置文件給靜態(tài)變量賦值

    SpringBoot 使用 @Value 注解讀取配置文件給靜態(tài)變量賦值

    這篇文章主要介紹了SpringBoot 使用 @Value 注解讀取配置文件給靜態(tài)變量賦值，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-11-11
  • 如何對Mysql數(shù)據(jù)表查詢出來的結(jié)果進行排序

    如何對Mysql數(shù)據(jù)表查詢出來的結(jié)果進行排序

    這篇文章主要介紹了如何對Mysql數(shù)據(jù)表查詢出來的結(jié)果進行排序問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-08-08
  • 20個非常實用的Java程序代碼片段

    20個非常實用的Java程序代碼片段

    這篇文章主要為大家分享了20個非常實用的Java程序片段，對java開發(fā)項目有所幫助，感興趣的小伙伴們可以參考一下
    2016-02-02
  • REST架構(gòu)及RESTful應(yīng)用程序簡介

    REST架構(gòu)及RESTful應(yīng)用程序簡介

    這篇文章主要為大家介紹了REST架構(gòu)及RESTful的應(yīng)用程序簡介，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2022-03-03
  • java 代理機制的實例詳解

    java 代理機制的實例詳解

    這篇文章主要介紹了java 代理機制的實例詳解的相關(guān)資料,這里說明下如何實現(xiàn)代理機制，幫助大家理解掌握這部分內(nèi)容，需要的朋友可以參考下
    2017-08-08
  • Java實現(xiàn)文本編譯器

    Java實現(xiàn)文本編譯器

    這篇文章主要為大家詳細介紹了Java實現(xiàn)文本編譯器，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-04-04
  • 詳解Java String類常用方法有哪些

    詳解Java String類常用方法有哪些

    今天給大家?guī)淼氖顷P(guān)于Java String的相關(guān)知識,文章圍繞著String類常用方法展開,文中有非常詳細的介紹及代碼示例,需要的朋友可以參考下
    2021-06-06
  • 快速解決List集合add元素,添加多個對象出現(xiàn)重復(fù)的問題

    快速解決List集合add元素,添加多個對象出現(xiàn)重復(fù)的問題

    這篇文章主要介紹了快速解決List集合add元素,添加多個對象出現(xiàn)重復(fù)的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-08-08

最新評論