SpringBoot整合RabbitMQ图文过程以及RabbitTemplate常用API介绍

简介: SpringBoot整合RabbitMQ图文过程以及RabbitTemplate常用API介绍

🌟项目创建


1.进入网址springboot项目创建

2.创建项目,选择相关信息,注意JDK选择8版本。这里依赖添加RabbitMQ和Spring Web。图中漏了Spring Web。

f796aca17fa55164820a3bee420b6341_bf787608f0ff44628bb0d2402cdc54ee.png

3.生成压缩包并解压,使用IDEA打开。


🌟POM文件


如果是在原有项目上整合,引入以下依赖即可。


<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.amqp</groupId>
  <artifactId>spring-rabbit-test</artifactId>
  <scope>test</scope>
</dependency>


🌟配置文件修改


#整合rabbitmq
spring.rabbitmq.host=192.168.124.23
spring.rabbitmq.port=5672
spring.rabbitmq.virtual-host= /dev
spring.rabbitmq.username=admin
spring.rabbitmq.password=password


🌟测试是否整合成功


测试用例编写,发送消息。


@Autowired
  RabbitTemplate rabbitTemplate;
  @Test
  void contextLoads() {
  rabbitTemplate.convertAndSend("生产消息");
  }


通过登录web管控台,可以看出有消息的发送和消费过程。rabbitmq消息默认是自动确认的。

09dedc7e2c6340cd27b529c9b93fd459_a8facdb190264401a8137d7dce6ca702.png


🌟RabbitTemplate常用API


  1. 发送消息:
  1. convertAndSend(String exchange, String routingKey, Object message):将消息发送到指定的交换机和路由键。
  2. convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor):在发送消息之前对消息进行后处理。
  3. convertAndSend(String exchange, String routingKey, Object message, CorrelationData correlationData):将消息发送到指定的交换机和路由键,并关联一个 correlationData。
  4. send(String exchange, String routingKey, Message message):发送原始的 AMQP 消息对象。
  1. 接收消息:
  1. receive(String queueName):从指定队列接收消息,并在没有消息时立即返回 null。
  2. receiveAndConvert(String queueName):从指定队列接收消息,并将消息转换为指定类型的对象。
  3. basicConsume(String queue, ChannelAwareMessageListener listener):基于底层的 Channel 消费队列中的消息,并使用指定的监听器处理接收到的消息。
  1. 手动确认:
  1. basicAck(long deliveryTag, boolean multiple):手动确认消息的接收。将 deliveryTag 对应的消息标记为已确认。如果 multiple 为 true,则确认所有小于等于 deliveryTag 的消息。
  2. basicNack(long deliveryTag, boolean multiple, boolean requeue):手动否认消息的接收。将 deliveryTag 对应的消息标记为未确认,可以选择是否将消息重新放回队列。
  3. basicReject(long deliveryTag, boolean requeue):手动拒绝消息的接收。将 deliveryTag 对应的消息标记为未确认,并选择是否将消息重新放回队列。
  1. 消息可靠机制:
  1. setCorrelationKey(Message message, byte[] correlationKey):设置消息的关联键(correlation key)。
  2. setReturnCallback(ReturnCallback returnCallback):设置消息发送失败时的回调函数。
  3. setConfirmCallback(ConfirmCallback confirmCallback):设置消息发送确认的回调函数。


🌟写在最后


有关于SpringBoot整合RabbitMQ图文过程以及RabbitTemplate常用API介绍到此就结束了。感谢大家的阅读,希望大家在评论区对此部分内容散发讨论,便于学到更多的知识。


