springboot+整合rabbitmq的全套代码

package com.powernode.config; import org.springframework.amqp.core.*; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * @program: rabbitmq * @ClassName: RabbitMQConfig * @version: 1.0 * @description: 配置类 * @author: bjpowernode **/ @Configuration public class RabbitMQConfig { //指定EXCHANGE_NAME交换机 的名称 public static final String EXCHANGE_NAME = "boot_topic_exchange"; //指定QUEUE_NAME队列 的名称 public static final String QUEUE_NAME = "boot_queue"; //指定QUEUE_NAME队列 的名称 public static final String QUEUE_NAME2 = "boot_queue2"; //1.交换机 @Bean("bootExchange") public Exchange bootExchange(){ /** * ExchangeBuilder构建交换机对象. * topicExchange(String name) -->topicExchange-指定交换机的类型--> (String name)指定交换机的名称. * directExchange(String name) * fanoutExchange(String name) * headersExchange(String name) * .durable(true) 选择true指定为持久化 * .build()为构建. */ return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build(); } //2.Queue 队列 @Bean("bootQueue") public Queue bootQueue(){ /** * QueueBuilder构建队列的对象. * durable() * durable(String name) --> ()指定队列的名称. * nonDurable() * nonDurable(String name) * .build()为构建. */ return QueueBuilder.durable(QUEUE_NAME).build(); } //2.Queue 队列 @Bean("bootQueue2") public Queue bootQueue2(){ /** * QueueBuilder构建队列的对象. * durable() * durable(String name) --> ()指定队列的名称. * nonDurable() * nonDurable(String name) * .build()为构建. */ return QueueBuilder.durable(QUEUE_NAME2).build(); } //3. 队列和交互机绑定关系 Binding /** 1. 指定队列 2. 指定交换机 3. routing key @Qualifier-->如果配置类出现多个队列,通过名称绑定参数 */ @Bean public Binding bindQueueExchange(@Qualifier("bootQueue") Queue queue, @Qualifier("bootExchange") Exchange exchange){ /** * BindingBuilder.bind(queue).to(exchange).with("boot.#").noargs(); * .bind(queue)通过什么队列 * .to(exchange)绑定什么交换机 * .with("boot.#")指定routingKey * .noargs()不需要指定参数,如果需要指定参数,调用.and() */ /* amqpAdmin.declareQueue(new Queue(QUEUE_HI, true)); amqpAdmin.declareQueue(new Queue(QUEUE_HELLO, true));*/ return BindingBuilder.bind(queue).to(exchange).with("1.txt").noargs(); } @Bean public Binding bindQueueExchange1(@Qualifier("bootQueue2") Queue queue, @Qualifier("bootExchange") Exchange exchange){ /** * BindingBuilder.bind(queue).to(exchange).with("boot.#").noargs(); * .bind(queue)通过什么队列 * .to(exchange)绑定什么交换机 * .with("boot.#")指定routingKey * .noargs()不需要指定参数,如果需要指定参数,调用.and() */ return BindingBuilder.bind(queue).to(exchange).with("1.#").noargs(); } @Bean public Binding bindQueueExchange2(@Qualifier("bootQueue2") Queue queue, @Qualifier("bootExchange") Exchange exchange){ /** * BindingBuilder.bind(queue).to(exchange).with("boot.#").noargs(); * .bind(queue)通过什么队列 * .to(exchange)绑定什么交换机 * .with("boot.#")指定routingKey * .noargs()不需要指定参数,如果需要指定参数,调用.and() */ return BindingBuilder.bind(queue).to(exchange).with("555.zzz").noargs(); } }