springboot实现rabbitmq的队列初始化和绑定
更新时间:2018年10月03日 09:59:47 作者:张占岭(仓储大叔,Lind)
这篇文章主要介绍了springboot实现rabbitmq的队列初始化和绑定,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
配置文件,在rabbit中自动建立exchange,queue和绑定它们的关系
- 代码里初始化exchange
- 代码里初始化queue
- 代码里绑定exchange,queue和routekey
- 配置文件,直接声明vhost
代码里初始化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配置. */ @Configuration public 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; @Configuration public 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); } }
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。
相关文章
Spring中ApplicationContextAware的使用方法详解
ApplicationContextAware 通过它Spring容器会自动把上下文环境对象调用ApplicationContextAware接口中的setApplicationContext方法,这篇文章主要介绍了Spring中ApplicationContextAware的作用,需要的朋友可以参考下2023-03-03Java面试synchronized偏向锁后hashcode存址
这篇文章主要为大家介绍了Java面试中synchronized偏向锁后hashcode存址详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2022-05-05仿京东平台框架开发开放平台(包含需求,服务端代码,SDK代码)
现在开放平台越来越多了,下面针对仿京东开放平台框架,封装自己的开放平台,分享给大家。先感谢一下京东开放平台的技术大佬们,下面从开放平台需求,服务端代码,SDK代码三大块进行分享2021-06-06
最新评论