02.RabbitMQ整合springboot简单使用

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

1.添加依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>

2. 配置yml文件

spring: rabbitmq: host: ip port: 5672 password: ***** username: ***** virtual-host: /dev_virtual

3.引入springboot中的注解和类

启动类增加 @EnableRabbit注解
引入rabbitmq管理类

@Autowired private RabbitTemplate rabbitTemplate;//用于消息处理 @Autowired private RabbitAdmin rabbitAdmin; //用于管理组件

4.测试DIRECT模式消息队列

代码创建exchange和queue

@Test public void buildRabbit(){ //交换机 Exchange exchange = new ExchangeBuilder("exchange_direct", ExchangeTypes.DIRECT).durable(true).build(); rabbitAdmin.declareExchange(exchange); //队列 Queue queue = QueueBuilder.durable("queue_lpf").build(); rabbitAdmin.declareQueue(queue); //绑定 Binding binding = BindingBuilder.bind(queue).to(exchange).with("mq_key").noargs(); rabbitAdmin.declareBinding(binding); String beanName = rabbitAdmin.getBeanName(); System.out.println("buildRabbit"+beanName); }

provider发送消息

@Test public void sendRabbitInfo() { CorrelationData data = new CorrelationData(UUID.randomUUID().toString().replace("-", "")); Book book = new Book("红楼梦","曹雪芹"); rabbitTemplate.convertAndSend("exchange_direct", "mq_key", sendMessage,data); }

consumer接收发送的消息

@RabbitListener(queues="queue_lpf") public void getMessage(Map message){ System.out.println("********************************************************"); System.out.println(message); System.out.println("********************************************************"); }

5.测试TOPIC模式发送数据

代码创建EXCHANGE 和 QUEUE

@Test public void buildTopicRabbit(){ Exchange topicExchange = new ExchangeBuilder("topic_exchange", ExchangeTypes.TOPIC).durable(true).build(); rabbitAdmin.declareExchange(topicExchange); Queue queue1 = QueueBuilder.durable("queue_topic").build(); rabbitAdmin.declareQueue(queue1); Queue queue2 = QueueBuilder.durable("queue_lpf").build(); rabbitAdmin.declareQueue(queue2); Queue queue3 = QueueBuilder.durable("topic_lpf").build(); rabbitAdmin.declareQueue(queue3); //队列和交换器绑定 Binding binding = BindingBuilder.bind(queue1).to(topicExchange).with("#.topic").noargs(); Binding binding1 = BindingBuilder.bind(queue2).to(topicExchange).with("queue.#").noargs(); Binding binding2 = BindingBuilder.bind(queue3).to(topicExchange).with("#.lpf").noargs(); rabbitAdmin.declareBinding(binding); rabbitAdmin.declareBinding(binding1); rabbitAdmin.declareBinding(binding2); }

privider 发送消息

@Test public void sendMsg(){ CorrelationData data = new CorrelationData(UUID.randomUUID().toString().replace("-", "")); String message="this is a topic message(queue.lpf is the routingkey)"; rabbitTemplate.convertAndSend("topic_exchange","queue.lpf", (Object) message,data); }