RabbitMQ队列详细属性（重要）

RabbitMQ队列详细属性

  • 1、队列的属性介绍
    • 1.1、Type：队列类型
    • 1.2、Name：队列名称
    • 1.3、Durability：声明队列是否持久化
    • 1.4、Auto delete： 是否自动删除
    • 1.5、Exclusive：
    • 1.6、Arguments：队列的其他属性，例如指定DLX（死信交换机等）；
  • 2、队列的属性代码验证
    • 2.1、Auto delete
      • 2.1.1、RabbitConfig配置类（关键代码）
      • 2.1.2、发送消息
      • 2.1.3、接收消息
      • 2.1.4、启动类
      • 2.1.5、配置文件application.yml
      • 2.1.6、配置文件pom.xml
      • 2.1.7、测试
    • 2.2、Arguments参数属性之x-overflow和x-max-length
      • 2.2.1、RabbitConfig配置类
      • 2.2.2、其他代码同上
      • 2.2.3、测试
    • 2.3、Arguments参数属性之x-single-active-consumer
      • 2.3.1、消费者
      • 2.3.2、RabbitConfig配置类
      • 2.3.3、测试
    • 2.4、Arguments参数属性之x-max-length-bytes
    • 2.5、Arguments参数属性之x-max-priority
      • 2.5.1、设置优先级
      • 2.5.2、测试

1、队列的属性介绍

在这里插入图片描述

1.1、Type：队列类型

在这里插入图片描述

1.2、Name：队列名称

就是一个字符串，随便一个字符串就可以；

1.3、Durability：声明队列是否持久化

声明队列是否持久化，代表队列在服务器重启后是否还存在，默认值为true;

1.4、Auto delete： 是否自动删除

如果为true，当没有消费者连接到这个队列的时候，队列会自动删除；默认为false

1.5、Exclusive：

exclusive属性的队列只对首次声明它的连接可见，并且在连接断开时自动删除；
基本上不设置它，设置成false

1.6、Arguments：队列的其他属性，例如指定DLX（死信交换机等）；

1、x-expires：Number
当Queue（队列）在指定的时间未被访问，则队列将被自动删除；
在指定时间内，队列未被使用（没有被消费者访问），就会自动删除该队列。
在这里插入图片描述

2、x-message-ttl：Number
发布的消息在队列中存在多长时间后被取消（单位毫秒）；
消息发送到队列中后，在指定时间后会过期。
在这里插入图片描述

3、x-overflow：String
设置队列溢出行为，当达到队列的最大长度时，消息会发生什么，有效值为Drop Head或Reject Publish；
默认值是Drop Head，即如果队列满了，会从头部开始删除消息，继续接收新的消息
Reject Publish拒绝发布，如果队列满了，就不再接收新的消息了。

在这里插入图片描述

4、x-max-length：Number
队列所能容下消息的最大长度，当超出长度后，新消息将会覆盖最前面的消息，类似于Redis的LRU算法；

在这里插入图片描述

5、 x-single-active-consumer：默认为false
激活单一的消费者，也就是该队列只能有一个消息者消费消息；
如果设置该值为true,那么只能设置一个消费者接收消息。

在这里插入图片描述

6、x-max-length-bytes：Number
限定队列的最大占用空间，当超出后也使用类似于Redis的LRU算法；

在这里插入图片描述

7、x-dead-letter-exchange：String
指定队列关联的死信交换机，有时候我们希望当队列的消息达到上限后溢出的消息不会被删除掉，而是走到另一个队列中保存起来；

8.x-dead-letter-routing-key：String
指定死信交换机的路由键，一般和6一起定义；

9.x-max-priority：Number
如果将一个队列加上优先级参数，那么该队列为优先级队列；
（1）给队列加上优先级参数使其成为优先级队列
x-max-priority=10【0-255取值范围】
（2）给消息加上优先级属性
通过优先级特性，将一个队列实现插队消费；
MessageProperties messageProperties=new MessageProperties();
messageProperties.setPriority(8);

10、x-queue-mode：String（理解下即可）
队列类型x-queue-mode=lazy懒队列，在磁盘上尽可能多地保留消息以减少RAM使用，如果未设置，则队列将保留内存缓存以尽可能快地传递消息；