相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
3月前
|
人工智能 Java 机器人
基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
Spring AI Alibaba集成Ollama,基于Java构建本地大模型应用,支持流式对话、knife4j接口可视化,实现高隐私、免API密钥的离线AI服务。
1969 1
基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
|
3月前
|
消息中间件 Ubuntu Java
SpringBoot整合MQTT实战:基于EMQX实现双向设备通信
本教程指导在Ubuntu上部署EMQX 5.9.0并集成Spring Boot实现MQTT双向通信,涵盖服务器搭建、客户端配置及生产实践,助您快速构建企业级物联网消息系统。
1190 1
|
3月前
|
消息中间件 Java Kafka
消息队列比较:Spring 微服务中的 Kafka 与 RabbitMQ
本文深入解析了 Kafka 和 RabbitMQ 两大主流消息队列在 Spring 微服务中的应用与对比。内容涵盖消息队列的基本原理、Kafka 与 RabbitMQ 的核心概念、各自优势及典型用例,并结合 Spring 生态的集成方式,帮助开发者根据实际需求选择合适的消息中间件,提升系统解耦、可扩展性与可靠性。
222 1
消息队列比较:Spring 微服务中的 Kafka 与 RabbitMQ
|
3月前
|
消息中间件 存储 Java
RabbitMQ 和 Spring Cloud Stream 实现异步通信
本文介绍了在微服务架构中,如何利用 RabbitMQ 作为消息代理,并结合 Spring Cloud Stream 实现高效的异步通信。内容涵盖异步通信的优势、RabbitMQ 的核心概念与特性、Spring Cloud Stream 的功能及其与 RabbitMQ 的集成方式。通过这种组合,开发者可以构建出具备高可用性、可扩展性和弹性的分布式系统,满足现代应用对快速响应和可靠消息传递的需求。
198 2
RabbitMQ 和 Spring Cloud Stream 实现异步通信
|
6月前
|
Java API 网络架构
基于 Spring Boot 框架开发 REST API 接口实践指南
本文详解基于Spring Boot 3.x构建REST API的完整开发流程,涵盖环境搭建、领域建模、响应式编程、安全控制、容器化部署及性能优化等关键环节,助力开发者打造高效稳定的后端服务。
818 1
|
7月前
|
消息中间件 缓存 NoSQL
基于Spring Data Redis与RabbitMQ实现字符串缓存和计数功能(数据同步)
总的来说,借助Spring Data Redis和RabbitMQ,我们可以轻松实现字符串缓存和计数的功能。而关键的部分不过是一些"厨房的套路",一旦你掌握了这些套路,那么你就像厨师一样可以准备出一道道饕餮美食了。通过这种方式促进数据处理效率无疑将大大提高我们的生产力。
240 32
|
6月前
|
监控 安全 Java
Java 开发中基于 Spring Boot 3.2 框架集成 MQTT 5.0 协议实现消息推送与订阅功能的技术方案解析
本文介绍基于Spring Boot 3.2集成MQTT 5.0的消息推送与订阅技术方案,涵盖核心技术栈选型(Spring Boot、Eclipse Paho、HiveMQ)、项目搭建与配置、消息发布与订阅服务实现,以及在智能家居控制系统中的应用实例。同时,详细探讨了安全增强(TLS/SSL)、性能优化(异步处理与背压控制)、测试监控及生产环境部署方案,为构建高可用、高性能的消息通信系统提供全面指导。附资源下载链接:[https://pan.quark.cn/s/14fcf913bae6](https://pan.quark.cn/s/14fcf913bae6)。
968 0
|
9月前
|
前端开发 Cloud Native Java
Java||Springboot读取本地目录的文件和文件结构,读取服务器文档目录数据供前端渲染的API实现
博客不应该只有代码和解决方案,重点应该在于给出解决方案的同时分享思维模式,只有思维才能可持续地解决问题,只有思维才是真正值得学习和分享的核心要素。如果这篇博客能给您带来一点帮助,麻烦您点个赞支持一下,还可以收藏起来以备不时之需,有疑问和错误欢迎在评论区指出~
Java||Springboot读取本地目录的文件和文件结构,读取服务器文档目录数据供前端渲染的API实现