【RabbitMQ】RabbitMQ配置与交换机学习

article/2025/8/11 23:18:14

文章目录

    • 简介
    • 安装和部署
        • 1. 安装RabbitMQ
        • 2.创建virtual-host
        • 3. 添加依赖
        • 4.修改配置文件
    • WorkQueues模型
        • 1.编写消息发送测试类
        • 2.编写消息接收（监听）类
        • 3. 实现能者多劳
    • 交换机
      • Fanout交换机
        • 1.消息发送
        • 2.消息监听
      • Direct交换机
        • 1.消息发送
        • 2.消息接收
      • Topic交换机
        • 1.消息发送
        • 2.消息接收
    • 声明队列和交换机
        • 声明队列
        • 声明交换机
        • 绑定队列和交换机
          • 1.fanout示例
          • 2. direct示例
          • 3.基于注解的方式声明队列和交换机
        • 消息转换器
    • 总结

简介

RabbitMQ是一个开源的消息代理软件，它实现了高级消息队列协议（AMQP）。RabbitMQ支持多种消息传递协议，具有高可靠性、高可用性和高性能等特点。它允许应用程序通过消息队列进行异步通信，从而实现解耦和负载均衡。RabbitMQ的核心概念包括交换机（Exchange）、队列（Queue）和绑定（Binding），它们共同构成了消息的路由和传递机制。

RabbitMQ的架构如图：

47ab6076-c1b1-45e1-b8c4-f6c41a601b21

其中包含几个概念：

  • publisher：生产者，也就是发送消息的一方
  • consumer：消费者，也就是消费消息的一方
  • queue：队列，存储消息。生产者投递的消息会暂存在消息队列中，等待消费者处理
  • exchange：交换机，负责消息路由。生产者发送的消息由交换机决定投递到哪个队列。
  • virtual host：虚拟主机，起到数据隔离的作用。每个虚拟主机相互独立，有各自的exchange、queue

安装和部署

这里以Centos7为例：

1. 安装RabbitMQ
docker run \-e RABBITMQ_DEFAULT_USER=shijun \-e RABBITMQ_DEFAULT_PASS=123321 \-v mq-plugins:/plugins \--name mq \--hostname mq \-p 15672:15672 \-p 5672:5672 \--network hm-net\-d \rabbitmq:3.8-management

  1. -e RABBITMQ_DEFAULT_USER=shijun

    -e参数用于设置环境变量。这行代码用来设置RabbitMQ的默认用户名为shijun。

  2. -e RABBITMQ_DEFAULT_PASS=123321

    这行代码用来设置默认密码为123321。

  3. -p 15672:15672

    这行代码用来将宿主机的15672端口映射到容器的15672端口，15672端口是RabbitMQ管理控制台的默认端口。

  4. -p 5672:5672

    这行代码用来将宿主机的5672端口映射到容器的5672端口，5672端口是RabbitMQ的默认通信端口。

  5. --network hm-net

    这行代码将容器连接到名为hm-net的网络。

  6. -d

    -d参数表示以后台模式运行容器。

  7. rabbitmq:3.8-management

    这里是我们要运行的rabbitmq的Docker镜像，这里选择的是RabbitMQ 3.8版本，版本需要根据自己的SpringCloud版本来选择。

安装完成后访问：http://虚拟机IP地址:15672

输入刚才的账号密码：shijun 123321，就能进入控制台界面。

image-20240608222043550

2.创建virtual-host

由于RabbitMQ 每秒并发能力为几万，一般项目都不会达到这个规模，因此我们可以让多个项目使用同一个RabbitMQ 。要实现项目直接的隔离需要创建virtual-host，每个项目对应一个virtual-host。

按顺序点击，填入“Name”和“Descrption”，然后点击“Add virtual host”按钮：

image-20240609151722019

然后在右上角切换到创建的virtual-host：

image-20240609152323104

3. 添加依赖
        <dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!--AMQP依赖，包含RabbitMQ--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><!--单元测试--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId></dependency>
4.修改配置文件
logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 192.168.56.101 # 你的虚拟机IPport: 5672 # 端口virtual-host: /mq-demo # 虚拟主机username: shijun # 用户名password: 123321 # 密码