在这里插入图片描述

11、x-queue-master-locator：String（用的较少）
在集群模式下设置队列分配到的主节点位置信息；
每个queue都有一个master节点，所有对于queue的操作都是事先在master上完成，之后再slave上进行相同的操作；
每个不同的queue可以坐落在不同的集群节点上，这些queue如果配置了镜像队列，那么会有1个master和多个slave。
基本上所有的操作都落在master上，那么如果这些queues的master都落在个别的服务节点上，而其他的节点又很空闲，这样就无法做到负载均衡，那么势必会影响性能；
关于master queue host 的分配有几种策略，可以在queue声明的时候使用x-queue-master-locator参数，或者在policy上设置queue-master-locator，或者直接在rabbitmq的配置文件中定义queue_master_locator，有三种可供选择的策略：
（1）min-masters：选择master queue数最少的那个服务节点host；
（2）client-local：选择与client相连接的那个服务节点host；
（3）random：随机分配；

2、队列的属性代码验证

2.1、Auto delete

在这里插入图片描述

2.1.1、RabbitConfig配置类（关键代码）

在这里插入图片描述

package com.power.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Value("${my.exchangeName}")
    private String exchangeName;

    @Value("${my.queueName}")
    private String queueName;

    //创建交换机
    @Bean
    public DirectExchange directExchange(){
        return ExchangeBuilder
                .directExchange(exchangeName)
                .build();
    }

    //创建队列
    @Bean
    public Queue queue(){
        return QueueBuilder
                .durable(queueName)
                .autoDelete()
                .build();
    }

    @Bean
    public Binding binding(DirectExchange exchangeName,Queue queueName){
        return BindingBuilder.bind(queueName).to(exchangeName).with("info");
    }
}

2.1.2、发送消息

package com.power.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;

@Service
@Slf4j
public class MessageService {

    @Resource
    private RabbitTemplate rabbitTemplate;

    @Value("${my.exchangeName}")
    private String exchangeName;

    @Bean
    public void sendMsg(){
        Message message = MessageBuilder.withBody("hello world".getBytes()).build();
        rabbitTemplate.convertAndSend(exchangeName,"info",message);
        log.info("消息发送完毕，发送时间是："+new Date());
    }
}

2.1.3、接收消息

package com.power.message;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class ReceiveMessage {

    private static final String queueName="queue.queueProperties.01";

    @RabbitListener(queues={queueName})
    public void receiveMsg(Message message){
        log.info("接收到队列的消息：{}",new String(message.getBody()));
    }
}

2.1.4、启动类

package com.power;

import com.power.service.MessageService;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import javax.annotation.Resource;

@SpringBootApplication
public class Application implements ApplicationRunner {

    @Resource
    private MessageService messageService;

    public static void main(String[] args) {
        SpringApplication.run(Application.class);
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {
        messageService.sendMsg();
    }
}

2.1.5、配置文件application.yml

server:
  port: 8080
spring:
  application:
    name: rabbit_11_quque_properties01_autoDelete

  rabbitmq:
    host: 你的服务器IP
    port: 5672
    username: 你的账号
    password: 你的密码
    virtual-host: power

my:
  exchangeName: exchange.queueProperties.01
  queueName: queue.queueProperties.01

2.1.6、配置文件pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.power</groupId>
  <artifactId>rabbit_11_quque_properties01_autoDelete</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>rabbit_11_quque_properties01_autoDelete</name>

