/**  * rabbitMq里初始化exchange.  *  * @return  */ @Bean public TopicExchange crmExchange() {  return new TopicExchange(EXCHANGE); }

/**  * rabbitMq里初始化隊列crm.hello.  *  * @return  */ @Bean public Queue helloQueue() {  return new Queue(HELLO); }

/**  * 綁定exchange & queue & routekey.  *  * @param queueMessage 隊列  * @param exchange   交換機  * @param routekey   路由  * @return  */ public Binding bindingExchange(Queue queueMessage, TopicExchange exchange, String routekey) {  return BindingBuilder.bind(queueMessage).to(exchange).with(routekey); }

spring:  rabbitmq:  host: localhost  port: 5672  username: guest  password: guest  virtual-host: lind

package com.lind.microservice.productCenter.mq;import org.springframework.amqp.core.Binding;import org.springframework.amqp.core.BindingBuilder;import org.springframework.amqp.core.Queue;import org.springframework.amqp.core.TopicExchange;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;/** * amqp配置. */@Configurationpublic class AmqpConfig { /**  * 交換機.  */ public final static String EXCHANGE = "crm"; /**  * hello隊列.  */ public final static String HELLO = "crm.hello"; /**  * 建立訂單隊列.  */ public final static String LIND_GENERATE_ORDER = "crm.generate.order"; /**  * 綁定exchange & queue & routekey.  *  * @param queueMessage 隊列  * @param exchange   交換機  * @param routekey   路由  * @return  */ public Binding bindingExchange(Queue queueMessage, TopicExchange exchange, String routekey) {  return BindingBuilder.bind(queueMessage).to(exchange).with(routekey); } /**  * rabbitMq里初始化exchange.  *  * @return  */ @Bean public TopicExchange crmExchange() {  return new TopicExchange(EXCHANGE); } /**  * rabbitMq里初始化隊列crm.hello.  *  * @return  */ @Bean public Queue helloQueue() {  return new Queue(HELLO); } /**  * rabbitMq里初始化隊列crm.generate.order.  *  * @return  */ @Bean public Queue orderQueue() {  return new Queue(LIND_GENERATE_ORDER); }}

package com.lind.microservice.productCenter.mq;import java.util.Date;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Configuration;@Configurationpublic class HelloPublisher { @Autowired AmqpTemplate rabbitTemplate; @Autowired AmqpConfig amqpConfig; public void hello() {  String context = "hello " + new Date();  System.out.println("HelloPublisher : " + context);  amqpConfig.bindingExchange(    amqpConfig.helloQueue(),    amqpConfig.crmExchange(),    "crm.hello.#"  );  this.rabbitTemplate.convertAndSend(AmqpConfig.EXCHANGE, AmqpConfig.HELLO, context); }}

package com.lind.microservice.productCenter.mq;import org.springframework.amqp.rabbit.annotation.RabbitHandler;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;@Component@RabbitListener(queues = AmqpConfig.HELLO)public class HelloSubscriber { @RabbitHandler public void process(String hello) {  System.out.println("HelloSubscriber : " + hello); }}