Spring Cloud Seata at模式 java 代码实例

以下是一个简单的使用 Spring Cloud Seata AT 模式的 Java 代码实例：

首先，需要在 Spring Boot 项目的 pom.xml 文件中添加 Seata 的依赖：

<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-all</artifactId>
    <version>1.4.1</version>
</dependency>

然后，在项目的 application.properties 文件中添加 Seata 的配置信息：

# Seata配置信息
seata.tx-service-group=my_tx_group
seata.enable-auto-data-source-proxy=true

接着，在需要使用 Seata 的服务中，可以通过注解的方式进行事务管理：

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserDao userDao;

    @Override
    @GlobalTransactional(name = "create-user", rollbackFor = Exception.class)
    public void createUser(User user) {
        userDao.insert(user);
    }

}

在上述代码中，@GlobalTransactional 注解标记了事务的边界，表示这个方法是一个全局事务，并设置了事务的名称和回滚异常。

最后，需要在项目的启动类中添加 Seata 的配置：

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableTransactionManagement
@EnableAutoDataSourceProxy
public class UserServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }

    @Bean
    public GlobalTransactionScanner globalTransactionScanner() {
        return new GlobalTransactionScanner("user-service", "my_tx_group");
    }

}

在上述代码中，@EnableTransactionManagement 注解开启了 Spring 的事务管理，@EnableAutoDataSourceProxy 注解开启了 Seata 的数据源代理，而 GlobalTransactionScanner 则是 Seata 的全局事务扫描器，用于处理全局事务的注册和注销。

以上就是一个简单的 Spring Cloud Seata AT 模式的 Java 代码实例。