大家好,又见面了,我是你们的朋友全栈君。
原文网址:分布式事务–Hmily(feign)_IT利刃出鞘的博客-CSDN博客
简介
说明
本文使用himily整合springcloud的feign测试TCC分布式事务。所有代码:https://gitee.com/shapeless/demo_SpringCloud/tree/hmily/
官网
文档(springcloud):SpringCloud用户指南 · dromara(Open source organization)
官网示例:https://github.com/dromara/hmily/tree/master/hmily-demo/hmily-demo-tcc/hmily-demo-tcc-springcloud
业务场景
创建订单时,order微服务先预生成订单(订单状态为创建中),再调用storage的feign来减库存,再调用account的feign来减账户余额,最后将订单状态改为已完成。
技术框架
所用技术栈:
- hmily-spring-boot-starter-springcloud:2.1.1
- springboot:2.3.7.RELEASE
- springcloud:Hoxton.SR9
- mysql
- mybatis-plus-boot-starter:3.4.1
- eureka
- gateway
所用插件:
- lombok
技术细节
配置方式
- hmily配置: 各个微服务的resources路径:hmily.yml
- 业务微服务服务:application.yml
缺陷:
存在的问题:order微服务只调用storage的feign是正常的,但若在后边加上account的feign,会报空指针异常。
建库建表
创建hmily数据库
创建名为hmily的数据库。
用于hmily框架保存回滚的信息。本处只需创建库即可,在运行时,它会自动创建表结构,创建后的表结构如下:
创建业务库和表
创建名为business的数据库。
创建业务表:
CREATE TABLE `t_order` (
`id` bigint(11) NOT NULL AUTO_INCREMENT,
`user_id` bigint(11) DEFAULT NULL COMMENT '用户id',
`product_id` bigint(11) DEFAULT NULL COMMENT '产品id',
`count` int(11) DEFAULT NULL COMMENT '数量',
`money` decimal(11,0) DEFAULT NULL COMMENT '金额',
`status` int(1) DEFAULT NULL COMMENT '订单状态:0:创建中;1:已完结',
`create_time` datetime(0) NULL DEFAULT NULL,
`update_time` datetime(0) NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP(0),
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8;
CREATE TABLE `t_account` (
`id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
`user_id` bigint(11) DEFAULT NULL COMMENT '用户id',
`total` decimal(10,0) DEFAULT NULL COMMENT '总额度',
`used` decimal(10,0) DEFAULT NULL COMMENT '已用余额',
`residue` decimal(10,0) DEFAULT '0' COMMENT '剩余可用额度',
`frozen` decimal(10, 0) NULL DEFAULT NULL COMMENT '冻结金额',
`create_time` datetime(0) NULL DEFAULT NULL,
`update_time` datetime(0) NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP(0),
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
# INSERT INTO `seat-account`.`account` (`id`, `user_id`, `total`, `used`, `residue`) VALUES ('1', '1', '1000', '0', '100');
INSERT INTO `t_account` (`id`, `user_id`, `total`, `used`, `residue`) VALUES ('1', '1', '1000', '0', '1000');
CREATE TABLE `t_storage` (
`id` bigint(11) NOT NULL AUTO_INCREMENT,
`product_id` bigint(11) DEFAULT NULL COMMENT '产品id',
`total` int(11) DEFAULT NULL COMMENT '总库存',
`used` int(11) DEFAULT NULL COMMENT '已用库存',
`residue` int(11) DEFAULT NULL COMMENT '剩余库存',
`frozen` decimal(10, 0) NULL DEFAULT NULL COMMENT '冻结库存',
`create_time` datetime(0) NULL DEFAULT NULL,
`update_time` datetime(0) NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP(0),
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
# INSERT INTO `seat-storage`.`storage` (`id`, `product_id`, `total`, `used`, `residue`) VALUES ('1', '1', '100', '0', '100');
INSERT INTO `t_storage` (`id`, `product_id`, `total`, `used`, `residue`) VALUES ('1', '1', '100', '0', '100');
业务微服务配置hmily
说明
hmily不需要像seata一样单独起一个服务。
本处只展示order微服务的hmily配置,其他微服务配置类似。只这几项不同:hmily.server.appName, hmily.config.appName, metrics.port
hmily.yml
hmily:
server:
configMode: local
appName: appName_order
# 如果server.configMode eq local 的时候才会读取到这里的配置信息.
config:
appName: appName_order
repository: mysql
ribbon:
rule:
enabled: true
repository:
database:
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/hmily?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
username: root
password: 222333
metrics:
metricsName: prometheus
port: 8801
业务主要代码
order
controller
package com.example.order.controller;
import com.example.order.entity.Order;
import com.example.order.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/order")
public class OrderController {
@Autowired
OrderService orderService;
@PostMapping("createNormal")
public String createNormal(Order order) {
orderService.createNormal(order);
return "success";
}
@PostMapping("createFault")
public String createFault(Order order) {
orderService.createFault(order);
return "success";
}
}
service
Service
package com.example.order.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.order.entity.Order;
public interface OrderService extends IService<Order> {
void createNormal(Order order);
void createFault(Order order);
}
ServiceImpl
package com.example.order.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.base.feign.AccountFeignClient;
import com.example.base.feign.StorageFeignClient;
import com.example.order.entity.Order;
import com.example.order.mapper.OrderMapper;
import com.example.order.service.OrderService;
import com.example.order.tcc.OrderTccAction;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Slf4j
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
@Autowired
StorageFeignClient storageFeignClient;
@Autowired
AccountFeignClient accountFeignClient;
@Autowired
OrderMapper orderMapper;
@Autowired
OrderTccAction orderTccAction;
@Override
public void createNormal(Order order) {
log.info("创建订单总业务:开始");
save(order);
orderMapper.updateStatus(order.getId(), 1);
orderTccAction.tryCreateOrderNormal(order.getId(), order.getProductId(), order.getCount(), order.getUserId(), order.getMoney());
// ResultHolder.setResult(OrderTccAction.class, UUID.randomUUID().toString(), "p");
log.info("创建订单总业务:结束");
}
@Override
public void createFault(Order order) {
log.info("创建订单总业务:开始");
save(order);
orderMapper.updateStatus(order.getId(), 1);
// orderTccAction.tryCreateOrderFault(order.getId(), order.getProductId(), order.getCount(), order.getUserId(), order.getMoney());
log.info("创建订单总业务:结束");
}
}
mapper
package com.example.order.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.order.entity.Order;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Update;
import org.springframework.stereotype.Repository;
@Repository
public interface OrderMapper extends BaseMapper<Order> {
@Update("UPDATE `t_order` SET status = #{status} WHERE id = #{id}")
int updateStatus(@Param("id") Long id, @Param("status") Integer status);
}
storage
controller
package com.example.storage.feign;
import com.example.storage.service.StorageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class FeignController {
@Autowired
StorageService storageService;
@PostMapping("/feign/storage/tryDecreaseStorage")
public boolean tryDecreaseStorage(@RequestParam("productId")Long productId,
@RequestParam("count")Integer count) {
storageService.tryDecreaseStorage(productId, count);
return true;
}
}
service
Service
package com.example.storage.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.storage.entity.Storage;
public interface StorageService extends IService<Storage> {
void tryDecreaseStorage(Long productId, Integer count);
}
ServiceImpl
package com.example.storage.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.storage.entity.Storage;
import com.example.storage.mapper.StorageMapper;
import com.example.storage.service.StorageService;
import lombok.extern.slf4j.Slf4j;
import org.dromara.hmily.annotation.HmilyTCC;
import org.springframework.stereotype.Service;
@Service
@Slf4j
public class StorageServiceImpl extends ServiceImpl<StorageMapper, Storage> implements StorageService {
@Override
@HmilyTCC(confirmMethod = "confirmDecreaseStorage", cancelMethod = "cancelDecreaseStorage")
public void tryDecreaseStorage(Long productId, Integer count) {
log.info("库存服务:第一阶段开始:检查剩余库存、冻结库存");
Storage storage = getById(productId);
if (storage.getResidue() < count) {
throw new RuntimeException("库存不足。" +
"实际库存:" + storage.getResidue() + ",购买数量:" + count);
}
getBaseMapper().prepareDecreaseStorage(productId, count);
//第一阶段成功 添加一个标识。
//xid也可以通过RootContext.getXid()来获得
// ResultHolder.setResult(StorageFeignClient.class, RootContext.getXID(), "p");
// log.info("storage XID:{}", RootContext.getXID());
log.info("库存服务:第一阶段结束:检查剩余库存、冻结库存");
}
public void confirmDecreaseStorage(Long productId, Integer count) {
log.info("库存服务:第二阶段提交开始:释放冻结的库存、增加已用库存");
//TODO ResultHolder相关方法
getBaseMapper().commitDecreaseStorage(productId, count);
log.info("库存服务:第二阶段提交结束:释放冻结的库存、增加已用库存");
}
public void cancelDecreaseStorage(Long productId, Integer count) {
log.info("库存服务:第二阶段回滚开始:释放冻结的库存、增加回原来剩余库存");
//TODO ResultHolder相关方法
getBaseMapper().cancelDecreaseStorage(productId, count);
log.info("库存服务:第二阶段回滚结束:释放冻结的库存、增加回原来剩余库存");
}
}
mapper
package com.example.storage.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.storage.entity.Storage;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Update;
import org.springframework.stereotype.Repository;
@Repository
public interface StorageMapper extends BaseMapper<Storage> {
@Update("UPDATE `t_storage` SET used= used + #{count}, residue = residue - #{count} WHERE product_id = #{productId}")
int decreaseStorage(@Param("productId") Long productId, @Param("count") Integer count);
@Update("UPDATE `t_storage` SET frozen = frozen + #{count}, residue = residue - #{count} WHERE product_id = #{productId}")
void prepareDecreaseStorage(@Param("productId") Long productId, @Param("count") Integer count);
@Update("UPDATE `t_storage` SET frozen = frozen - #{count}, used = used + #{count} WHERE product_id = #{productId}")
void commitDecreaseStorage(@Param("productId") Long productId, @Param("count") Integer count);
@Update("UPDATE `t_storage` SET frozen = frozen - #{count}, residue = residue + #{count} WHERE product_id = #{productId}")
void cancelDecreaseStorage(@Param("productId") Long productId, @Param("count") Integer count);
}
account
controller
package com.example.account.feign;
import com.example.account.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
@RestController
public class FeignController {
@Autowired
AccountService accountService;
@PostMapping("/feign/account/tryDecreaseMoney")
public void tryDecreaseMoney(@RequestParam("userId")Long userId, @RequestParam("money")BigDecimal money) {
accountService.tryDecreaseMoney(userId, money);
}
@PostMapping("/feign/account/tryDecreaseMoneyFault")
public void tryDecreaseMoneyFault(@RequestParam("userId")Long userId, @RequestParam("money")BigDecimal money) {
accountService.tryDecreaseMoneyFault(userId, money);
}
}
service
Service
package com.example.account.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.account.entity.Account;
import java.math.BigDecimal;
public interface AccountService extends IService<Account> {
void tryDecreaseMoney(Long userId, BigDecimal money);
void tryDecreaseMoneyFault(Long userId, BigDecimal money);
}
ServiceImpl
package com.example.account.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.account.entity.Account;
import com.example.account.mapper.AccountMapper;
import com.example.account.service.AccountService;
import lombok.extern.slf4j.Slf4j;
import org.dromara.hmily.annotation.HmilyTCC;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
@Service
@Slf4j
public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> implements AccountService {
@Override
@HmilyTCC(confirmMethod = "confirmDecreaseMoney", cancelMethod = "cancelDecreaseMoney")
public void tryDecreaseMoney(Long userId, BigDecimal money) {
log.info("账户服务:第一阶段开始:检查余额、冻结金额");
Account account = getById(userId);
if (account.getResidue().compareTo(money) < 0) {
throw new RuntimeException("余额不足。" +
"实际余额:" + account.getResidue() + ",购买金额:" + money);
}
getBaseMapper().tryDecreaseMoney(userId, money);
log.info("账户服务:第一阶段结束:检查余额、冻结金额");
}
public void confirmDecreaseMoney(Long userId, BigDecimal money) {
log.info("账户服务:第二阶段提交开始:释放冻结的金额、增加已用金额");
getBaseMapper().confirmDecreaseMoney(userId, money);
log.info("账户服务:第二阶段提交结束:释放冻结的金额、增加已用金额");
}
public void cancelDecreaseMoney(Long userId, BigDecimal money) {
log.info("账户服务:第二阶段回滚开始:释放冻结的金额、增加回原来余额");
getBaseMapper().cancelDecreaseMoney(userId, money);
log.info("账户服务:第二阶段回滚结束:释放冻结的金额、增加回原来余额");
}
@Override
@HmilyTCC(confirmMethod = "confirmDecreaseMoneyFault", cancelMethod = "cancelDecreaseMoneyFault")
public void tryDecreaseMoneyFault(Long userId, BigDecimal money) {
log.info("账户服务:第一阶段开始:检查余额、冻结金额");
Account account = getById(userId);
if (account.getResidue().compareTo(money) < 0) {
throw new RuntimeException("余额不足。" +
"实际余额:" + account.getResidue() + ",购买金额:" + money);
}
getBaseMapper().tryDecreaseMoney(userId, money);
log.info("账户服务:第一阶段结束:检查余额、冻结金额");
}
public void confirmDecreaseMoneyFault(Long userId, BigDecimal money) {
log.info("账户服务:第二阶段提交开始:释放冻结的金额、增加已用金额");
int i = 1 / 0;
getBaseMapper().confirmDecreaseMoney(userId, money);
log.info("账户服务:第二阶段提交结束:释放冻结的金额、增加已用金额");
}
public void cancelDecreaseMoneyFault(Long userId, BigDecimal money) {
log.info("账户服务:第二阶段回滚开始:释放冻结的金额、增加回原来余额");
int i = 1 / 0;
getBaseMapper().cancelDecreaseMoney(userId, money);
log.info("账户服务:第二阶段回滚结束:释放冻结的金额、增加回原来余额");
}
}
mapper
package com.example.account.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.account.entity.Account;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Update;
import org.springframework.stereotype.Repository;
import org.springframework.web.bind.annotation.RequestParam;
import java.math.BigDecimal;
@Repository
public interface AccountMapper extends BaseMapper<Account> {
@Update("UPDATE `t_account` SET residue = residue - #{money},used = used + #{money} where user_id = #{userId}")
int decreaseMoney(@Param("userId")Long userId, @Param("money") BigDecimal money);
@Update("UPDATE `t_account` SET frozen = frozen + #{money}, residue = residue - #{money} WHERE user_id = #{userId}")
void tryDecreaseMoney(@Param("userId") Long userId, @Param("money") BigDecimal money);
@Update("UPDATE `t_account` SET frozen = frozen - #{money}, used = used + #{money} WHERE user_id = #{userId}")
void confirmDecreaseMoney(@Param("userId") Long userId, @Param("money") BigDecimal money);
@Update("UPDATE `t_account` SET frozen = frozen - #{money}, residue = residue + #{money} WHERE user_id = #{userId}")
void cancelDecreaseMoney(@Param("userId") Long userId, @Param("money") BigDecimal money);
}
业务次要代码
base
通用应用注解
package com.example.base.config;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.core.annotation.AliasFor;
import java.lang.annotation.*;
@Inherited
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@MapperScan("com.example.**.mapper")
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients("com.example.base.feign")
public @interface BaseApplication {
@AliasFor(annotation = SpringBootApplication.class)
String[] scanBasePackages() default "com.example.**";
// @AliasFor(annotation = SpringBootApplication.class)
// Class<?>[] exclude() default {DataSourceAutoConfiguration.class};
}
mybatis-plus 自动填充插件
package com.example.base.config;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.time.LocalDateTime;
@Configuration
//@MapperScan("com.example.**.mapper")
public class MyBatisPlusConfig {
private static final Logger logger = LoggerFactory.getLogger(MyBatisPlusConfig.class);
//自动填充插件
@Bean
public MetaObjectHandler metaObjectHandler() {
return new MybatisPlusAutoFillConfig();
}
public class MybatisPlusAutoFillConfig implements MetaObjectHandler {
// 新增时填充
@Override
public void insertFill(MetaObject metaObject) {
logger.info("插入:自动填充createTime和updateTime:"+ LocalDateTime.now());
setFieldValByName("createTime", LocalDateTime.now(), metaObject);
setFieldValByName("updateTime", LocalDateTime.now(), metaObject);
}
// 修改时填充
@Override
public void updateFill(MetaObject metaObject) {
logger.info("更新:自动填充updateTime:" + LocalDateTime.now());
setFieldValByName("updateTime", LocalDateTime.now(), metaObject);
}
}
}
feign定义
package com.example.base.feign;
import org.dromara.hmily.annotation.Hmily;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
@FeignClient("storage")
public interface StorageFeignClient {
@Hmily
@PostMapping("/feign/storage/tryDecreaseStorage")
void tryDecreaseStorage(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
}
package com.example.base.feign;
import org.dromara.hmily.annotation.Hmily;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import java.math.BigDecimal;
@FeignClient("account")
public interface AccountFeignClient {
@Hmily
@PostMapping("/feign/account/tryDecreaseMoney")
boolean tryDecreaseMoney(@RequestParam("userId")Long userId, @RequestParam("money")BigDecimal money);
@Hmily
@PostMapping("/feign/account/tryDecreaseMoneyFault")
boolean tryDecreaseMoneyFault(@RequestParam("userId")Long userId, @RequestParam("money")BigDecimal money);
}
pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.3.7.RELEASE</version>
</parent>
<packaging>pom</packaging>
<groupId>com.example</groupId>
<artifactId>base</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>base</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<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.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.12</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>2.2.6.RELEASE</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<!-- <version>8.0.21</version> 版本Spring-Boot-Parent中已带 -->
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.1</version>
</dependency>
<dependency>
<groupId>org.dromara</groupId>
<artifactId>hmily-spring-boot-starter-springcloud</artifactId>
<version>2.1.1</version>
<!-- <version>2.0.6-RELEASE</version>-->
<exclusions>
<exclusion>
<groupId>org.dromara</groupId>
<artifactId>hmily-repository-mongodb</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<!-- <version>Finchley.RELEASE</version>-->
<!-- <version>Greenwich.SR3</version>-->
<version>Hoxton.SR9</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>build-helper-maven-plugin</artifactId>
<version>1.8</version>
<executions>
<execution>
<id>add-source</id>
<phase>generate-sources</phase>
<goals>
<goal>add-source</goal>
</goals>
<configuration>
<sources>
<source>src/main/java</source>
<source>../base</source>
<!-- <source>../base/src/main/java</source>-->
</sources>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
<!-- <resources>-->
<!-- <resource>-->
<!-- <directory>src/main/resources</directory>-->
<!-- <includes>-->
<!-- <include>**/*</include>-->
<!-- </includes>-->
<!-- <filtering>false</filtering>-->
<!-- </resource>-->
<!-- <resource>-->
<!-- <directory>../base/src/main/resources</directory>-->
<!-- <includes>-->
<!-- <include>**/*</include>-->
<!-- </includes>-->
<!-- <filtering>false</filtering>-->
<!-- </resource>-->
<!-- </resources>-->
</build>
</project>
eureka/gateway
eureka
启动类
package com.example.eurekaserver;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaServerApplication.class, args);
}
}
application.yml
server:
port: 7001
spring:
application:
name: eureka-server
eureka:
instance:
hostname: localhost1
client:
register-with-eureka: false
fetch-registry: false
serviceUrl:
defaultZone: http://localhost:7001/eureka/
pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<!-- <version>2.0.6.RELEASE</version>-->
<version>2.1.12.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>eureka-server</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>eureka-server</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<!-- <version>Finchley.SR2</version>-->
<version>Greenwich.SR6</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
</project>
gateway
启动类
package com.example.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class GatewayApplication {
public static void main(String[] args) {
SpringApplication.run(GatewayApplication.class, args);
}
}
application.yml
server:
port: 6001
spring:
application:
name: gateway
cloud:
gateway:
discovery:
locator:
enabled: true
lower-case-service-id: true
httpclient:
ssl:
use-insecure-trust-manager: true
eureka:
client:
service-url:
defaultZone: http://localhost:7001/eureka/
# 配置Gateway日志等级,输出转发细节信息
logging:
level:
org.springframework.cloud.gateway: debug
pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.12.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>gateway</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Greenwich.SR6</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
order/storage/account
说明:order/storage/account的次要代码都是一样的。只是改了唯一性的东西:spring.applicaion.name、端口号、pom.xml的artifactId以及name。
启动类
package com.example.order;
import com.example.base.config.BaseApplication;
import org.springframework.boot.SpringApplication;
@BaseApplication
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
}
application.yml
server:
port: 9011
spring:
application:
name: order
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/business?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
username: root
password: 222333
eureka:
client:
service-Url:
defaultZone: http://localhost:7001/eureka
# defaultZone: http://localhost:7001/eureka,http://localhost:7002/eureka
feign:
hystrix:
enabled: false
#Ribbon的负载均衡策略
#ribbon:
# OkToRetryOnAllOperations: fasle # 对所有操作请求都进行重试 default false
# MaxAutoRetriesNextServer: 0 # 切换实例的重试次数 default 1
# MaxAutoRetries: 0 # 对当前实例的重试次数 default 0
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
#management:
# metrics:
# binders:
# hystrix:
# enabled: false
pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.example</groupId>
<artifactId>base</artifactId>
<version>0.0.1-SNAPSHOT</version>
<relativePath>../base/pom.xml</relativePath>
</parent>
<artifactId>order</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>order</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
</dependencies>
</project>
测试
测试不报错的接口
访问:http://localhost:6001/order/order/createNormal?userId=1&productId=1&count=10&money=100
测试account服务报错的接口
访问:http://localhost:6001/order/order/createFault?userId=1&productId=1&count=10&money=100
其他网址
分布式事务解决方案之TCC(Hmily)_篮战丶的博客-CSDN博客_tcc分布式事务
Hmily实现TCC事务控制_传智燕青-CSDN博客
Hmily:高性能异步分布式事务TCC框架_架构师的成长之路的博客-CSDN博客
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/143346.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...