WorkQueues模型

Work queues，任务模型。简单来说就是让多个消费者绑定到一个队列，共同消费队列中的消息。

当消息处理比较耗时的时候，可能生产消息的速度会远远大于消息的消费速度。长此以往，消息就会堆积越来越多，无法及时处理。

此时就可以使用work 模型，多个消费者共同处理消息处理，消息处理的速度就能大大提高了。

image-20240609154853698

在控制台创建一个work.queue队列：

image-20240609155329959

1.编写消息发送测试类
import static org.junit.jupiter.api.Assertions.*;
@SpringBootTest
class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testpublic void testWorkQueue() throws InterruptedException {// 队列名称String queueName = "work.queue";// 消息String message = "hello, message_";for (int i = 0; i < 50; i++) {// 发送消息，每20毫秒发送一次，相当于每秒发送50条消息rabbitTemplate.convertAndSend(queueName, message + i);Thread.sleep(20);}}
}
  • RabbitTemplate：Spring AMQP提供的模板类，用于发送和接收消息。
  • rabbitTemplate.convertAndSend(queueName, message + i);：使用RabbitTemplate发送消息到指定的队列。
2.编写消息接收（监听）类
@Component
public class SpringRabbitListener {/*** 监听名为"work.queue"的RabbitMQ队列，接收并处理来自队列的消息。* 通过延迟执行模拟消息处理时间* * @param msg 从队列中接收到的消息内容，以字符串形式提供* @throws InterruptedException 如果线程在睡眠期间被中断，则抛出此异常*/@RabbitListener(queues = "work.queue")public void listenWorkQueue1(String msg) throws InterruptedException {// 输出接收到消息的时间，以便跟踪消息处理的时间点System.out.println("消费者1接收到消息：【" + msg + "】" + LocalTime.now());// 模拟消息处理时间，让线程睡眠20毫秒Thread.sleep(20);}@RabbitListener(queues = "work.queue")public void listenWorkQueue2(String msg) throws InterruptedException {System.err.println("消费者2........接收到消息：【" + msg + "】" + LocalTime.now());Thread.sleep(200);}
}
  • @RabbitListener：此注解用来设置该方法应该作为RabbitMQ消息队列的监听器。这意味着当队列中有消息发布时，Spring框架会自动调用此方法来处理这些消息。
  • queues = "work.queue"：指定要监听的RabbitMQ队列的名称，在这个例子中是work.queue。
  • 注意到这两消费者，都设置了Thead.sleep，模拟任务耗时：
    • 消费者1 sleep了20毫秒，相当于每秒钟处理50个消息
    • 消费者2 sleep了200毫秒，相当于每秒处理5个消息

运行后查看结果：

image-20240609163135799

观察可以发现：

  1. 一个消息只会被一个消费者处理
  2. 当有很多消息时，会平均分配（一个消费者负责奇数的消息，一个消费者负责偶数的消息）

但问题是消费者之间的消费能力可能不一样，有的消费能力强，有消费的弱，会出现部分消费者一直空闲而其他消费者一直繁忙的状况，没有充分利用每一个消费者的能力

3. 实现能者多劳

修改配置文件：

spring:rabbitmq:listener:simple:prefetch: 1 # 每次只能获取一条消息，处理完成才能获取下一个消息

再次运行，查看结果：

image-20240609164615309

观察可以发现：

消费者2处理了大概5条消息，而消费者1处理了40多条消息，成功实现"能者多劳"。

交换机

在之前的RabbitMQ的架构图中我们可以看到，里面还有一项Exchange没有提到，那就是RabbitMQ中的交换机。

交换机是RabbitMQ中用于接收生产者发送的消息并将这些消息路由到一个或多个队列的组件。

Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

交换机有不同的类型，常见的有以下几种：

