您的位置:首页 > 科技 > 能源 > RabbitMQ实践——临时队列

RabbitMQ实践——临时队列

2024/11/19 6:52:48 来源:https://blog.csdn.net/breaksoftware/article/details/139735790  浏览:    关键词:RabbitMQ实践——临时队列

临时队列是一种自动删除队列。当这个队列被创建后,如果没有消费者监听,则会一直存在,还可以不断向其发布消息。但是一旦的消费者开始监听,然后断开监听后,它就会被自动删除。

新建自动删除队列

我们创建一个名字叫queue.auto.delete的临时队列
在这里插入图片描述

绑定

我们直接使用默认交换器,所以不用创建新的交换器,也不用建立绑定关系。

实验

发布消息

我们在后台管理页面的默认交换器下向这个队列发布2条消息
在这里插入图片描述

监听队列

这次我们需要使用代码来订阅队列

package com.rabbitmq.basic.service;import java.util.Map;
import java.util.concurrent.locks.ReentrantLock;import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import jakarta.annotation.PostConstruct;@Service
public class ConsumerService {@Autowiredprivate RabbitTemplate rabbitTemplate;private ConnectionFactory connectionFactory;private final ReentrantLock lock = new ReentrantLock();private Map<String, SimpleMessageListenerContainer> listeners = new java.util.HashMap<>();@PostConstructpublic void init() {connectionFactory = rabbitTemplate.getConnectionFactory();}public void startListening(String queueName) {SimpleMessageListenerContainer container = getListener(queueName, new RBMQMessageListener());container.start();System.out.println("Listening to " + queueName);}public void stopListening(String queueName) {SimpleMessageListenerContainer container = getListener(queueName, null);container.stop();System.out.println("Stopped listening to " + queueName);}private SimpleMessageListenerContainer getListener(String queueName, MessageListener messageListener) {lock.lock();try {SimpleMessageListenerContainer listener = listeners.get(queueName);if (listener == null && messageListener != null) {listener = new SimpleMessageListenerContainer();listener.setConnectionFactory(connectionFactory);listener.setQueueNames(queueName);listener.setMessageListener(messageListener);listeners.put(queueName, listener);}return listener;} finally {lock.unlock();}}private class RBMQMessageListener implements MessageListener {@Overridepublic void onMessage(Message message) {System.out.println("Received message: " + new String(message.getBody()));}}}

然后在页面上开启监听
在这里插入图片描述

可以看到终端上输出了之前发布的消息
在这里插入图片描述
然后我们继续在后台发布3条消息,可以看到新的消息也被接收到。
在这里插入图片描述
然后我们关闭监听
在这里插入图片描述

队列queue.auto.delete就被删除掉了。

代码工程

https://github.com/f304646673/RabbitMQDemo

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com