SpringBoot快速整合RabbitMq小案例(使用步骤)
对于一个直接创建的springBoot项目工程来说,可以按照以下步骤使用rabbitmq
- 添加依赖:添加rabbitMQ的依赖。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>
- 配置连接:在配置文件中配置虚拟主机、端口号、用户名、密码等信息。
spring: rabbitmq: host: localhost port: 5672 virtual-host: {你的虚拟主机} username: {你的用户名} password: {你的密码}
- 创建生产者:导入对应依赖后,使用rabbitTemplate,并调用convertAndSend来发送消息。
@Autowired private RabbitTemplate rabbitTemplate; public void sendMessage(String message) { rabbitTemplate.convertAndSend("exchangeName", "routingKey", message); }
来发送消息。
- 创建消费者:使用
@RabbitListener
注解在消息处理方法上,指定监听的队列名称,并在方法参数中接收消息。
@RabbitListener(queues = "queueName") public void receiveMessage(String message) { // 处理接收到的消息 System.out.println("Received message: " + message); }
- 编写配置类,使用@Bean注解在对应的方法上把方法的返回值(将队列,交换机等信息)交由spring管理。
// 交换机名称 public static final String ITEM_TOPIC_EXCHANGE = "item_topic_exchange"; // 队列名称 public static final String ITEM_QUEUE = "item_queue"; //声明交换机 @Bean public Exchange exchange(){ return ExchangeBuilder.topicExchange(ITEM_TOPIC_EXCHANGE).durable(true).build(); } //声明队列 @Bean public Queue queue(){ return QueueBuilder.durable(ITEM_QUEUE).build(); } //队列绑定到交换机 @Bean public Binding binding(Queue queue,Exchange exchange){ return BindingBuilder.bind(queue).to(exchange).with("item.#").noargs(); }
- 启动应用程序或者写测试类。
@Autowired RabbitTemplate rabbitTemplate; @Test public void testSendMessage(){ rabbitTemplate.convertAndSend(RabbitmqConfig.ITEM_TOPIC_EXCHANGE, "item.insert", "新增商品的消息~~"); System.out.println("消息发送成功"); }
到此这篇关于SpringBoot快速整合RabbitMq小案例的文章就介绍到这了,更多相关SpringBoot整合RabbitMq内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
idea快捷键生成getter和setter,有构造参数,无构造参数,重写toString方式
这篇文章主要介绍了java之idea快捷键生成getter和setter,有构造参数,无构造参数,重写toString方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-11-11SpringBoot注册FilterRegistrationBean相关情况讲解
这篇文章主要介绍了SpringBoot注册FilterRegistrationBean相关情况,借助FilterRegistrationBean来注册filter,可以避免在web.xml种配置filter这种原始的写法2023-02-02MyBatis批量插入数据到Oracle数据库中的两种方式(实例代码)
本文通过实例代码给大家分享了MyBatis批量插入数据到Oracle数据库中的两种方式,非常不错,具有参考借鉴价值,需要的朋友参考下吧2017-09-09Springcloud+Mybatis使用多数据源的四种方式(小结)
这篇文章主要介绍了Springcloud+Mybatis使用多数据源的四种方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2020-09-09Mockito 结合 Springboot 进行应用测试的方法详解
这篇文章主要介绍了Mockito 结合 Springboot 进行应用测试的方法详解,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-11-11SpringCloud Gateway 利用 Mysql 实现动态路由的方法
这篇文章主要介绍了SpringCloud Gateway 利用 Mysql 实现动态路由的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2021-02-02
最新评论