我正在尝试使用 RabbitMQ 在春季创建发布者和消费者应用程序。一切工作正常,当发布者发送消息时,消费者接收并成功消费它。但正如您在下图中看到的,RabbitMQ 界面没有向我显示创建的队列和交换。
无需排队
无交换
这是我写的代码:
RABBITMQ 配置(发布者应用程序和消费者应用程序中相同)
package com.example.rabbitmq.springrabbitmqconsumer.configuration;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQConfig {
public static final String ROUTING_A = "routing.A";
public static final String ROUTING_B = "routing.B";
//QUEUES
@Bean
Queue queueA() {
return new Queue("queue.A", false);
}
@Bean
Queue queueB() {
return new Queue("queue.B", false);
}
//Direct Exchange
@Bean
DirectExchange exchange() {
return new DirectExchange("exchange.direct");
}
//BINDINGS …Run Code Online (Sandbox Code Playgroud)