配置文件，在rabbit中自動建立exchange,queue和綁定它們的關系
代碼里初始化exchange
/** * rabbitMq里初始化exchange. * * @return */ @Bean public TopicExchange crmExchange() { return new TopicExchange(EXCHANGE); }代碼里初始化queue
/** * rabbitMq里初始化隊列crm.hello. * * @return */ @Bean public Queue helloQueue() { return new Queue(HELLO); }代碼里綁定exchange,queue和routekey
/** * 綁定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); }}以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。
新聞熱點
疑難解答
圖片精選
