SpringCloudAlibaba--Seata简单案例(二)

深碍√TFBOYSˉ_ 2021-08-27 15:56 289阅读 0赞

#### 新建库存Storage-Module ####

1.  seata-storage-service2002
2.  pom.xml

<dependencies>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
                <exclusions>
                    <exclusion>
                        <artifactId>seata-all</artifactId>
                        <groupId>io.seata</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-all</artifactId>
                <version>0.9.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.0.0</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.37</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
        </dependencies>

1.  application.yml

server:
      port: 2002
    
    spring:
      application:
        name: seata-storage-service
      cloud:
        alibaba:
          seata:
            tx-service-group: fsp_tx_group
        nacos:
          discovery:
            server-addr: localhost:8848
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata_storage
        username: root
        password: 123456
    
    logging:
      level:
        io:
          seata: info
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml

1.  file.conf  
    与之前一致
2.  registry.conf  
    与之前一致
3.  domain

@Data
    public class Storage { 
    
        private Long id;
    
        /** * 产品id */
        private Long productId;
    
        /** * 总库存 */
        private Integer total;
    
        /** * 已用库存 */
        private Integer used;
    
        /** * 剩余库存 */
        private Integer residue;
    }

@Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class CommonResult<T>
    { 
        private Integer code;
        private String  message;
        private T       data;
    
        public CommonResult(Integer code, String message)
        { 
            this(code,message,null);
        }
    }

1.  Dao接口及实现

@Mapper
    public interface StorageDao { 
        //扣减库存
        void decrease(@Param("productId") Long productId, @Param("count") Integer count);
    }

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    
    
    <mapper namespace="pers.zhang.springcloud.alibaba.dao.StorageDao">
    
        <resultMap id="BaseResultMap" type="pers.zhang.springcloud.alibaba.domain.Storage">
            <id column="id" property="id" jdbcType="BIGINT"/>
            <result column="product_id" property="productId" jdbcType="BIGINT"/>
            <result column="total" property="total" jdbcType="INTEGER"/>
            <result column="used" property="used" jdbcType="INTEGER"/>
            <result column="residue" property="residue" jdbcType="INTEGER"/>
        </resultMap>
    
        <update id="decrease">
            UPDATE
                t_storage
            SET
                used = used + #{count},residue = residue - #{count}
            WHERE
                product_id = #{productId}
        </update>
    
    </mapper>

1.  Service接口及实现

public interface StorageService { 
        /** * 扣减库存 */
        void decrease(Long productId, Integer count);
    }

@Service
    public class StorageServiceImpl implements StorageService { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(StorageServiceImpl.class);
    
        @Resource
        private StorageDao storageDao;
    
        /** * 扣减库存 */
        @Override
        public void decrease(Long productId, Integer count) { 
            LOGGER.info("------->storage-service中扣减库存开始");
            storageDao.decrease(productId,count);
            LOGGER.info("------->storage-service中扣减库存结束");
        }
    }

1.  Controller

@RestController
    public class StorageController { 
    
        @Autowired
        private StorageService storageService;
    
        /** * 扣减库存 */
        @RequestMapping("/storage/decrease")
        public CommonResult decrease(Long productId, Integer count) { 
            storageService.decrease(productId, count);
            return new CommonResult(200,"扣减库存成功！");
        }
    }

1.  Config配置  
    与之前一致。
2.  主启动类

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    @EnableDiscoveryClient
    @EnableFeignClients
    public class SeataStorageServiceApplication2002
    { 
        public static void main(String[] args)
        { 
            SpringApplication.run(SeataStorageServiceApplication2002.class, args);
        }
    }

#### 新建账户Account-module ####

1.  seata-account-service2003
2.  pom.xml

1.  application.yml

server:
      port: 2003
    
    spring:
      application:
        name: seata-account-service
      cloud:
        alibaba:
          seata:
            tx-service-group: fsp_tx_group
        nacos:
          discovery:
            server-addr: localhost:8848
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/seata_account
        username: root
        password: 123456
    
    feign:
      hystrix:
        enabled: false
    
    logging:
      level:
        io:
          seata: info
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml

1.  file.conf  
    与之前一致
2.  registry.conf  
    与之前一致
3.  domain

@Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Account { 
    
        private Long id;
    
        /** * 用户id */
        private Long userId;
    
        /** * 总额度 */
        private BigDecimal total;
    
        /** * 已用额度 */
        private BigDecimal used;
    
        /** * 剩余额度 */
        private BigDecimal residue;
    }

1.  Dao接口及实现

@Mapper
    public interface AccountDao { 
    
        /** * 扣减账户余额 */
        void decrease(@Param("userId") Long userId, @Param("money") BigDecimal money);
    }

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
    
    <mapper namespace="pers.zhang.springcloud.alibaba.dao.AccountDao">
    
        <resultMap id="BaseResultMap" type="pers.zhang.springcloud.alibaba.domain.Account">
            <id column="id" property="id" jdbcType="BIGINT"/>
            <result column="user_id" property="userId" jdbcType="BIGINT"/>
            <result column="total" property="total" jdbcType="DECIMAL"/>
            <result column="used" property="used" jdbcType="DECIMAL"/>
            <result column="residue" property="residue" jdbcType="DECIMAL"/>
        </resultMap>
    
        <update id="decrease">
            UPDATE t_account
            SET
              residue = residue - #{money},used = used + #{money}
            WHERE
              user_id = #{userId};
        </update>
    
    </mapper>

1.  Service接口及实现

public interface AccountService { 
    
        /** * 扣减账户余额 * @param userId 用户id * @param money 金额 */
        void decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money);
    }

@Service
    public class AccountServiceImpl implements AccountService { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(AccountServiceImpl.class);
    
    
        @Resource
        AccountDao accountDao;
    
        /** * 扣减账户余额 */
        @Override
        public void decrease(Long userId, BigDecimal money) { 
            LOGGER.info("------->account-service中扣减账户余额开始");
            //模拟超时异常，全局事务回滚
            //暂停几秒钟线程
            //try { TimeUnit.SECONDS.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); }
            accountDao.decrease(userId,money);
            LOGGER.info("------->account-service中扣减账户余额结束");
        }
    }

1.  Controller

@RestController
    public class AccountController { 
    
        @Resource
        AccountService accountService;
    
        /** * 扣减账户余额 */
        @RequestMapping("/account/decrease")
        public CommonResult decrease(@RequestParam("userId") Long userId, @RequestParam("money") BigDecimal money){ 
            accountService.decrease(userId,money);
            return new CommonResult(200,"扣减账户余额成功！");
        }
    }

1.  Config配置  
    与之前一致。
2.  主启动类

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    @EnableDiscoveryClient
    @EnableFeignClients
    public class SeataAccountMainApp2003
    { 
        public static void main(String[] args)
        { 
            SpringApplication.run(SeataAccountMainApp2003.class, args);
        }
    }