  <properties>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.6.13</version>
    <relativePath/>
  </parent>

  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <version>1.18.24</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

</project>

2.1.7、测试

启动服务：消息发送成功，接收消息成功
在这里插入图片描述登录rabbitmq后台，查看到有一个队列

在这里插入图片描述
此时我们停止服务，即断掉消费者和队列的联系，队列会自动删除。

在这里插入图片描述

2.2、Arguments参数属性之x-overflow和x-max-length

2.2.1、RabbitConfig配置类

在这里插入图片描述

package com.power.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class RabbitConfig {

    @Value("${my.exchangeName}")
    private String exchangeName;

    @Value("${my.queueName}")
    private String queueName;

    //创建交换机
    @Bean
    public DirectExchange directExchange(){
        return ExchangeBuilder.directExchange(exchangeName).build();
    }

    //创建队列
    @Bean
    public Queue queue(){
        Map<String,Object> arguments = new HashMap<>();
        arguments.put("x-overflow","reject-publish");//队列的溢出行为，默认是删除头部，此处设置未拒绝发布（当队列满了之后，不再接收消息）
        arguments.put("x-max-length",5);//队列的最大长度
        return new Queue(queueName,true,false,false,arguments);
    }

    @Bean
    public Binding binding(DirectExchange directExchange,Queue queue){
        return BindingBuilder.bind(queue).to(directExchange).with("info");
    }
}

2.2.2、其他代码同上

2.2.3、测试

启动服务，登录rabbitmq后台。
我们发现当设置为arguments.put(“x-overflow”,“reject-publish”);和arguments.put(“x-max-length”,5);时，我们发现队列里只存放了5条消息。后边的678三条消息并没有进入队列。
在这里插入图片描述

2.3、Arguments参数属性之x-single-active-consumer

2.3.1、消费者

我们设置多个消费者，接收生产者发送的消息

package com.power.message;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Date;

@Component
@Slf4j
public class ReceiveMessage {

    @RabbitListener(queues={"queue.properties.03"})
    public void receiveMsg1(Message message){
        byte[] body = message.getBody();
        String msg = new String(body);
        log.info("1监听到的消息是："+msg+",接收的时间是："+new Date());
    }

    @RabbitListener(queues={"queue.properties.03"})
    public void receiveMsg2(Message message){
        byte[] body = message.getBody();
        String msg = new String(body);
        log.info("2监听到的消息是："+msg+",接收的时间是："+new Date());
    }