  • Fanout Exchange（扇出交换机）：将消息广播到所有绑定的队列，不考虑路由键。
  • Direct Exchange（直连交换机）：根据消息的路由键精确匹配队列。
  • Topic Exchange（主题交换机）：根据路由键的模式匹配队列。
  • Headers Exchange（头交换机）：根据消息的头部信息匹配队列。

Fanout交换机

扇出交换机将消息广播到所有绑定的队列，而不考虑路由键。这种交换机非常适合需要将消息广播到多个消费者的场景。

假如说当订单服务有了一笔新订单之后就要去通知短信服务、商品服务等等，有了交换机之后就只需要将消息发给交换机，然后为每一个微服务创建一个队列并绑定，之后当有消息时，交换机就会把消息发送到所有队列，就能实现一个消息被多个消费者处理了。

image-20240610112130389

  • 可以有多个队列
  • 每个队列都要绑定到Exchange（交换机）
  • 生产者发送的消息，只能发送到交换机
  • 交换机把消息发送给绑定过的所有队列
  • 订阅队列的消费者都能拿到消息

  1. 创建Fanout交换机

    image-20240609170548383

  2. 创建两个队列fanout.queue1、fanout.queue2：

    image-20240609170655932

  3. 点击刚刚创建的交换机，进入：

    image-20240609170907536

  4. 将刚才创建的两个队列绑定到交换机，

image-20240609171002978
1.消息发送

在SpringAmqpTest类中添加测试方法：

@Test
public void testFanoutExchange() {// 交换机名称String exchangeName = "demo.fanout";// 消息String message = "hello, everyone!";rabbitTemplate.convertAndSend(exchangeName, "", message);
}

abbitTemplate.convertAndSend(exchangeName, "", message);中的第二个参数用来指定路由键。对于Fanout交换机，路由键没有实际意义，因此可以传递一个空字符串。

2.消息监听

在SpringRabbitListener中添加两个方法：

@RabbitListener(queues = "fanout.queue1")
public void listenFanoutQueue1(String msg) {System.out.println("消费者1接收到Fanout消息：【" + msg + "】");
}@RabbitListener(queues = "fanout.queue2")
public void listenFanoutQueue2(String msg) {System.out.println("消费者2接收到Fanout消息：【" + msg + "】");
}

运行代码，查看结果：

image-20240609173012677

交换机的作用是什么？

  • 接收publisher发送的消息
  • 将消息按照规则路由到与之绑定的队列
  • 不能缓存消息，路由失败，消息丢失
  • FanoutExchange的会将消息路由到每个绑定的队列

Direct交换机

在Fanout模式中，一条消息，会被所有订阅的队列都消费。但是，在某些场景下，我们希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。

直连交换机根据消息的路由键精确匹配队列。只有当消息的路由键与绑定的路由键完全匹配时，消息才会被路由到相应的队列。

image-20240610112328443

在Direct模型下：

  • 队列与交换机的绑定，不能是任意绑定了，而是要指定一个RoutingKey（路由key）
  • 消息的发送方在 向 Exchange发送消息时，也必须指定消息的 RoutingKey。
  • Exchange不再把消息交给每一个绑定的队列，而是根据消息的Routing Key进行判断，只有队列的Routingkey与消息的 Routing key完全一致，才会接收到消息

  1. 创建direct.queue1和direct.queue2两个队列，之后创建一个direct类型的交换机：

    image-20240609174620595

  2. 绑定队列到交换机，最终结果如图所示：

    image-20240609184743239

1.消息发送

在SpringAmqpTest类中添加测试方法：

@Test
public void testSendDirectExchange1() {// 交换机名称String exchangeName = "demo.direct";// 消息String message = "红色警报！日本乱排核废水，导致海洋生物变异，惊现哥斯拉！";// 发送消息rabbitTemplate.convertAndSend(exchangeName, "red", message);
}@Test
public void testSendDirectExchange2() {// 交换机名称String exchangeName = "demo.direct";// 消息String message = "最新报道，哥斯拉是居民自治巨型气球，虚惊一场！";// 发送消息rabbitTemplate.convertAndSend(exchangeName, "blue", message);
}
2.消息接收

在SpringRabbitListener中添加方法：

@RabbitListener(queues = "direct.queue1")
public void listenDirectQueue1(String msg) {System.out.println("消费者1接收到direct.queue1的消息：【" + msg + "】");
}@RabbitListener(queues = "direct.queue2")
public void listenDirectQueue2(String msg) {System.out.println("消费者2接收到direct.queue2的消息：【" + msg + "】");
}

运行测试类中的testSendDirectExchange1，查看结果：

image-20240609185400537

运行测试类中的testSendDirectExchange2，查看结果：

image-20240609185710182

观察可以发现：

