SpringBoot整合RabbitMQ实现交换机与队列的绑定

ExchangeBuilder.topicExchange(EXCHANGE_TOPIC_WELCOME).durable( true ).build();

new TopicExchange(EXCHANGE_TOPIC_WELCOME, true , false )

QueueBuilder.durable( "Hi" ).build();

new Queue(QUEUE_HI, true )

BindingBuilder.bind(helloQueue).to(welcomExchange).with( "hello.#" )

new Binding( "Queue@hello" , Binding.DestinationType.QUEUE,

                 "Exchange@topic.welcome" , "hello.#" , null )

package com.example.config;

import org.springframework.amqp.core.*;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class RabbitMQRouterConfig {

     public static final String QUEUE_HELLO              = "Queue@hello" ;

     public static final String QUEUE_HI                 = "Queue@hi" ;

     public static final String EXCHANGE_TOPIC_WELCOME   = "Exchange@topic.welcome" ;

     public static final String ROUTINGKEY_HELLOS        = "hello.#" ;

     @Autowired

     private AmqpAdmin amqpAdmin;

     @Bean

     public Object initBindingTest() {

         amqpAdmin.declareExchange( new TopicExchange(EXCHANGE_TOPIC_WELCOME, true , false ));

         amqpAdmin.declareQueue( new Queue(QUEUE_HI, true ));

         amqpAdmin.declareQueue( new Queue(QUEUE_HELLO, true ));

         amqpAdmin.declareBinding( new Binding(QUEUE_HELLO, Binding.DestinationType.QUEUE,

                 EXCHANGE_TOPIC_WELCOME, ROUTINGKEY_HELLOS, null ));

         return new Object();

     }

}

Map<String, Object> params = new HashMap();

params.put( "x-message-ttl" , 2000 );

amqpAdmin.declareBinding( new Binding(QUEUE_HELLO, Binding.DestinationType.QUEUE,

                 EXCHANGE_TOPIC_WELCOME, ROUTINGKEY_HELLOS, params));

package com.lly.order.message;

import org.springframework.amqp.core.*;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class RabbitMQConfig {

     public final static String QUEUE_DIRECT     = "Queue@direct" ;

     public final static String QUEUE_TOPIC_ONE  = "Queue@topic_one" ;

     public final static String TOPIC_QUEUE_TWO  = "Queue@topic_two" ;

     public final static String QUEUE_FANOUT_ONE = "Queue@fanout_one" ;

     public final static String QUEUE_FANOUT_TWO = "Queue@fanout_two" ;

     public final static String EXCHANGE_TOPIC   = "Exchange@topic" ;

     public final static String EXCHANGE_FANOUT  = "Exchange@fanout" ;

     public final static String ROUTINGKEY_TOPIC_ONE = "hello.key" ;

     public final static String ROUTINGKEY_TOPIC_TWO = "*.key" ;

     //  direct模式队列

     @Bean

     public Queue directQueue() {

         return new Queue(QUEUE_DIRECT, true );

     }

     //  topic 订阅者模式队列

     @Bean

     public Queue topicQueueOne() {

         return new Queue(QUEUE_TOPIC_ONE, true );

     }

     @Bean

     public Queue topicQueueTwo() {

         return new Queue(TOPIC_QUEUE_TWO, true );

     }

     //  fanout 广播者模式队列

     @Bean

     public Queue fanoutQueueOne() {

         return new Queue(QUEUE_FANOUT_ONE, true );

     }

     @Bean

     public Queue fanoutQueueTwo() {

         return new Queue(QUEUE_FANOUT_TWO, true );

     }

     //  topic 交换器

     @Bean

     public TopicExchange topExchange() {

         return new TopicExchange(EXCHANGE_TOPIC);

     }

     //  fanout 交换器

     @Bean

     public FanoutExchange fanoutExchange() {

         return new FanoutExchange(EXCHANGE_FANOUT);

     }

     //   订阅者模式绑定

     @Bean

     public Binding topicExchangeBingingOne() {

         return BindingBuilder.bind(topicQueueOne()).to(topExchange()).with(ROUTINGKEY_TOPIC_ONE);

     }

     @Bean

     public Binding topicExchangeBingingTwo() {

         return BindingBuilder.bind(topicQueueTwo()).to(topicExchange()).with(ROUTINGKEY_TOPIC_TWO);

     }

     //   广播模式绑定

     @Bean

     public Binding fanoutExchangeBingingOne() {

         return BindingBuilder.bind(fanoutQueueOne()).to(fanoutExchange());

     }

     @Bean

     public Binding fanoutExchangeBingingTwo() {

         return BindingBuilder.bind(fanoutQueueTwo()).to(fanoutExchange());

     }

}

@Component

public class Receiver {

     @RabbitListener (queues = "hello" )

     public void process(String hello) {

         System.out.println ( "Receiver : "   + hello);

     }

     @RabbitListener (bindings = @QueueBinding (

             exchange = @Exchange (value = "Exchange@topic.Hello" ,durable = "true" ,type = "topic" ),

             value    = @Queue (value = "Queue@Hello" ,durable = "true" ),

             key      = "key.#"

     ))

     public void processMessage1(Message message) {

         System.out.println(message);

     }

}