如何在Spring和GlassFish 5中执行分布式事务XA？

本文介绍了如何在Spring和GlassFish 5中执行分布式事务XA？的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我试图创建一个包含两个REST Web服务的事务，其数据源指向相同的数据库。第一个名为 1 的服务使用Spring RestTemplate调用另一个名为 2 的Web服务。

为了实现事务，我使用了JNDI连接池，MySql JDBC驱动程序（版本5.1.35），JTA，XA，Spring和GlassFish 5 AppServer。

现在，我已经下载了Spring项目中的Maven依赖项，使用 JtaTransactionManager 定义了一个配置类，并将数据源和JTA属性配置为 application.yml 文件，如下面的代码所示：

  @Configuration 
 @EnableTransactionManagement 
 public class Transacciones {
 
 @Bean 
 public PlatformTransactionManager platformTransactionManager（）{
 return new JtaTransactionManager（）; 
} 
 
}

  spring：
数据源：
 jndi-名称：jdbc / Prueba 
 driver-class-name：com.mysql.jdbc.Driver 
 $ b jta：
启用：true

我在GlassFish 5中配置了定义名为 jdbc / Prueba 的JDBC资源的JNDI数据源。使用 javax.sql.XADataSource 数据源名为 pruebaXA 的Connections pools页面：

在Web服务控制层 1 ，该方法使用Spring Framework的 RestTemplate 类调用服务 2 p>

  @RestController 
 @RequestMapping（/ servicio）
 @EnableTransactionManagement 
 public class a {
 
 @Autowired 
 private JdbcTemplate objJdbcTemplate; 
 
 
 @Transactional（rollbackFor = RuntimeException.class）
 @GetMapping（/ 1）
 public Integer getValor（）{
 try {
 int数字; 
 int n = 50; 
 RestTemplate restTemplate = new RestTemplate（）; 
 
整型intRes1; 
整型intRes2; 
 numero =（int）（Math.random（）* n）+ 1; 
 
 intRes2 = restTemplate.postForObject（http：// localhost：8080 / servicio2-1.0-SNAPSHOT / servicio / 2，numero，Integer.class）; 
 
 intRes1 = objJdbcTemplate.update（INSERT INTO A VALUES（+ numero +））; 
 
返回数字; 
} catch（Exception e）{
 throw new RuntimeException（e）; 
} 
} 
}

  @RestController 
 @RequestMapping（/ servicio ）
 public class a {
 
 @Autowired 
 private JdbcTemplate objJdbcTemplate; 
 
 @Transactional（rollbackFor = RuntimeException.class）
 @PostMapping（/ 2）
 public Integer getValor（@RequestBody Integer intNum）{
 try {
 Integer intRes; 
 
 intRes = objJdbcTemplate.update（INSERT INTO B VALUES（+ intNum +））; 
返回intRes; 
} catch（Exception e）{
 throw new RuntimeException（e）; 
 
 
 
 
 
 $ p $如果这两个服务工作没有错误，没有问题。但是，当服务 1 下降时，服务 2 不知道错误并且不执行回滚。 
 
 
 我不知道是否需要在GlassFish 5或Spring程序中配置其他功能/选项。
 
 
 我已经读过，在Spring中只需要一个 JtaTransactionManager  bean，该框架执行与配置和使用JTA事务有关的所有工作。 
感谢您的帮助和时间。 class =h2_lin>解决方案

@Configuration @EnableTransactionManagement public class Transacciones { @Bean public PlatformTransactionManager platformTransactionManager(){ return new JtaTransactionManager(); } }

@RestController @RequestMapping("/servicio") @EnableTransactionManagement public class a { @Autowired private JdbcTemplate objJdbcTemplate; @Transactional(rollbackFor = RuntimeException.class) @GetMapping("/1") public Integer getValor(){ try{ int numero; int n=50; RestTemplate restTemplate = new RestTemplate(); Integer intRes1; Integer intRes2; numero = (int) (Math.random() * n) + 1; intRes2 = restTemplate.postForObject("http://localhost:8080/servicio2-1.0-SNAPSHOT/servicio/2",numero,Integer.class); intRes1=objJdbcTemplate.update("INSERT INTO A VALUES(" +numero + ")"); return numero; }catch(Exception e){ throw new RuntimeException(e); } } }

@RestController @RequestMapping("/servicio") public class a { @Autowired private JdbcTemplate objJdbcTemplate; @Transactional(rollbackFor = RuntimeException.class) @PostMapping("/2") public Integer getValor(@RequestBody Integer intNum){ try{ Integer intRes; intRes=objJdbcTemplate.update("INSERT INTO B VALUES(" + intNum + ")"); return intRes; }catch(Exception e){ throw new RuntimeException(e); } } }