  • 当发送的消息的Routing key为red时，两个消息队列都能收到

  • 当发送的消息的Routing key为red时，只有消息队列1才能收到

Topic交换机

Topic交换机（Topic Exchange）是RabbitMQ中一种功能强大的交换机类型，它通过路由键的模式匹配将消息路由到一个或多个队列。Topic交换机允许使用通配符来匹配路由键，从而实现灵活的消息路由。

  • 通配符

    ：在绑定键中，可以使用两个特殊字符来实现模式匹配：

    • *：匹配一个单词。
    • #：匹配零个或多个单词。
image-20240610112445760

如图所示，假如此时publisher发送的消息使用的RoutingKey共有四种：

  • china.news代表有中国的新闻消息；
  • china.weather 代表中国的天气消息；
  • japan.news 则代表日本新闻
  • japan.weather 代表日本的天气消息；

解释：

  • topic.queue1：绑定的是china.# ，凡是以 china.开头的routing key 都会被匹配到，包括：
    • china.news
    • china.weather
  • topic.queue2：绑定的是#.news ，凡是以 .news结尾的 routing key 都会被匹配。包括:
    • china.news
    • japan.news

更多范例：

假设我们有以下绑定键：

  • *.orange.*
  • *.*.rabbit
  • lazy.#

我们可以通过以下路由键进行消息路由：

  • 路由键quick.orange.rabbit将匹配第一个和第二个绑定键。
  • 路由键lazy.orange.elephant将匹配第一个和第三个绑定键。
  • 路由键lazy.brown.fox将匹配第三个绑定键。
  • 路由键lazy将匹配第三个绑定键。

按照之前的流程创建Topic交换机和队列并进行绑定，最终结果如下：

1.消息发送

在SpringAmqpTest类中添加测试方法：

@Test
public void testSendTopicExchange1() {// 交换机名称String exchangeName = "demo.topic";// 消息String message = "喜报！孙悟空大战哥斯拉，胜!";// 发送消息rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
}@Test
public void testSendTopicExchange1() {// 交换机名称String exchangeName = "demo.topic";// 消息String message = "喜报！孙悟空大战哥斯拉，胜!";// 发送消息rabbitTemplate.convertAndSend(exchangeName, "china.weather", message);
}
2.消息接收

在SpringRabbitListener中添加方法：

@RabbitListener(queues = "topic.queue1")
public void listenTopicQueue1(String msg){System.out.println("消费者1接收到topic.queue1的消息：【" + msg + "】");
}@RabbitListener(queues = "topic.queue2")
public void listenTopicQueue2(String msg){System.out.println("消费者2接收到topic.queue2的消息：【" + msg + "】");
}

运行测试类中的testSendTopicExchange1后观察结果：

image-20240609204043494

观察发现两个消息队列都收到了，说明china.# 和#.news都匹配成功了。

运行测试类中的testSendTopicExchange2后观察结果：

image-20240609204427086

观察可以发现只有消息队列1匹配成功，说明china.#匹配成功。

声明队列和交换机

之前我们创建交换机是通过控制台创建的，然而实际开发中是不推荐使用这种方式，因为可能会出现一些问题，更推荐让程序员通过代码来判断交换机和队列是否存在，如果没有再进行创建。

在实际开发中，RabbitMQ的配置类一般放到消费者包下，生产者一般会关心消息是否发送成功。

声明队列

队列是RabbitMQ中用于存储消息的组件。Spring AMQP通过Queue类来声明队列。队列有以下几个重要属性：

  • name：队列名称。
  • durable：是否持久化。持久化队列在RabbitMQ重启后仍然存在，信息持久到磁盘。
  • exclusive：是否排他。排他队列只能被创建它的连接使用，并且在连接断开时自动删除。
  • autoDelete：是否自动删除。当最后一个消费者断开连接后，自动删除队列。

比如：

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQQueueConfig {@Beanpublic Queue myQueue() {return new Queue("simple.queue");}
}

声明了一个名为simple.queue的队列，默认为持久化、非排他、非自动删除。

image-20240610095936480
声明交换机

使用ExchangeBuilder声明交换机，ExchangeBuilder类提供了多种方法来配置交换机的属性。以下是一些常用的方法：

