spring boot 는 RabbitMQ 를 사용 하여 topic 테 마 를 실현 합 니 다.

package com.zb.rabbitMQtest.t5topics.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author   
 */
@Configuration(value = "t5Config")
public class Config {

  /**
   *    ：  
   *   ：2018/3/5   10:45
   * @apiNote        
   */
  @Bean
  public TopicExchange topicExchange() {
    return new TopicExchange("topic-exchange");
  }

  /**
   *    ：  
   *   ：2018/3/5   10:48
   * @apiNote           
   */
  @Bean
  public Queue autoDeleteQueue0() {
    return new AnonymousQueue();
  }

  /**
   *    ：  
   *   ：2018/3/5   10:48
   * @apiNote           
   */
  @Bean
  public Queue autoDeleteQueue1() {
    return new AnonymousQueue();
  }

  /**
   *    ：  
   *   ：2018/3/5   10:48
   * @param topicExchange      
   * @param autoDeleteQueue0       
   * @apiNote          orange   autoDeleteQueue0          
   * @return Binding
   */
  @Bean
  public Binding binding0a(TopicExchange topicExchange, Queue autoDeleteQueue0) {
    return BindingBuilder.bind(autoDeleteQueue0).to(topicExchange).with("*.orange.*");
  }

  /**
   *    ：  
   *   ：2018/3/5   10:48
   * @param topicExchange      
   * @param autoDeleteQueue1       
   * @apiNote          black   autoDeleteQueue1          
   * @return Binding
   */
  @Bean
  public Binding binding1a(TopicExchange topicExchange, Queue autoDeleteQueue1) {
    return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("*.*.rabbit");
  }

  /**
   *    ：  
   *   ：2018/3/5   10:48
   * @param topicExchange      
   * @param autoDeleteQueue1       
   * @apiNote          green   autoDeleteQueue1          
   * @return Binding
   */
  @Bean
  public Binding binding1b(TopicExchange topicExchange, Queue autoDeleteQueue1) {
    return BindingBuilder.bind(autoDeleteQueue1).to(topicExchange).with("lazy.#");
  }
}

package com.zb.rabbitMQtest.t5topics.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author   
 */
@Component(value = "t5Receiver")
public class Receiver {

  @RabbitListener(queues = "#{autoDeleteQueue0.name}")
  public void receiver0(String str) {
    System.out.println("receiver0++++++++++:" + str);
    //try {
    //  Thread.sleep(1000);
    //} catch (InterruptedException e) {
    //  e.printStackTrace();
    //}
  }

  @RabbitListener(queues = "#{autoDeleteQueue1.name}")
  public void receiver1(String str) {
    System.out.println("receiver1++++++++++:" + str);
    //try {
    //  Thread.sleep(1000);
    //} catch (InterruptedException e) {
    //  e.printStackTrace();
    //}
  }
}

package com.zb.rabbitMQtest.t5topics.send;

import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author   
 */
@Component(value = "t5Send")
public class Send {

  @Autowired
  private TopicExchange topicExchange;

  @Autowired
  private RabbitTemplate rabbitTemplate;

  private String[] keys = {"quick.orange.rabbit",
      "lazy.orange.elephant", "quick.orange.fox",
      "lazy.brown.fox", "lazy.pink.rabbit", "quick.brown.fox"};

  public void send() {
    String message = "   ";
    for (int i = 0; i < 5; i++) {
      System.out.println("send++++++++++:".concat(message));
      rabbitTemplate.convertAndSend(topicExchange.getName(), keys[5], message);
    }
  }
}

package com.zb.rabbitMQtest.t5topics.send;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * @author   
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class SendTest {

  @Autowired
  private Send send;
  @Test
  public void send() throws Exception {
    send.send();
  }
}