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

🧑‍💻作者名称：DaenCode
🎤作者简介：啥技术都喜欢捣鼓捣鼓，喜欢分享技术、经验、生活。
😎人生感悟：尝尽人生百味，方知世间冷暖。
📖所属专栏：SpringBoot实战

系列文章目录

以下是专栏部分内容，更多内容请前往专栏查看！

专栏推荐

• 专门为Redis入门打造的专栏，包含Redis基础知识、基础命令、五大数据类型实战场景、key删除策略、内存淘汰机制、持久化机制、哨兵模式、主从复制、分布式锁等等内容。链接>>>>>>>>>《Redis从头学》
• 专门为RabbitMQ入门打造的专栏，持续更新中。。。。。。。。链接>>>>>>>《图解RabbitMQ》

文章目录

• 系列文章目录
• 专栏推荐
• 🌟项目创建
• 🌟POM文件
• 🌟配置文件修改
• 🌟测试是否整合成功
• 🌟RabbitTemplate常用API
• 🌟写在最后

🌟项目创建

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

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消息默认是自动确认的。

🌟RabbitTemplate常用API

1. 发送消息：

   • convertAndSend(String exchange, String routingKey, Object message)：将消息发送到指定的交换机和路由键。
   • convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)：在发送消息之前对消息进行后处理。
   • convertAndSend(String exchange, String routingKey, Object message, CorrelationData correlationData)：将消息发送到指定的交换机和路由键，并关联一个 correlationData。
   • send(String exchange, String routingKey, Message message)：发送原始的 AMQP 消息对象。

2. 接收消息：

   • receive(String queueName)：从指定队列接收消息，并在没有消息时立即返回 null。
   • receiveAndConvert(String queueName)：从指定队列接收消息，并将消息转换为指定类型的对象。
   • basicConsume(String queue, ChannelAwareMessageListener listener)：基于底层的 Channel 消费队列中的消息，并使用指定的监听器处理接收到的消息。

3. 手动确认：

   • basicAck(long deliveryTag, boolean multiple)：手动确认消息的接收。将 deliveryTag 对应的消息标记为已确认。如果 multiple 为 true，则确认所有小于等于 deliveryTag 的消息。
   • basicNack(long deliveryTag, boolean multiple, boolean requeue)：手动否认消息的接收。将 deliveryTag 对应的消息标记为未确认，可以选择是否将消息重新放回队列。
   • basicReject(long deliveryTag, boolean requeue)：手动拒绝消息的接收。将 deliveryTag 对应的消息标记为未确认，并选择是否将消息重新放回队列。

4. 消息可靠机制：

   • setCorrelationKey(Message message, byte[] correlationKey)：设置消息的关联键（correlation key）。
   • setReturnCallback(ReturnCallback returnCallback)：设置消息发送失败时的回调函数。
   • setConfirmCallback(ConfirmCallback confirmCallback)：设置消息发送确认的回调函数。

🌟写在最后

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