RabbitMq（十四）消息的事务支持及代码演示

在rabbitmq中我们也有类似数据库的事务需求，及当程序运行过程中出现异常时，不能完整的执行一个流程时，为了保持功能完整性，我们需要将之前发送的消息也不让他发送出去，此时就需要使用到rabbitmq的事务功能。rabbitmq的事务功能与消息确认机制不能共存，只能同时使用其中一种。

在资源文件中我们需要引入外部的事务管理器transactionManager来控制rabbitmq的事务。以及在资源文件中配置其消息发送对象时声明 channel-transacted="true" 。在我们执行主要业务流程的方法上添加上spring的@Transaction注解来实现方法内的消息控制在同一事务内。

项目完整文件如下：

pom.xml
src/main/resources/application.properties
src/main/resources/spring/transcation-rabbitmq.xml
src/main/java/com/xiaohui/rabbitmq/ProducerApplication.java
src/main/java/com/xiaohui/rabbitmq/controller/MsgController.java

一、pom.xml

pom.xml引入了spring web模块主要用来调用链接测试模拟发送消息。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.xiaohui.mqproducer</groupId><artifactId>MqProducer</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.4.RELEASE</version></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency></dependencies></project>

二、springboot配置问题application.properties

#端口
server.port=8888
#rabbitMq配置
spring.rabbitmq.host=172.18.255.118
spring.rabbitmq.port=5672
spring.rabbitmq.virtual-host=/myhost
spring.rabbitmq.username=xiaohui
spring.rabbitmq.password=root

三、spring资源文件 transcation-rabbitmq.xml

事务主要配置在这里，注意消息发送对象不能遗漏配置 channel-transacted="true" 。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.1.xsdhttp://www.springframework.org/schema/rabbithttp://www.springframework.org/schema/rabbit/spring-rabbit.xsd"><!-- xml可以使用$占位符 --><context:property-placeholder location="classpath*:application.properties" /><!--  在使用事务时 链接工厂不能使用  publisher-confirms="true" publisher-returns="true" ，事务与工厂配置消息确认机制不能共存 --><rabbit:connection-factory id="connectionFactory"host="${spring.rabbitmq.host}"port="${spring.rabbitmq.port}"username="${spring.rabbitmq.username}"password="${spring.rabbitmq.password}"virtual-host="${spring.rabbitmq.virtual-host}"/><!-- 定义消息发送类，并指定回调处理对象 以及连接工厂信息 --><rabbit:template id="rabbitTemplate"connection-factory="connectionFactory"channel-transacted="true" /><!-- 事务管理器 --><bean id="transactionManager" class="org.springframework.amqp.rabbit.transaction.RabbitTransactionManager"><property name="connectionFactory" ref="connectionFactory"/></bean></beans>

四、springboot启动类ProducerApplication.java

在启动类中我们使用@ImportResource 引入了第三步的spring资源文件transcation-rabbitmq.xml。

package com.xiaohui.rabbitmq;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;/*** 生产者启动类*/
@SpringBootApplication
@ImportResource({"classpath:spring/transcation-rabbitmq.xml"})
public class ProducerApplication {public static void main(String[] args) {SpringApplication.run(ProducerApplication.class,args);}
}

五、web层Controller类MsgController.java

用来模拟发送消息以及方法内报错时验证消息是否正常回滚。发送消息方法需要添加spring 注解@Transaction

package com.xiaohui.rabbitmq.controller;import com.xiaohui.rabbitmq.config.RabbitMqConfig;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;@RestController
public class MsgController {@AutowiredRabbitTemplate rabbitTemplate;@GetMapping("/sendTransMsg")@Transactionalpublic String sendTransMsg(@RequestParam String msg,@RequestParam String exchange,@RequestParam String key){rabbitTemplate.convertAndSend(exchange,key,msg);//模拟报错Integer.parseInt(msg);rabbitTemplate.convertAndSend(exchange,key,"@@:"+msg);return "消息发送成功！";}
}

六、启动工程，通过消息参数分别模拟正常发送情况和报错情况。

场景1：我们在消息参数上传入数字值时请求后在mq控制台可以看到消息正常的进入到了队列中。

场景2：当我们在消息参数中传入其他非数字时，发送消息逻辑中发生异常，通过控制台观察没有消息进入到队列中。

项目工程结构如下，划线文件为未使用到噢文件，本示例中消息队列以及交换机应之前做好了创建绑定关系。

RabbitMq（十四）消息的事务支持及代码演示相关推荐

RabbitMQ中7种消息队列和保姆级代码演示！
blog.csdn.net/qq_32828253/article/details/110450249 七种模式介绍与应用场景简单模式(Hello World) 做最简单的事情,一个生产者对应一个消 ...
springcloudstream+rabbitmq+eureka进行消息发送和接收实例代码
文章目录 eureka作注册中心的配置: 消息提供方: 消费者代码注册中心.消息接受者.消息提供者分别启动: eureka作注册中心的配置: 依赖包: <dependencies>< ...
嵌入式Linux系统编程学习之二十四消息队列
文章目录前言一.msgget 函数二.msgsnd 函数三.msgctl 函数补充前言消息队列与 FIFO 很相似,都是一个队列结构,都可以有多个进程往队列里面写信息,多个进程从队列 ...
牛客网力扣算法编程之十四 | 字符串 - 字符个数统计 - Java代码实现
[算法编程]字符个数统计一. 题目描述编写一个函数,计算字符串中含有的不同字符的个数.字符在 ASCII 码范围内( 0~127 ,包括 0 和 127 ),换行表示结束符,不算在字符里.不在范围 ...
JavaScript实现中国地图圆点标注（二十四）
JavaScript实现中国地图圆点标注(二十四) 效果如下: 部分代码如下: <!DOCTYPE html> <html lang="en"><he ...
视觉SLAM十四讲（第二版）环境安装心得体会
前言将高博的视觉SLAM14讲(第二版)看完后,也将里面所有的代码都跑了一遍,在安装环境的时候遇到了无数的坑.为了后来的人能够更加快速上手SLAM,现将书中环境安装心得记录如下. 环境安装 1. 安 ...
【读书笔记】《视觉SLAM十四讲（高翔著）》第13讲
文章目录工程文件一:dense_monocular(单目稠密地图) 工程文件二:dense_RGBD(点云地图 & 八叉树地图) 本博客的内容是本章程序编译运行方法,记录调通本章程序的过程. ...
STM32驱动SDIO WIFI 介绍（十六） ---- 上位机UDP操作/代码
代码工程的GITHUB连接:点进进入GITHUB仓库 https://github.com/sj15712795029/stm32f1_marvell88w8801_marvell8801_wifi ...
RabbitMQ（十）：RabbitMQ 如何保证消息的可靠性
一条消费成功被消费经历了生产者->MQ->消费者,因此在这三个步骤中都有可能造成消息丢失. 一消息生产者没有把消息成功发送到MQ 1.1 事务机制 AMQP协议提供了事务机制,在投递消息 ...

RabbitMq（十四）消息的事务支持及代码演示

RabbitMq（十四）消息的事务支持及代码演示相关推荐

最新文章

热门文章