实战项目中整合Seata编码实践

<!-- Seata 依赖包 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

seata.enabled=true
#3个不同的微服务被命名为不同的名称，如goods-server、order-server、shopcart-server
seata.application-id=order-server
#事务分组配置
seata.tx-service-group=newbee_cloud_save_order_group
service.vgroupMapping.newbee_cloud_save_order_group=default
#连接Nacos服务中心的配置信息
seata.registry.type=nacos
seata.registry.nacos.application=seata-server
seata.registry.nacos.server-addr=127.0.0.1:8848
seata.registry.nacos.username=nacos
seata.registry.nacos.password=nacos
seata.registry.nacos.group=DEFAULT_GROUP
seata.registry.nacos.cluster=default

import com.alibaba.druid.pool.DruidDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.annotation.PostConstruct;
import javax.sql.DataSource;

@Configuration
public class SeataProxyConfiguration {

    //创建 Druid 数据源
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource")
    public DruidDataSource druidDataSource() {
        return new DruidDataSource();
    }

    //创建 DataSource 数据源代理
    @Bean("dataSource")
    @Primary
    public DataSource dataSourceDelegation(DruidDataSource druidDataSource) {
        return new DataSourceProxy(druidDataSource);
    }

    /*
     * 解决 druid 日志报错; discard long time none received connection:xxx
     */
    @PostConstruct
    public void setProperties() {
        System.setProperty("druid.mysql.usePingMethod", "false");
    }
}

@Override
@Transactional
//加上这个注解，开启 Seata 分布式事务
@GlobalTransactional
public String saveOrder(Long mallUserId, MallUserAddress address, List<Long> cartItemIds) {
    //省略部分代码
}