rabbitmq 交换机和队列持久化

发布时间:
更新时间:
🕒 阅读时间:2 min read 👀 阅读量:Loading...

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

1、创建非持久化交换机

image-20231106192621173

创建之后,可以在列表中看到:

image-20231106192708597

2、创建非持久化队列

image-20231106195216265

创建之后,可以在列表中看到:

image-20231106195132627

3、绑定

image-20231106195748319

4、发送消息

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服务器

Terminal window
docker restart rabbitmq

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

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

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

1、发送消息

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

2、在管理界面查看消息

image-20231106200934265

3、重启RabbitMQ服务器

Terminal window
docker restart rabbitmq

4、再次查看消息

仍然还在:

image-20231106201123268

三、结论

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

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

rabbitmq 交换机和队列持久化

作者: Mindspark

本文链接: https://oxai.net.cn/posts/2c1df1ef

本文采用 知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议 进行许可。

留言评论

2000年1月1日星期六
00:00:00