    @RabbitListener(queues={"queue.properties.03"})
    public void receiveMsg3(Message message){
        byte[] body = message.getBody();
        String msg = new String(body);
        log.info("3监听到的消息是："+msg+",接收的时间是："+new Date());
    }

}

2.3.2、RabbitConfig配置类

package com.power.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class RabbitConfig {

    @Value("${my.exchangeName}")
    private String exchangeName;

    @Value("${my.queueName}")
    private String queueName;

    //创建交换机
    @Bean
    public DirectExchange directExchange(){
        return ExchangeBuilder.directExchange(exchangeName).build();
    }

    //创建队列
    @Bean
    public Queue queue(){
        Map<String,Object> arguments = new HashMap<>();
        return new Queue(queueName,true,false,false,arguments);
    }

    @Bean
    public Binding binding(DirectExchange directExchange,Queue queue){
        return BindingBuilder.bind(queue).to(directExchange).with("info");
    }
}

2.3.3、测试

启动服务，我们发现，当不设置该参数时，3个消费者都可以接收到消息

当设置了该参数时：只有一个消费者可以接收到消息
在这里插入图片描述

在这里插入图片描述

2.4、Arguments参数属性之x-max-length-bytes

如下图所示，修改RabbitConfig类，设置队列的x-max-length-bytes属性值为100

在这里插入图片描述

尝试发送100条消息
在这里插入图片描述
启动服务，登录rabbitmq后台：
可以看到队列中只有7条消息
在这里插入图片描述

2.5、Arguments参数属性之x-max-priority

2.5.1、设置优先级

给队列设置优先级
在这里插入图片描述
给队列中的消息设置优先级
在这里插入图片描述

2.5.2、测试

启动服务，登录rabbitmq后台

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/916281.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

通过Python 调整Excel行高、列宽

通过Python 调整Excel行高、列宽

在Excel中&#xff0c;默认的行高和列宽可能不足以完全显示某些单元格中的内容&#xff0c;特别是当内容较长时。通过调整行高和列宽&#xff0c;可以确保所有数据都能完整显示&#xff0c;避免内容被截断。合理的行高和列宽可以使表格看起来更加整洁和专业&#xff0c;尤其是在…
阅读更多...
Qt学习笔记（四）多线程

Qt学习笔记（四）多线程

系列文章目录 Qt开发笔记&#xff08;一&#xff09;Qt的基础知识及环境编译&#xff08;泰山派&#xff09; Qt学习笔记&#xff08;二&#xff09;Qt 信号与槽 Qt学习笔记&#xff08;三&#xff09;网络编程 Qt学习笔记&#xff08;四&#xff09;多线程 文章目录 系列文章…
阅读更多...
用 Python 从零开始创建神经网络（三）：添加层级（Adding Layers）

用 Python 从零开始创建神经网络（三）：添加层级（Adding Layers）

添加层级&#xff08;Adding Layers&#xff09; 引言1. Training Data2. Dense Layer Class 引言 我们构建的神经网络变得越来越受人尊敬&#xff0c;但目前我们只有一层。当神经网络具有两层或更多隐藏层时&#xff0c;它们变成了“深度”网络。目前我们只有一层&#xff0c…
阅读更多...
如何在jupyter notebook切换python环境

如何在jupyter notebook切换python环境

目录 参考链接 首先确保conda已经正常安装 conda --version 或者conda -V 以下请将“myenv”替换成自己的命名&#xff01;&#xff01;&#xff01; 1-查看虚拟环境目录 conda env list 2-创建虚拟环境命令 conda create -n myenv 或者 conda create --name myenv 3-激活虚拟环…
阅读更多...
C#从入门到放弃

C#从入门到放弃

C#和.NET的区别 C# C#是一个编程语言 .NET .NET是一个在window下创建程序的框架 .NET框架不仅局限于C#,它还可以支持很多语言 .NET包括了2个组件&#xff0c;一个叫CLR(通用语言运行时)&#xff0c;另一个是用来构建程序的类库 CLR 用C写一个程序&#xff0c;在一台8688的机器…
阅读更多...
STM32 低功耗模式详解

STM32 低功耗模式详解

目录 一、什么是低功耗 二、低功耗的核心思想 三、STM32的3种低功耗模式 1、睡眠模式 (Sleep Mode) 2、停止模式 (Stop Mode) 3、 待机模式 (Standby Mode) 四、相关电源管理寄存器 1、PWR_CR (Power Control Register, 电源控制寄存器) 2、PWR_CSR (Power Control/St…
阅读更多...
数位DP学习

数位DP学习

数位 DP - OI Wiki 引入 主要变量及函数 变量&#xff1a; L, R: 所求区间边界 limit&#xff1a;边界限制&#xff0c;主要在记忆化搜索里用 len&#xff1a;所求数的位数 pos&#xff1a;当前所求位置 lead&#xff1a; 前导零 DP[N][M] &#xff1a;第一维是当前的pos&…
阅读更多...
WP网站如何增加文章/页面的自定义模板

WP网站如何增加文章/页面的自定义模板

通过Wordpress我们后台在发布文章或者页面的时候其实可以看到有些主题 他有选择使用的页面模板&#xff0c;可以自定义模板&#xff0c;但是有些主题却没有选择主题这个功能&#xff0c;那这个自定义模板的功能是如何实现的呢&#xff1f;以下分两种情况&#xff1a;Page页面和…
阅读更多...
Python学习从0到1 day27 Python 高阶技巧 ③ 设计模式 — 单例模式

Python学习从0到1 day27 Python 高阶技巧 ③ 设计模式 — 单例模式

此去经年&#xff0c;再难同游 —— 24.11.11 一、什么是设计模式 设计模式是一种编程套路&#xff0c;可以极大的方便程序的开发最常见、最经典的设计模式&#xff0c;就是我们所学习的面向对象了。 除了面向对象外,在编程中也有很多既定的套路可以方便开发,我们称之为设计模…
阅读更多...
DAY112代码审计PHP开发框架POP链利用Yii反序列化POP利用链

DAY112代码审计PHP开发框架POP链利用Yii反序列化POP利用链

一、pop1链的跟踪 1、路由关系 2、漏洞触发口unserialize(base64_decode($data)); 2、__destruct()&#xff0c;魔术法方法调用close函数方法 3、未找到利用链&#xff0c;尝试__call魔术方法 4、逆推找call_user_func 函数 第一部分 namespace yii\db; class BatchQueryResu…
阅读更多...
Flink新版Source接口源码解析

Flink新版Source接口源码解析

目录 1. 前言 2. Source解析 2.1 Source类图 2.2 接口和方法说明 2.2.1 Source,> 3. SplitEnumerator解析 3.1 SplitEnumetator类图 3.2 类和方法说明 3.2.1 SplitEnumerator 3.2.2 SimpleVersionedSerializer 4. SourceReader解析 4.1 SourceReader类图 4.2 类…
阅读更多...
SpringBoot后端解决跨域问题

SpringBoot后端解决跨域问题

1.全局方式 新建一个conifg配置类&#xff0c;内容如下&#xff1a; Configuration public class CorsConfig implements WebMvcConfigurer {Overridepublic void addCorsMappings(CorsRegistry registry) {registry.addMapping("/**")//是否发送Cookie.allowCrede…
阅读更多...
qt QUndoCommand 与 QUndoStack详解

qt QUndoCommand 与 QUndoStack详解

1、概述 QUndoCommand 和 QUndoStack 是 Qt 框架中用于实现撤销/重做&#xff08;undo/redo&#xff09;功能的两个核心类。QUndoCommand 是表示单个可撤销操作的基类&#xff0c;而 QUndoStack 则负责管理这些命令的堆栈&#xff0c;提供撤销和重做操作的接口。 QUndoCommand…
阅读更多...
Struts源码阅读——三个常用的辅助类DispatchAction

Struts源码阅读——三个常用的辅助类DispatchAction

Struts源码阅读——三个常用的辅助类 紧接前文&#xff0c;我们来阅读org.apache.struts.actions包中三个常用类的源码。 DispatchAction、LookupDispatchAction 和 MappingDispatchAction 是 Struts 1 框架中的三个常用的辅助类&#xff0c;用来简化 Action 类中的请求分发。…
阅读更多...
C++中的栈（Stack）和堆（Heap）

C++中的栈（Stack）和堆（Heap）

在C中&#xff0c;堆&#xff08;heap&#xff09;和栈&#xff08;stack&#xff09;是两种用于存储数据的内存区域。理解它们的原理和区别&#xff0c;对于优化代码性能和确保代码的安全性至关重要。以下是对C中堆栈的详细解析&#xff0c;包括它们的分配方式、优缺点、应用场…
阅读更多...
群控系统服务端开发模式-应用开发-前端登录接口开发

群控系统服务端开发模式-应用开发-前端登录接口开发

一、修改验证方法 1、修改验证器 loginRules: {username: [{required: true, trigger: blur, validator: validateUsername}],password: [{required: true, trigger: blur, validator: validatePassword}],captcha_code: [{required: true, trigger: blur, validator: validat…
阅读更多...
游戏引擎学习第10天

游戏引擎学习第10天

视频参考:https://www.bilibili.com/video/BV1LyU3YpEam/ 介绍intel architecture reference manual 地址:https://www.intel.com/content/www/us/en/developer/articles/technical/intel-sdm.html RDTS&#xff08;读取时间戳计数器&#xff09;指令是 x86/x86_64 架构中的…
阅读更多...
MySQL查询某个数据库中特定表的空间占用大小

MySQL查询某个数据库中特定表的空间占用大小

如果您也想要查询某个数据库中特定表的空间占用大小&#xff0c;包括数据和索引的大小&#xff0c;那么您可以使用以下SQL查询。这个查询将显示特定表在数据库中的数据大小、索引大小以及总大小。 SELECT table_name AS Table,ROUND(((data_length index_length) / 1024 / 10…
阅读更多...
SystemVerilog学习笔记（十一）：接口

SystemVerilog学习笔记（十一）：接口

在Verilog中&#xff0c;模块之间的通信是使用模块端口指定的。 Verilog模块连接的缺点 声明必须在多个模块中重复。存在声明不匹配的风险。设计规格的更改可能需要修改多个模块。 接口 SystemVerilog引入了 interface 结构&#xff0c;它封装了模块之间的通信。一个 inter…
阅读更多...
el-input 正则表达式校验输入框不能输入汉字

el-input 正则表达式校验输入框不能输入汉字

<el-form :model"data1" :rules"rules" ref"ruleForm" label-width"210px" class"demo-ruleForm"><el-form-item label"锯路&#xff1a;" prop"sawKref"><el-input class"inptWid…
阅读更多...
最新文章

Copyright @ 2022~2023