谁都饶恕比谁都不饶恕同样残忍。——塞涅卡
分享一个动态创建rabbitmq队列的代码：
依赖：
代码语言：javascript复制<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>配置：
代码语言：javascript复制spring:
rabbitmq:
host: localhost
port: 5672
username: xxx
password: xxx代码：
代码语言：javascript复制import com.alibaba.nacos.common.utils.JacksonUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
@Slf4j
public class RabbitMQUtil {
private static final AmqpAdmin amqpAdmin = SpringContextHolder.getBean(AmqpAdmin.class);
private static final ConnectionFactory connectionFactory = SpringContextHolder.getBean(ConnectionFactory.class);
private static final RabbitTemplate rabbitTemplate = SpringContextHolder.getBean(RabbitTemplate.class);
public static void createQueue(String queueName) {
Queue queue = new Queue(queueName, true);
amqpAdmin.declareQueue(queue);
}
public static void deleteQueue(String queueName) {
amqpAdmin.deleteQueue(queueName);
}
public static void subscribeQueue(String queueName, Object messageListener, String methodName) {
log.debug("subscribeQueue: {}", queueName);
// 创建一个消息监听适配器
MessageListenerAdapter listenerAdapter = new MessageListenerAdapter(messageListener, methodName);
// 创建 SimpleMessageListenerContainer
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames(queueName);
container.setMessageListener(listenerAdapter);
// 启动容器
container.start();
}
public static void sendMessage(String queueName, Object message) {
String json = JacksonUtils.toJson(message);
log.debug("sendMessage, queueName: {} , message: {}", queueName, json);
rabbitTemplate.convertAndSend(queueName, json);
}
}使用起来很简单：
创建队列：
代码语言：javascript复制RabbitMQUtil.createQueue("test");订阅队列：
代码语言：javascript复制 @Getter
public static class MyMessageListener implements MQMessageListener {
@Override
public void handleMessage(String message) {
System.out.println("Received message: " message);
}
}
MyMessageListener listener = new MyMessageListener();
RabbitMQUtil.subscribeQueue("test", listener, "handleMessage");然后是删除队列：
代码语言：javascript复制RabbitMQUtil.deleteQueue("test")
