程序员波特的个人博客

一个小而美的程序员编程资料站

0%

实操8-3、交换机和队列持久化

一、测试非持久化交换机和队列

1、创建非持久化交换机

image-20231106192621173

创建之后，可以在列表中看到：

image-20231106192708597

2、创建非持久化队列

image-20231106195216265

创建之后，可以在列表中看到：

image-20231106195132627

3、绑定

image-20231106195748319

4、发送消息

1
2
3
4
5
6
7
8
9
10
public static final String EXCHANGE_TRANSIENT = "exchange.transient.user";
public static final String ROUTING_KEY_TRANSIENT = "user";

@Test
public void testSendMessageTransient() {
    rabbitTemplate.convertAndSend(
            EXCHANGE_TRANSIENT,
            ROUTING_KEY_TRANSIENT,
            "Hello atguigu user~~~");
}

5、查看已发送消息

image-20231106200245531

结论：临时性的交换机和队列也能够接收消息，但如果RabbitMQ服务器重启之后会怎么样呢？

6、重启RabbitMQ服务器

1
docker restart rabbitmq

重启之后，刚才临时性的交换机和队列都没了。在交换机和队列这二者中，队列是消息存储的容器，队列没了，消息就也跟着没了。

二、持久化的交换机和队列

我们其实不必专门创建持久化的交换机和队列，因为它们默认就是持久化的。接下来我们只需要确认一下：存放到队列中，尚未被消费端取走的消息，是否会随着RabbitMQ服务器重启而丢失？

1、发送消息

运行以前的发送消息方法即可，不过要关掉消费端程序

2、在管理界面查看消息

image-20231106200934265

3、重启RabbitMQ服务器

1
docker restart rabbitmq

4、再次查看消息

仍然还在：

image-20231106201123268

三、结论

在后台管理界面创建交换机和队列时，默认就是持久化的模式。

此时消息也是持久化的，不需要额外设置。