  • durable()：声明持久化交换机。
  • autoDelete()：声明自动删除交换机。
  • withArgument()：添加交换机的自定义参数。
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.ExchangeBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.core.HeadersExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitMQExchangeConfig {@Beanpublic DirectExchange directExchange() {return ExchangeBuilder.directExchange("direct.exchange").durable(true).build();}@Beanpublic FanoutExchange fanoutExchange() {return ExchangeBuilder.fanoutExchange("fanout.exchange").durable(true).build();}@Beanpublic TopicExchange topicExchange() {return ExchangeBuilder.topicExchange("topic.exchange").durable(true).build();}}
绑定队列和交换机

在RabbitMQ中，绑定关系（Binding）是交换机和队列之间的连接。绑定关系告诉交换机如何将消息路由到队列。在Spring AMQP中，我们可以使用BindingBuilder类来声明和配置绑定关系。

BindingBuilder类提供了一些静态方法来创建绑定关系。常用的方法包括：

  • bind()：绑定队列到交换机。
  • to()：指定交换机。
  • with()：指定路由键（用于直连交换机和主题交换机）。
  • where()：指定头部信息（用于头交换机）。
1.fanout示例
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class FanoutConfig {/*** 声明交换机* @return Fanout类型交换机*/@Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("demo.fanout");}/*** 第1个队列*/@Beanpublic Queue fanoutQueue1(){return new Queue("fanout.queue1");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}/*** 第2个队列*/@Beanpublic Queue fanoutQueue2(){return new Queue("fanout.queue2");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
}

在控制台删除demo.fanout交换机和fanout.queue2 、fanout.queue2这两个队列，再次运行代码会发现删除的又重新出现了：

image-20240610102527887
2. direct示例

direct交换机

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class DirectConfig {/*** 声明交换机* @return Direct类型交换机*/@Beanpublic DirectExchange directExchange(){return ExchangeBuilder.directExchange("direct.exchange").build();}/*** 第1个队列*/@Beanpublic Queue directQueue1(){return new Queue("direct.queue1");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue1WithRed(Queue directQueue1, DirectExchange directExchange){return BindingBuilder.bind(directQueue1).to(directExchange).with("red");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue1WithBlue(Queue directQueue1, DirectExchange directExchange){return BindingBuilder.bind(directQueue1).to(directExchange).with("blue");}/*** 第2个队列*/@Beanpublic Queue directQueue2(){return new Queue("direct.queue2");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue2WithRed(Queue directQueue2, DirectExchange directExchange){return BindingBuilder.bind(directQueue2).to(directExchange).with("red");}/*** 绑定队列和交换机*/@Beanpublic Binding bindingQueue2WithYellow(Queue directQueue2, DirectExchange directExchange){return BindingBuilder.bind(directQueue2).to(directExchange).with("yellow");}
}
3.基于注解的方式声明队列和交换机

基于@Bean的方式声明队列和交换机比较麻烦，Spring还提供了基于注解方式来声明。

修改SpringRabbitListener类：


@Component
public class SpringRabbitListener {// .......@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue1"),exchange = @Exchange(name = "demo.direct", type = ExchangeTypes.DIRECT),key = {"red", "blue"}))public void listenDirectQueue1(String msg){System.out.println("消费者1接收到direct.queue1的消息：【" + msg + "】");}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "direct.queue2"),exchange = @Exchange(name = "demo.direct", type = ExchangeTypes.DIRECT),key = {"red", "yellow"}))public void listenDirectQueue2(String msg){System.out.println("消费者2接收到direct.queue2的消息：【" + msg + "】");}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue1"),exchange = @Exchange(name = "demo.topic", type = ExchangeTypes.TOPIC),key = "china.#"))public void listenTopicQueue1(String msg){System.out.println("消费者1接收到topic.queue1的消息：【" + msg + "】");}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue2"),exchange = @Exchange(name = "demo.topic", type = ExchangeTypes.TOPIC),key = "#.news"))public void listenTopicQueue2(String msg){System.out.println("消费者2接收到topic.queue2的消息：【" + msg + "】");}// .......}

@QueueBinding注解包含以下几个主要部分：

  1. value：定义队列，使用@Queue注解。
  2. exchange：定义交换机，使用@Exchange注解。
  3. key：定义路由键，使用字符串数组。

删除交换机和队列后再次运行会发现又重新出现：

image-20240610105323455
消息转换器

Spring的消息发送代码接收的消息体是一个Object：

image-20240610105507926

在数据传输时，它会把你发送的消息序列化为字节发送给MQ，接收消息的时候，还会把字节反序列化为Java对象。

只不过，默认情况下Spring采用的序列化方式是JDK序列化。众所周知，JDK序列化存在下列问题：

  • 数据体积过大
  • 有安全漏洞
  • 可读性差

因此我们可以配置JSON转换器来解决这个问题。

  1. 引入Jackson依赖：
        <dependency><groupId>com.fasterxml.jackson.dataformat</groupId><artifactId>jackson-dataformat-xml</artifactId></dependency>

  1. 配置消息转换器

    在publisher和consumer两个服务的启动类中添加一个Bean即可：

@Bean
public MessageConverter messageConverter(){// 1.定义消息转换器Jackson2JsonMessageConverter jackson2JsonMessageConverter = new Jackson2JsonMessageConverter();// 2.配置自动创建消息id，用于识别不同消息，也可以在业务中基于ID判断是否是重复消息jackson2JsonMessageConverter.setCreateMessageIds(true);return jackson2JsonMessageConverter;
}

测试：

在FanoutConfig类中声明队列：

    @Beanpublic Queue objectQueue() {return new Queue("object.queue");}

在SpringAmqpTest类中添加：

@Test
public void testSendMap() throws InterruptedException {// 准备消息Map<String,Object> msg = new HashMap<>();msg.put("name", "柳岩");msg.put("age", 21);// 发送消息rabbitTemplate.convertAndSend("object.queue", msg);
}

在SpringRabbitListener类中添加：

@RabbitListener(queues = "object.queue")
public void listenSimpleQueueMessage(Map<String, Object> msg) throws InterruptedException {System.out.println("消费者接收到object.queue消息：【" + msg + "】");
}

运行测试类查看结果：

image-20240610110529216

总结

本文较为详细的记录了RabbitMQ的安装配置以及交换机学习，希望本文对大家学习RabbitMQ有所帮助。


http://www.hkcw.cn/article/CDRowMaywg.shtml

相关文章

详解RabbitMQ工作模式之发布订阅模式

详解RabbitMQ工作模式之发布订阅模式

目录 发布订阅模式 概念 概念介绍 特点和优势 应用场景 注意事项 代码案例 引入依赖 常量类 编写生产者代码 编写消费者1代码 运行代码 发布订阅模式 概念 RabbitMQ的发布订阅模式&#xff08;Publish/Subscribe&#xff09;是一种消息传递模式&#xff0c;它允许消…
阅读更多...
Java操作RabbitMQ

Java操作RabbitMQ

文章目录 Spring集成RabbitMQ1. AMQP&SpringAMQP2. SpringBoot集成RabbitMQ3. 模型work模型 4.交换机Fanout交换机Direct交换机Topic交换机 5.声明式队列和交换机基于API声明基于注解声明 6.消息转换器 Spring集成RabbitMQ 1. AMQP&SpringAMQP AMQP&#xff08;高级消…
阅读更多...
女龙队从佛山九江“扒”向世界 农村大妈划出国际范

女龙队从佛山九江“扒”向世界 农村大妈划出国际范

临近端午，广东多地的河道里又开始热闹起来，特别是佛山地区的龙舟活动历史悠久。九江镇被誉为全国首个龙舟名镇，赛龙舟的传统已有300年历史。九江是典型的水乡，河网密布，几乎每个村子都有河流经过，划船出行是最便捷的交通方式。在村民眼中，龙舟不仅能聚人气，还能增强村里…
阅读更多...
同济大学教授路秉杰逝世 建筑学界痛失“中国塔王”

同济大学教授路秉杰逝世 建筑学界痛失“中国塔王”

著名建筑历史学家、建筑教育家路秉杰先生因病医治无效，于2025年5月29日在上海逝世，享年90岁。他生前是中国建筑学会史学分会原副理事长，同济大学建筑与城市规划学院教授及博士生导师。路秉杰出生于1935年，山东聊城人。他在中日两国建筑史、园林史以及中国伊斯兰教建筑等领域…
阅读更多...
武汉警界科技精英万松因公牺牲 幕后英雄悄然离去

武汉警界科技精英万松因公牺牲 幕后英雄悄然离去

5月27日0时33分，湖北省武汉市公安局科技信息化支队警务技术四级主任万松因公牺牲，享年50岁。两天后的早晨，武昌殡仪馆告别大厅内庄严肃穆，花圈环绕，哀乐低回。他的遗属、生前亲友及同事百余人含泪忍悲，送别这位警界科技精英。5月26日早上7时30分，青年民警王国栋送完孩子…
阅读更多...
UniGUI DBGrid 实现多选

UniGUI DBGrid 实现多选

设置unidbgrid属性添加多选框 Options —> dgRowSelect、dgCheckSelect、dgMultiSelect —> True 属性完成后&#xff0c;保存运行&#xff0c;unidbgrid前面就会出现多选框&#xff0c;多选时质检选中前面的多选框或者 shift鼠标左键 将两次点击范围内的数据全选 或是 c…
阅读更多...
常见位运算总结

常见位运算总结

位运算 常见位运算总结位1的个数比特位计数汉明距离只出现一次的数字 常见位运算总结 位1的个数 191. 位1的个数 给定一个正整数 n&#xff0c;编写一个函数&#xff0c;获取一个正整数的二进制形式并返回其二进制表达式中 设置位 的个数&#xff08;也被称为汉明重量&#xf…
阅读更多...
离散化算法的二分法应用

离散化算法的二分法应用

我们思考一个问题&#xff1a;其实这里的二分法回归本源也是基于下标映射的原理&#xff0c;只是实现是借助二分的形式。 在排序好的数组中对目标数值进行二分搜索&#xff0c;在 O(logn) 的时间复杂度内找到该数值是整体数据中的第几个。 具体的我们可以如下操作&#xff1a; …
阅读更多...
字节流操作：InputStream类 读取文件的操作（三种 read 方法）

字节流操作：InputStream类 读取文件的操作（三种 read 方法）

字节流操作&#xff1a;InputStream类 和 OutputStream类 文章目录 字节流操作&#xff1a;InputStream类 和 OutputStream类观前提醒&#xff1a;InputStream类 读取文件的操作&#xff08;三种 read 方法&#xff09;1. 不带参数的 read( )方法&#xff0c;返回值是&#xff…
阅读更多...
day13 leetcode-hot100-22（链表1）

day13 leetcode-hot100-22（链表1）

160. 相交链表 - 力扣&#xff08;LeetCode&#xff09; 1.哈希集合HashSet 思路 &#xff08;1&#xff09;将A链的所有数据存储到HashSet中。 &#xff08;2&#xff09;遍历B链&#xff0c;找到是否在A中存在。 具体代码 /*** Definition for singly-linked list.* pu…
阅读更多...
《在人间》葛铮：以无言演绎孤独，肢体语言传递情绪

《在人间》葛铮：以无言演绎孤独，肢体语言传递情绪

如何塑造一个全剧中几乎没有台词的角色？葛铮认为关键在于认真体验角色的内心，由心而发地去感受，在镜头前自然地表现。5月28日，他出演的高概念意象情感剧《在人间》播出，他在剧中饰演铁林一角，多数镜头中只能用肢体语言、面部表情等方式传递角色的情绪，这对葛铮来说无疑是…
阅读更多...
【docker部署】 Windows版docker部署harbor镜像

【docker部署】 Windows版docker部署harbor镜像

个人简介&#xff1a;Java领域新星创作者&#xff1b;阿里云技术博主、星级博主、专家博主&#xff1b;正在Java学习的路上摸爬滚打&#xff0c;记录学习的过程~ 个人主页&#xff1a;.29.的博客 学习社区&#xff1a;进去逛一逛~ Windows版docker部署harbor镜像 Windows版dock…
阅读更多...
TopCode之手撕快排

TopCode之手撕快排

题目链接 912. 排序数组 - 力扣&#xff08;LeetCode&#xff09; 题目解析 算法原理 使用数组分三块的思想 i用来遍历整个数组 left用来标记<key的边界 right用来标记>key的边界 然后i进行遍历,数组就分成了四块 [l,left]<key [left1,i-1]key [i,right-1]未…
阅读更多...
vue2使用node版本启动差异

vue2使用node版本启动差异

node 14.21.3启动 无需添加去除ssl的环境变量&#xff0c;npm run dev即可 node 20.12.2 版本需要添加 SET NODE_OPTIONS–openssl-legacy-provider && "dev": "SET NODE_OPTIONS--openssl-legacy-provider && vue-cli-service serve"其…
阅读更多...
母亲多种工具打孩子10多次被立案 强制报告制度显效

母亲多种工具打孩子10多次被立案 强制报告制度显效

近日，司法部发布了一起未成年人法律援助典型案例。江苏省某小学老师发现学生胡某某身上有多处新旧伤痕，询问后得知胡某某因不愿意上学等问题被母亲多次殴打。老师随即按照强制报告制度要求向检察机关报告。经鉴定，胡某某挫伤面积达体表面积8%，已构成轻伤一级。随后，其母亲…
阅读更多...
多家银行5年期定存利率跌破1.3% “存5年不如存1年”现象频现

多家银行5年期定存利率跌破1.3% “存5年不如存1年”现象频现

离新一轮存款降息仅过去10天，部分中小银行存款利率开始出现剧烈调整。5月30日，多家农商行、村镇银行集体宣布下调定期存款利率。五年期整存整取利率最低降至1.20%，已低于六家国有大行、招商银行等大行1.30%的存款挂牌利率水平。“存5年不如存1年”这样的现象在中小银行中并不…
阅读更多...
塞尔维亚一军工厂突发爆炸致7人受伤 工人制作炸药时意外引爆

塞尔维亚一军工厂突发爆炸致7人受伤 工人制作炸药时意外引爆

当地时间30日早上7时40分，塞尔维亚军工企业“克鲁希克”位于瓦列沃市的工厂发生爆炸事故，导致7名工人受伤送医。伤者均为轻伤，已出院居家休养。事故发生在工人制作军用炸药过程中，压机上的引信被意外激活引发爆炸。有1名工人头部受伤，4人出现耳鸣症状。爆炸发生后厂区秩序…
阅读更多...
专家解读印度“阵风”折翼背后较量 体系战斗力的较量

专家解读印度“阵风”折翼背后较量 体系战斗力的较量

印巴冲突中，双方出动了大批战机进行猛烈交火。过去，印巴冲突多为地面战斗，而此次出现了大规模空中作战。这不仅是双方作战平台性能的直接较量，更是两国空战体系的深层碰撞。5月7日，印度武装部队发起代号为“朱砂”的行动，打击巴基斯坦和巴控克什米尔地区的设施。随后，巴…
阅读更多...
长沙有花店将艾草花束卖到98元 节日氛围推高需求

长沙有花店将艾草花束卖到98元 节日氛围推高需求

端午节除了吃粽子，中国人还有在门口挂艾草的习俗。为了了解长沙市场上艾草的供应情况和价格，记者进行了走访。主打节日氛围的艾草出现在了超市和花店，经过商家精心搭配后成为一束束艾草花束。在河西的一家盒马超市内，摆放着多款艾草花束，价格从19.9元到39.9元不等。盒马相…
阅读更多...
买到演唱会铁窗视角票被退款 视野不良引争议

买到演唱会铁窗视角票被退款 视野不良引争议

近日，网友小鱼在京观看某明星演唱会时遭遇了视野被遮挡的问题。她表示，自己花费1960元购买了两张票，但到达现场后发现看台边缘的护栏遮住了大半个舞台，导致视线受阻。小鱼立即向工作人员反映情况并要求换座，但被告知没有空位。随后，小鱼录下了座位视角的视频，并找到多名…
阅读更多...
推荐文章

Copyright @ 2022~2023