Fanoutexchange switch code tutorial

The source code is at the end of the article

1. stay consumer Service statement Exchange、Queue、Binding

@Configuration
public class FanoutConfig {

    @Bean
    public FanoutExchange fanoutExchange(){
        //  Statement FanoutExchange Switch 
        return new FanoutExchange(" Statement FanoutExchange Switch ");
    }

    // Declare the first queue 
    @Bean
    public Queue fanoutQueue1(){
        return new Queue("fanout.queue1");
    }

    // Bind queue 1  And switches  ( The name and type should be consistent ,  It will be injected according to this )
    @Bean
    public Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange){
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }

    // Declare a second queue 
    @Bean
    public Queue fanoutQueue2(){
        return new Queue("fanout.queue2");
    }

    // Bind queue 2  And switches 
    @Bean
    public Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }
}

2. stay consumer Service statement two consumers

    @RabbitListener(queues = "fanout.queue1")
    public void listenFanoutQueue1(String msg){
        System.out.println(" Consumers receive fanout.queue1 The news of ：【" + msg + "】");
    }

    @RabbitListener(queues = "fanout.queue2")
    public void listenFanoutQueue2(String msg){
        System.out.println(" Consumers receive fanout.queue2 The news of ：【" + msg + "】");
    }

3. Finally, start sending message test

    @Test
    public void testSendFanoutExchange() {
        //  Switch name 
        String exchangeName = " Statement FanoutExchange Switch ";
        //  news 
        String message = " test  FanoutExchange  Switch ,  Please accept  !";
        rabbitTemplate.convertAndSend(exchangeName, "", message);
    }

Finally, the running result is

  Source project address :

link : https://pan.baidu.com/s/1vnYVEPGO8B5XLCf9Xc67cA Extraction code : few9