• springCloudeAlibaba的使用

    父pom文件：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.     <modules>
    7.         <module>ordermodule>
    8.         <module>commonmodule>
    9.         <module>usermodule>
    11.         <module>openFeignOrdermodule>
    12.     modules>
    13.  
    14.  
    15.     <groupId>org.examplegroupId>
    16.     <artifactId>springCloudAlibabaartifactId>
    17.     <version>1.0-SNAPSHOTversion>
    18.     <packaging>pompackaging>
    19.  
    20.     <parent>
    21.         <groupId>org.springframework.bootgroupId>
    22.         <artifactId>spring-boot-starter-parentartifactId>
    23.         <version>2.3.11.RELEASEversion>
    24.         <relativePath/> 
    25.     parent>
    26.     <dependencies>
    27.         <dependency>
    28.             <groupId>org.projectlombokgroupId>
    29.             <artifactId>lombokartifactId>
    30.             <version>1.18.30version>
    31.         dependency>
    32.     dependencies>
    33.  
    34.     
    35.     <dependencyManagement>
    36.         <dependencies>
    37.             <dependency>
    38.                 
    39.                 <groupId>com.alibaba.cloudgroupId>
    40.                 <artifactId>spring-cloud-alibaba-dependenciesartifactId>
    41.                 <version>2.2.5.RELEASEversion>
    42.                 <type>pomtype>
    43.                 <scope>importscope>
    44.             dependency>
    45.             <dependency>
    46.                 
    47.                 <groupId>org.springframework.cloudgroupId>
    48.                 <artifactId>spring-cloud-dependenciesartifactId>
    49.                 <version>Hoxton.SR8version>
    50.                 <type>pomtype>
    51.                 <scope>importscope>
    52.             dependency>
    53.         dependencies>
    54.     dependencyManagement>
    55.  
    56.     <properties>
    57.         <skywalking.version>8.5.0skywalking.version>
    58.         <maven.compiler.source>8maven.compiler.source>
    59.         <maven.compiler.target>8maven.compiler.target>
    60.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    61.     properties>
    62.     <build>
    63.         <plugins>
    64.             <plugin>
    65.                 <groupId>org.springframework.bootgroupId>
    66.                 <artifactId>spring-boot-maven-pluginartifactId>
    67.             plugin>
    68.         plugins>
    69.     build>
    70. project>

    （一定要遵从springcloude版本约定的各个组件版本号，直接往上搜来看版本发布说明 | Spring Cloud Alibaba (aliyun.com)）首先原来的服务注册与发现eureka被替代为nacos，直接下载运行 startup.cmd ，要改成单机运行：

    set MODE="standalone"

    然后配置文件这样配置yml：

    1. server:
    2.   port: 8001
    3. spring:
    4.   application:
    5. #注册成功后，这就是你的服务名
    6.     name: user-server
    7.   cloud:
    8.     nacos:
    9.       #      nacos服务ip
    10.       server-addr: 192.168.126.1:8848
    11.       discovery:
    12.         #        空间id
    13.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    14.         #        分组
    15.         group: TEST

     调用方式：

    1. package com.stockServer.controller;
    2.  
    3. import com.common.util.MyServerNameUtil;
    4. import org.springframework.beans.factory.annotation.Autowired;
    5. import org.springframework.web.bind.annotation.PostMapping;
    6. import org.springframework.web.bind.annotation.RequestMapping;
    7. import org.springframework.web.bind.annotation.RestController;
    8. import org.springframework.web.client.RestTemplate;
    9.  
    10. /**
    11.  * @program: springCloudAlibaba
    12.  * @author: quxiao
    13.  * @create: 2024-02-03 12:57
    14.  **/
    15. @RequestMapping("/dingDan")
    16. @RestController
    17. public class DingDanController {
    18.     @Autowired
    19.     RestTemplate restTemplate;
    20.  
    21.  
    22.     @PostMapping("/xiadan")
    23.     public String xiadan() {
    24.         String template = restTemplate.postForObject("http://" + "user-server" + "/XiaDab/jianKuChun", null, String.class);
    25.         return template;
    26.     }
    27. }

    就不再需要指定完全的url地址，还有就是默认集成了ribbon调用方式，也就是说，可以自己设定调用的方式，轮询、随机。。。。

    1. package com.stockServer.config;
    2.  
    3. import com.alibaba.cloud.nacos.ribbon.NacosRule;
    4. import com.netflix.loadbalancer.IRule;
    5. import com.netflix.loadbalancer.RandomRule;
    6. import org.springframework.boot.web.client.RestTemplateBuilder;
    7. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    8. import org.springframework.context.annotation.Bean;
    9. import org.springframework.context.annotation.Configuration;
    10. import org.springframework.web.client.RestTemplate;
    11.  
    12. /**
    13.  * @program: springCloudAlibaba
    14.  * @author: quxiao
    15.  * @create: 2024-02-03 13:00
    16.  **/
    17. @Configuration
    18. public class SpringConfig {
    19.     @Bean
    20.     @LoadBalanced
    21.     public RestTemplate getRestTemplate(RestTemplateBuilder builder) {
    22.         return builder.build();
    23.     }
    24.  
    25.     @Bean
    26.     public IRule getRule() {
    27. //        随机掉用
    28.         return new RandomRule();
    29.     }
    30. }

    使用open-fegin进行调用，不再需要使用url的方式，直接声明接口（请直接创建一个新的模块，不要再图方便，直接修改能跑的模块了！！！！！！！！！）：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>springCloudAlibabaartifactId>
    7.         <groupId>org.examplegroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>openFeignOrderartifactId>
    13.     <dependencies>
    14.         <dependency>
    15.             <groupId>com.alibaba.cloudgroupId>
    16.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    17.         dependency>
    18.         <dependency>
    19.             <groupId>org.examplegroupId>
    20.             <artifactId>commonartifactId>
    21.             <version>1.0-SNAPSHOTversion>
    22.             <scope>compilescope>
    23.         dependency>
    24.         <dependency>
    25.             <groupId>org.springframework.bootgroupId>
    26.             <artifactId>spring-boot-starter-webartifactId>
    27.         dependency>
    28.  
    29.         <dependency>
    30.             <groupId>org.springframework.cloudgroupId>
    31.             <artifactId>spring-cloud-starter-openfeignartifactId>
    32.         dependency>
    33.     dependencies>
    34.     <properties>
    35.         <maven.compiler.source>8maven.compiler.source>
    36.         <maven.compiler.target>8maven.compiler.target>
    37.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    38.     properties>
    39.  
    40. project>
    1. package com.stockServer.fegin;
    2.  
    3. import com.common.dto.MsgData;
    4. import org.springframework.cloud.openfeign.FeignClient;
    5. import org.springframework.web.bind.annotation.PostMapping;
    6. //指定远程接口的服务名，path是@RequestMapping的地址
    7. @FeignClient(name = "user-server", path = "XiaDab")
    8. public interface openFeginOrder {
    9.     @PostMapping("/jianKuChun")
    10.     public String jianKuChun();
    11.  
    12.     @PostMapping("/quxiao")
    13. //方法名可以不同，但是 @PostMapping("/quxiao")必须完全一样！
    14.     public MsgData quxiao();
    15. }

    调用方式：

    1. package com.stockServer.controller;
    2.  
    3. import com.stockServer.fegin.openFeginOrder;
    4. import org.springframework.beans.factory.annotation.Autowired;
    5. import org.springframework.web.bind.annotation.PostMapping;
    6. import org.springframework.web.bind.annotation.RequestMapping;
    7. import org.springframework.web.bind.annotation.RestController;
    8.  
    9. /**
    10.  * @program: springCloudAlibaba
    11.  * @author: quxiao
    12.  * @create: 2024-02-03 12:57
    13.  **/
    14. @RequestMapping("/dingDan")
    15. @RestController
    16. public class DingDanController {
    17. //直接注入这个接口，调用它的方法
    18.     @Autowired
    19.     openFeginOrder openFeginOrder;
    20.  
    21.  
    22.     @PostMapping("/xiadan")
    23.     public String xiadan() {
    24.         String template = openFeginOrder.quxiao1().toString();
    25.         return template;
    26.     }
    27.  
    28. }

    记得开启fegin哦（我在项目上就是因为没开启，导致一直走降级方法。。。。）

    开启：

    1. package com.stockServer;
    2.  
    3. import org.springframework.boot.SpringApplication;
    4. import org.springframework.boot.autoconfigure.SpringBootApplication;
    5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    6. import org.springframework.cloud.openfeign.EnableFeignClients;
    7.  
    8. @SpringBootApplication
    9. @EnableDiscoveryClient
    10. //开启fegin调用
    11. @EnableFeignClients
    12. public class fenginOrderApplication {
    13.     public static void main(String[] args) {
    14.         SpringApplication.run(fenginOrderApplication.class);
    15.     }
    16. }

    也就是说，相当于再我这个服务写一个调用另一个服务的controller，标记了url地址。

    （另一种方式是直接在每一个服务上写一个api模块，每一个服务都有）

    然后实现对外的接口，具体逻辑写好，另一个模块引入然后调用。

    还有另一种远程调用的方式：

     专门用一个api模块来表示是这个服务对外接口。

    具体实现由server来实现。

     启动类将对外的接口加载进来

    Sentinel限流，容灾等使用：

    1.         <dependency>
    2.             <groupId>com.alibaba.cloudgroupId>
    3.             <artifactId>spring-cloud-starter-alibaba-sentinelartifactId>
    4.         dependency>
    1.  private static final String T1 = "t1";
    2.  
    3.     //注解方式
    4.     //blockHandlerClass 将限流的方法写在指定的类中，静态，公共的
    5.     //blockHandler 指定达到限流后执行的方法
    6.     //fallback 发生异常后，容灾方法
    7.     //fallbackClass 将容灾的方法写在指定的类中，静态，公共的
    8.     @GetMapping("/t1")
    9.     @SentinelResource(value = T1, blockHandlerClass = test.class, blockHandler = "t1cw", fallback = "t1rz", fallbackClass = test.class)
    10.     public String t1() {
    11.         //代码的方式添加限流，或者容灾
    12. //        Entry entry = null;
    13. //        try {
    14. //            entry = SphU.entry("t1");
    15. //        } catch (BlockException e) {
    16. //            return "被限流了";
    17. //        } catch (Exception e) {
    18. //            Tracer.traceEntry(e, entry);
    19. //        } finally {
    20. //            if (entry != null) {
    21. //                entry.exit();
    22. //            }
    23. //        }
    24. //        int a = 0 / 1;
    25. //        a = 1 / 0;
    26.         return "t1";
    27.     }
    28.  
    29.     @PostConstruct
    30.     private static void init() {
    31.         List rules = new ArrayList<>();
    32.         FlowRule rule = new FlowRule();
    33.         //接口名
    34.         rule.setResource("t1");
    35.         //限流策略
    36.         rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
    37.         rule.setCount(1);
    38.         rules.add(rule);
    39.         FlowRuleManager.loadRules(rules);
    40.     }

    Sentinel有一个网页界面，拿来查看具体数据：

    需要去官网相爱一个jar包，然后运行。并且在需要监听的心目中指定页面的端口

    java -jar sentinel-dashboard-1.8.0.jar --server.port=8002

    (dashboard: localhost:8002)：

    1. server:
    2.   port: 8011
    3. spring:
    4.   application:
    5.     name: stock1-server
    6.   cloud:
    7.     sentinel:
    8.       transport:
    9.         dashboard: localhost:8002
    10.     nacos:
    11.       server-addr: 192.168.126.1:8848
    12.       discovery:
    13.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    14.         group: TEST

    限流、降级方法的指定方式：

    1、直接在接口的同一个类里指定：参数名，返回值相同，多一个异常

    BlockException类

    1.     @GetMapping("getStock2/{id}")
    2.     @SentinelResource(value = "getStock2", blockHandler = "getStock2err")
    3.     public String getStock2(@PathVariable("id") long id) {
    4.         return "" + id;
    5.     }
    6.  
    7.     public String getStock2err(@PathVariable("id") Long id, BlockException e) {
    8.         return "限流操作";
    9.     }
     2、放在指定的类里面：
    1. public class test {
    2.     public static String t1cw(BlockException e) {
    3.         return "流控方法";
    4.     }
    5.  
    6.     public static String t1rz(Throwable e) {
    7.         return "发生错误方法";
    8.     }
    1.     /**
    2.      * blockHandlerClass 流控方法类
    3.      * blockHandler 流控方法名
    4.      * fallbackClass 降级（发生异常）方法类
    5.      * fallback 降级（发生异常）方法名
    6.      */
    7.     @GetMapping("/t2")
    8.     @SentinelResource(value = "t2", blockHandlerClass = test.class, blockHandler = "t1cw", fallback = "t1rz", fallbackClass = test.class)
    9.     public String t2() {
    10.         return "t2";
    11.     }

    将需要调用的方法放在其他类中，是有约定的，方法必须是static的，因为这个方法必须比接口对应的方法先加载到jvm中。

    3、全局管理：
    1. package com.stock1Server.ecception;
    2.  
    3. import com.alibaba.csp.sentinel.adapter.spring.webmvc.callback.BlockExceptionHandler;
    4. import com.alibaba.csp.sentinel.slots.block.BlockException;
    5. import com.alibaba.csp.sentinel.slots.block.authority.AuthorityException;
    6. import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;
    7. import com.alibaba.csp.sentinel.slots.block.flow.FlowException;
    8. import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowException;
    9. import com.alibaba.csp.sentinel.slots.system.SystemBlockException;
    10. import org.springframework.stereotype.Component;
    11.  
    12. import javax.servlet.http.HttpServletRequest;
    13. import javax.servlet.http.HttpServletResponse;
    14.  
    15. @Component
    16. public class MyBlockExceptionHandler implements BlockExceptionHandler {
    17.  
    18.     @Override
    19.     public void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, BlockException e) throws Exception {
    20.  
    21.         String rs = null;
    22.  
    23.         if (e instanceof FlowException)
    24.             rs = "接口限流了";
    25.         else if (e instanceof DegradeException)
    26.             rs = "服务降级了";
    27.         else if (e instanceof ParamFlowException)
    28.             rs = "参数限流了";
    29.         else if (e instanceof AuthorityException)
    30.             rs = "权限规则不通过";
    31.         else if (e instanceof SystemBlockException)
    32.             rs = "系统保护";
    33.  
    34.         httpServletResponse.setContentType("application/json;charset=utf-8");
    35.         httpServletResponse.getWriter().write(rs);
    36.  
    37.     }
    38. }

    流控规则介绍：

    直接：

    达到流控要求是，直接进行流控（执行流控方法）、

    关联：

    意识是不在为自己设置流控，而是为他人，只要他人达到流控约束条件，我就执行流控方法。

    链路模式不做介绍，用的太少了。

    流控效果

    快速失败就是达到流控时，直接调用流控方法
    warm up

    是预热模式，就是处理能力会越来越强，适合激增请求的场景。

    排队等待

    就是有心跳式的访问，一下子多，停一会，又一下子变多。中间有一定的等待时间，这一段时间就可以拿来让服务器处理。

     降级规则:

    慢调用比例

    最小5此请求，达到10%次执行时间超过1000毫秒，持续10秒开始执行降级方法，10秒后，若第一次执行时间超过1000毫米，又持续10秒开始执行降级方法（半开状态）直到新的一次调用小于1000毫秒。

    异常比例:

    最小5此请求，达到10%次异常，持续10秒开始执行降级方法，10秒后，若第一次执行时间超过1000毫米，又持续10秒开始执行降级方法（半开状态）直到新的一次调用小于1000毫秒。

    异常数：

    最小5此请求，达到1次异常，持续10秒开始执行降级方法，10秒后，若第一次执行时间超过1000毫米，又持续10秒开始执行降级方法（半开状态）直到新的一次调用小于1000毫秒。

    结合openfigen

    要在配置文件中开启sentinel和openfigen的使用

    1. feign:
    2.   sentinel:
    3.     enabled: true

    然后再提供方，调用方都加上：依赖，并且开启上面的两个框架的集成。

    热点规则使用：

    一句话：给方法参数的某个数据添加流控，例如：给id为1、2、3添加流控，1秒2次就开启流控。其他数据1秒5次开启流控。

    用sentinel页面这玩意看运气，我添加了一下午才成功这一次，用代码添加如下：

    1.   @PostConstruct
    2.     public static void initParamFlowRule() {
    3.         //使用这个方式，居然没有调用我指定的限流方法，待解决
    4.         List rules = new ArrayList<>();
    5.         ParamFlowRule rule = new ParamFlowRule();
    6.         //阈值类型：只支持QPS
    7.         rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
    8.         //其它参数调用次数
    9.         rule.setCount(10);
    10.         //接口名
    11.         rule.setResource("getStock2");
    12.         //第几个参数，0为第一个
    13.         rule.setParamIdx(0);
    14.         //约定时间
    15.         rule.setDurationInSec(1);
    16.  
    17.         List items = new ArrayList<>();
    18.  
    19.         ParamFlowItem item1 = new ParamFlowItem();
    20.         item1.setClassType(long.class.getName());
    21.         //超过约定时间访问参数
    22.         item1.setCount(2);
    23.         //具体参数值
    24.         item1.setObject("1");
    25.  
    26.         items.add(item1);
    27.         rule.setParamFlowItemList(items);
    28.         rules.add(rule);
    29.         ParamFlowRuleManager.loadRules(rules);
    30.     }

     持久化sentinel配置：

    就是将图形化界面的配置，用json的格式，挨个挨个配置到nacos的config中，我在想，高版本的sentinel应该会出现直接保存到nacos的mysql数据库中，然后直接快熟导入。

    1.            
    2.         
    3.             com.alibaba.csp
    4.             sentinel-datasource-nacos
    5.         
    6.         
    7.         
    8.             com.alibaba.cloud
    9.             spring-cloud-starter-alibaba-nacos-config
    10.

    一个是持久化依赖，一个是nacos配置中心的依赖，再配置中心手动加上配置：

    代码项目中使用：

    1. server:
    2.   port: 8011
    3. spring:
    4.   application:
    5.     name: stock1-server
    6.   cloud:
    7.     sentinel:
    8.       transport:
    9.         dashboard: localhost:8002
    10.       datasource:
    11.         flow-rule:
    12.           nacos:
    13.             server-addr: 192.168.126.1:8848
    14.             data-id: stock1-server-sentinel-config
    15.             ruleType: flow
    16.  
    17.     nacos:
    18.       server-addr: 192.168.126.1:8848
    19.       discovery:
    20.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    21.         group: TEST
    22. feign:
    23.   sentinel:
    24.     enabled: true

    seata分布式事务搭建：

    首先需要下载对应的steta版本，并且记得把源码版也下上，后面将配置导入nacos需要用：

    修改配置：

    file.con文件

    1.  
    2. ## transaction log store, only used in seata-server
    3. store {
    4.   ## store mode: file、db、redis
    5.   mode = "db"
    6.  
    7.   db {
    8.     datasource = "druid"
    9.     dbType = "mysql"
    10.     driverClassName = "com.mysql.cj.jdbc.Driver"
    11.     url = "jdbc:mysql://192.168.126.128:3306/seata?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true"
    12.     user = "root"
    13.     password = "123456"
    14.     minConn = 5
    15.     maxConn = 30
    16.     globalTable = "global_table"
    17.     branchTable = "branch_table"
    18.     lockTable = "lock_table"
    19.     queryLimit = 100
    20.     maxWait = 5000
    21.   }
    22.  
    23. }

    就是指定自己的mysql数据库地址，外加三张必须得表：

    源码文件的这里：

    然后是配置到nacos的文件：

    registry.conf

    1. registry {
    2.   # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
    3.   type = "nacos"
    4.  
    5.   nacos {
    6.     application = "seata-server"
    7.     serverAddr = "192.168.126.1:8848"
    8.     group = "SEATA_GROUP"
    9.     namespace = ""
    10.     cluster = "default"
    11.     username = "nacos"
    12.     password = "nacos"
    13.   }
    14.   file {
    15.     name = "file.conf"
    16.   }
    17. }
    18.  
    19. config {
    20.   # file、nacos 、apollo、zk、consul、etcd3
    21.   type = "nacos"
    22.  
    23.   nacos {
    24.     serverAddr = "192.168.126.1:8848"
    25.     namespace = ""
    26.     group = "SEATA_GROUP"
    27.     username = "nacos"
    28.     password = "nacos"
    29.   }
    30.  
    31.   file {
    32.     name = "file.conf"
    33.   }
    34. }

    就是指定nacos的地址，加载到nacos后seata的基本信息。

    导入配置到nacos中：

    既然是使用nacos的配置，就得把配置放进nacos配置源中，在seata的源码文件中，有快速将配置加载到nacos配置源中的方法：

    1. transport.type=TCP
    2. transport.server=NIO
    3. transport.heartbeat=true
    4. transport.enableClientBatchSendRequest=false
    5. transport.threadFactory.bossThreadPrefix=NettyBoss
    6. transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
    7. transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
    8. transport.threadFactory.shareBossWorker=false
    9. transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
    10. transport.threadFactory.clientSelectorThreadSize=1
    11. transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
    12. transport.threadFactory.bossThreadSize=1
    13. transport.threadFactory.workerThreadSize=default
    14. transport.shutdown.wait=3
    15. service.vgroupMapping.my_test_tx_group=default
    16. service.default.grouplist=127.0.0.1:8091
    17. service.enableDegrade=false
    18. service.disableGlobalTransaction=false
    19. client.rm.asyncCommitBufferLimit=10000
    20. client.rm.lock.retryInterval=10
    21. client.rm.lock.retryTimes=30
    22. client.rm.lock.retryPolicyBranchRollbackOnConflict=true
    23. client.rm.reportRetryCount=5
    24. client.rm.tableMetaCheckEnable=false
    25. client.rm.sqlParserType=druid
    26. client.rm.reportSuccessEnable=false
    27. client.rm.sagaBranchRegisterEnable=false
    28. client.tm.commitRetryCount=5
    29. client.tm.rollbackRetryCount=5
    30. client.tm.degradeCheck=false
    31. client.tm.degradeCheckAllowTimes=10
    32. client.tm.degradeCheckPeriod=2000
    33. store.mode=db
    34. store.file.dir=file_store/data
    35. store.file.maxBranchSessionSize=16384
    36. store.file.maxGlobalSessionSize=512
    37. store.file.fileWriteBufferCacheSize=16384
    38. store.file.flushDiskMode=async
    39. store.file.sessionReloadReadSize=100
    40. store.db.datasource=druid
    41. store.db.dbType=mysql
    42. store.db.driverClassName=com.mysql.cj.jdbc.Driver
    43. store.db.url=mysql://192.168.126.128:3306/seata?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
    44. store.db.user=root
    45. store.db.password=123456
    46. store.db.minConn=5
    47. store.db.maxConn=30
    48. store.db.globalTable=global_table
    49. store.db.branchTable=branch_table
    50. store.db.queryLimit=100
    51. store.db.lockTable=lock_table
    52. store.db.maxWait=5000
    53. store.redis.host=127.0.0.1
    54. store.redis.port=6379
    55. store.redis.maxConn=10
    56. store.redis.minConn=1
    57. store.redis.database=0
    58. store.redis.password=null
    59. store.redis.queryLimit=100
    60. server.recovery.committingRetryPeriod=1000
    61. server.recovery.asynCommittingRetryPeriod=1000
    62. server.recovery.rollbackingRetryPeriod=1000
    63. server.recovery.timeoutRetryPeriod=1000
    64. server.maxCommitRetryTimeout=-1
    65. server.maxRollbackRetryTimeout=-1
    66. server.rollbackRetryTimeoutUnlockEnable=false
    67. client.undo.dataValidation=true
    68. client.undo.logSerialization=jackson
    69. client.undo.onlyCareUpdateColumns=true
    70. server.undo.logSaveDays=7
    71. server.undo.logDeletePeriod=86400000
    72. client.undo.logTable=undo_log
    73. client.log.exceptionRate=100
    74. transport.serialization=seata
    75. transport.compressor=none
    76. metrics.enabled=false
    77. metrics.registryType=compact
    78. metrics.exporterList=prometheus
    79. metrics.exporterPrometheusPort=9898

    修改这几个地方：

    store.mode=db

    store.db.driverClassName=com.mysql.cj.jdbc.Driver
    store.db.url=mysql://192.168.126.128:3306/seata?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
    store.db.user=root
    store.db.password=123456

    和前面的file.con文件保持一致，唯一不同的就是这个store.db.url的连接方式，我用和file.con文件一样的，它就报错，连接不上后来差了资料，改了链接语句。

    然后必须有git软件在电脑上，它可以运行bash语句，也就是linux的。

    有python也可以。

    项目配置：

    然后在需要使用seata全局事务配置文件中，加上对seata的配置：

    1. server:
    2.   port: 8011
    3. spring:
    4.   application:
    5.     name: stock1-server
    6.   cloud:
    7.     sentinel:
    8.       transport:
    9.         dashboard: localhost:8002
    10.       datasource:
    11.         flow-rule:
    12.           nacos:
    13.             server-addr: 192.168.126.1:8848
    14.             data-id: stock1-server-sentinel-config
    15.             ruleType: flow
    16.  
    17.     nacos:
    18.       server-addr: 192.168.126.1:8848
    19.       discovery:
    20.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    21.         group: TEST
    22.     alibaba:
    23.       seata:
    24.         tx-service-group: my_test_tx_group #事务分组
    25.   datasource:
    26.     driver-class-name: com.mysql.cj.jdbc.Driver
    27.     type: com.alibaba.druid.pool.DruidDataSource
    28.     url: jdbc:mysql://192.168.126.128:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
    29.     username: root
    30.     password: 123456
    31. feign:
    32.   sentinel:
    33.     enabled: true
    34. mybatis-plus:
    35.   configuration:
    36.     map-underscore-to-camel-case: true
    37.     auto-mapping-behavior: full
    38.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    39. seata:
    40.   registry:
    41.     type: nacos
    42.     nacos:
    43.       server-addr: 192.168.126.1:8848 #nacos地址
    44.       application: seata-server #在nacos中的服务名
    45.       username: nacos  #nacos账号密码
    46.       password: nacos
    47.       group: SEATA_GROUP #在nacos中的分组名
    48.   config:
    49.     nacos:
    50.       server-addr: 192.168.126.1:8848

    添加这两个地方：

    seata分组是在上面config.txt中配置的：

    service.vgroupMapping.my_test_tx_group=default

    使用 :my_test_tx_group

    使用全局事务处理：

    1.     @GlobalTransactional
    2.     @GetMapping("getStock1/{code}")
    3.     @GlobalLock
    4.     @SentinelResource(value = "getStock1", fallback = "getStock1err")
    5.     public MsgTxt getStock1(@PathVariable("code") String code) {
    6.         MsgTxt print = stock1FeignClient.print(code, 14);//扣除数量
    7.         worktableService.updateByIdTest1();//保存单号
    8.         int a = 1 / 0;//发生异常
    9.         return print;
    10.     }

    扣除数量就是一个远程方法，扣除数据。

    然后本服务发生异常，就会通知seata回滚，本方法修改了的表也会回滚，seata现在使用的是AT管理，自动事务。

    当开启分布式事务时，调用sql方法，就会在seata的数据库中保留回滚的数据，如下：

    global_table表就是存放执行分布式方法时，进入全局方法，就会生产它，这个方法的全局信息。

    lock_table表是运行数据库操作后，生产一个表信息。操作一个表，增加一个信息。如下：

    我就执行了远程服务的方法，里面操作了两个表，seata就生成了两条数据：

    branch_table表存放的是涉及到了多少个服务。很明显我调用了两个服务，所以两条数据，并且保存各自的服务信息。

    undo_log表就是存放执行情况，只要是修改了的数据，都会保存在这，里面包含了修改前数据，修改后数据。

    1. 修改前数据：    
    2. "beforeImage": {
    3.                     "@class": "io.seata.rm.datasource.sql.struct.TableRecords",
    4.                     "tableName": "worktable",
    5.                     "rows": [
    6.                         "java.util.ArrayList",
    7.                         [
    8.                             {
    9.                                 "@class": "io.seata.rm.datasource.sql.struct.Row",
    10.                                 "fields": [
    11.                                     "java.util.ArrayList",
    12.                                     [
    13.                                         {
    14.                                             "@class": "io.seata.rm.datasource.sql.struct.Field",
    15.                                             "name": "i1",
    16.                                             "keyType": "PRIMARY_KEY",
    17.                                             "type": 4,
    18.                                             "value": 1
    19.                                         },
    20.                                         {
    21.                                             "@class": "io.seata.rm.datasource.sql.struct.Field",
    22.                                             "name": "i2",
    23.                                             "keyType": "NULL",
    24.                                             "type": 12,
    25.                                             "value": "123321"
    26.                                         }
    27.                                     ]
    28.                                 ]
    29.                             }
    30.                         ]
    31.                     ]
    32.                 }
    33. 修改后数据
    34. "afterImage": {
    35.                     "@class": "io.seata.rm.datasource.sql.struct.TableRecords",
    36.                     "tableName": "worktable",
    37.                     "rows": [
    38.                         "java.util.ArrayList",
    39.                         [
    40.                             {
    41.                                 "@class": "io.seata.rm.datasource.sql.struct.Row",
    42.                                 "fields": [
    43.                                     "java.util.ArrayList",
    44.                                     [
    45.                                         {
    46.                                             "@class": "io.seata.rm.datasource.sql.struct.Field",
    47.                                             "name": "i1",
    48.                                             "keyType": "PRIMARY_KEY",
    49.                                             "type": 4,
    50.                                             "value": 1
    51.                                         },
    52.                                         {
    53.                                             "@class": "io.seata.rm.datasource.sql.struct.Field",
    54.                                             "name": "i2",
    55.                                             "keyType": "NULL",
    56.                                             "type": 12,
    57.                                             "value": "20212904"
    58.                                         }
    59.                                     ]
    60.                                 ]
    61.                             }
    62.                         ]
    63.                     ]
    64.                 }

    保存的发生修改sql之前的数据，和修改之后的数据。如果发生异常，就根据这里保存的数据，执行反向sql回滚。

    还有另一个注解，分布式数据库锁：

    @GlobalLock

    一旦标识了这个，该方法在执行时，就回去获取锁，如果正好这条数据库数据还在分布式事务中，就会报错，不允许修改。读取不受限制。

    1. Creating a new SqlSession
    2. SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@55b12ac0] was not registered for synchronization because synchronization is not active
    3. 2024-03-09 16:18:42.997  WARN 2780 --- [nio-8011-exec-4] c.a.druid.pool.DruidAbstractDataSource   : discard long time none received connection. , jdbcUrl : jdbc:mysql://192.168.126.128:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC, version : 1.2.4, lastPacketReceivedIdleMillis : 433818
    4. JDBC Connection [io.seata.rm.datasource.ConnectionProxy@5b76de06] will not be managed by Spring
    5. ==>  Preparing: UPDATE user SET user_code=? WHERE (id = ?)
    6. ==> Parameters: 新数据(String), 14(Integer)
    7. <==    Updates: 1
    8. Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@55b12ac0]
    9. Creating a new SqlSession
    10. Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3e4aeaba]
    11. JDBC Connection [io.seata.rm.datasource.ConnectionProxy@3c86fa5a] will be managed by Spring
    12. ==>  Preparing: UPDATE worktable SET i2=? WHERE (i1 = ?)
    13. ==> Parameters: 多了一个表(String), 2(Integer)
    14. <==    Updates: 1
    15. Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3e4aeaba]
    16. Transaction synchronization committing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3e4aeaba]
    17. Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3e4aeaba]
    18. Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3e4aeaba]
    19. Creating a new SqlSession
    20. SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3c0e5228] was not registered for synchronization because synchronization is not active
    21. JDBC Connection [io.seata.rm.datasource.ConnectionProxy@7dbe36da] will not be managed by Spring
    22. ==>  Preparing: UPDATE user SET user_code=? WHERE (id = ?)
    23. ==> Parameters: er(String), 14(Integer)
    24. 2024-03-09 16:18:46.397 ERROR 2780 --- [nio-8011-exec-5] i.s.r.d.exec.AbstractDMLBaseExecutor     : execute executeAutoCommitTrue error:Global lock wait timeout
    25.  
    26. io.seata.rm.datasource.exec.LockWaitTimeoutException: Global lock wait timeout
    27. 	at io.seata.rm.datasource.exec.LockRetryController.sleep(LockRetryController.java:52) ~[seata-all-1.3.0.jar:1.3.0]
    28. 	at io.seata.rm.datasource.ConnectionProxy$LockRetryPolicy.doRetryOnLockConflict(ConnectionProxy.java:302) ~[seata-all-1.3.0.jar:1.3.0]
    29. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor$LockRetryPolicy.execute(AbstractDMLBaseExecutor.java:155) ~[seata-all-1.3.0.jar:1.3.0]
    30. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.executeAutoCommitTrue(AbstractDMLBaseExecutor.java:110) [seata-all-1.3.0.jar:1.3.0]
    31. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.doExecute(AbstractDMLBaseExecutor.java:74) [seata-all-1.3.0.jar:1.3.0]
    32. 	at io.seata.rm.datasource.exec.BaseTransactionalExecutor.execute(BaseTransactionalExecutor.java:115) [seata-all-1.3.0.jar:1.3.0]
    33. 	at io.seata.rm.datasource.exec.ExecuteTemplate.execute(ExecuteTemplate.java:113) [seata-all-1.3.0.jar:1.3.0]
    34. 	at io.seata.rm.datasource.exec.ExecuteTemplate.execute(ExecuteTemplate.java:51) [seata-all-1.3.0.jar:1.3.0]
    35. 	at io.seata.rm.datasource.PreparedStatementProxy.execute(PreparedStatementProxy.java:55) [seata-all-1.3.0.jar:1.3.0]
    36. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    37. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    38. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    39. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    40. 	at org.apache.ibatis.logging.jdbc.PreparedStatementLogger.invoke(PreparedStatementLogger.java:59) [mybatis-3.5.7.jar:3.5.7]
    41. 	at com.sun.proxy.$Proxy123.execute(Unknown Source) [na:na]
    42. 	at org.apache.ibatis.executor.statement.PreparedStatementHandler.update(PreparedStatementHandler.java:47) [mybatis-3.5.7.jar:3.5.7]
    43. 	at org.apache.ibatis.executor.statement.RoutingStatementHandler.update(RoutingStatementHandler.java:74) [mybatis-3.5.7.jar:3.5.7]
    44. 	at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:50) [mybatis-3.5.7.jar:3.5.7]
    45. 	at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:117) [mybatis-3.5.7.jar:3.5.7]
    46. 	at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:76) [mybatis-3.5.7.jar:3.5.7]
    47. 	at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:194) [mybatis-3.5.7.jar:3.5.7]
    48. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    49. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    50. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    51. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    52. 	at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427) [mybatis-spring-2.0.6.jar:2.0.6]
    53. 	at com.sun.proxy.$Proxy82.update(Unknown Source) [na:na]
    54. 	at org.mybatis.spring.SqlSessionTemplate.update(SqlSessionTemplate.java:288) [mybatis-spring-2.0.6.jar:2.0.6]
    55. 	at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:64) [mybatis-plus-core-3.4.3.jar:3.4.3]
    56. 	at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148) [mybatis-plus-core-3.4.3.jar:3.4.3]
    57. 	at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89) [mybatis-plus-core-3.4.3.jar:3.4.3]
    58. 	at com.sun.proxy.$Proxy83.update(Unknown Source) [na:na]
    59. 	at com.baomidou.mybatisplus.extension.service.IService.update(IService.java:167) [mybatis-plus-extension-3.4.3.jar:3.4.3]
    60. 	at com.baomidou.mybatisplus.extension.service.IService.update(IService.java:157) [mybatis-plus-extension-3.4.3.jar:3.4.3]
    61. 	at com.stock1Server.service.impl.UserServiceImpl.updateTest(UserServiceImpl.java:24) [classes/:na]
    62. 	at com.stock1Server.service.impl.UserServiceImpl$$FastClassBySpringCGLIB$$3e673818.invoke() [classes/:na]
    63. 	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) [spring-core-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    64. 	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    65. 	at com.stock1Server.service.impl.UserServiceImpl$$EnhancerBySpringCGLIB$$c2539cd9.updateTest() [classes/:na]
    66. 	at com.stock1Server.controller.stockController.t6(stockController.java:118) [classes/:na]
    67. 	at com.stock1Server.controller.stockController$$FastClassBySpringCGLIB$$ae77ee83.invoke() [classes/:na]
    68. 	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) [spring-core-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    69. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:779) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    70. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    71. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    72. 	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:95) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    73. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    74. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    75. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.lambda$handleGlobalLock$0(GlobalTransactionalInterceptor.java:134) [seata-all-1.3.0.jar:1.3.0]
    76. 	at io.seata.rm.GlobalLockTemplate.execute(GlobalLockTemplate.java:48) ~[seata-all-1.3.0.jar:1.3.0]
    77. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.handleGlobalLock(GlobalTransactionalInterceptor.java:132) [seata-all-1.3.0.jar:1.3.0]
    78. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.invoke(GlobalTransactionalInterceptor.java:124) [seata-all-1.3.0.jar:1.3.0]
    79. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    80. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    81. 	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:692) [spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    82. 	at com.stock1Server.controller.stockController$$EnhancerBySpringCGLIB$$e2df0638.t6() ~[classes/:na]
    83. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    84. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    85. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    86. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    87. 	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    88. 	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    89. 	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    90. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:878) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    91. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:792) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    92. 	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    93. 	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    94. 	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    95. 	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    96. 	at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    97. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:626) ~[tomcat-embed-core-9.0.46.jar:4.0.FR]
    98. 	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    99. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:733) ~[tomcat-embed-core-9.0.46.jar:4.0.FR]
    100. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    101. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    102. 	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.46.jar:9.0.46]
    103. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    104. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    105. 	at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    106. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    107. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    108. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    109. 	at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    110. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    111. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    112. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    113. 	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    114. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    115. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    116. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    117. 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    118. 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    119. 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:542) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    120. 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:143) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    121. 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    122. 	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    123. 	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:357) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    124. 	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:374) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    125. 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    126. 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    127. 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1707) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    128. 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    129. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_171]
    130. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_171]
    131. 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    132. 	at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_171]
    133. Caused by: io.seata.rm.datasource.exec.LockConflictException: null
    134. 	at io.seata.rm.datasource.ConnectionProxy.checkLock(ConnectionProxy.java:119) ~[seata-all-1.3.0.jar:1.3.0]
    135. 	at io.seata.rm.datasource.ConnectionProxy.processLocalCommitWithGlobalLocks(ConnectionProxy.java:205) ~[seata-all-1.3.0.jar:1.3.0]
    136. 	at io.seata.rm.datasource.ConnectionProxy.doCommit(ConnectionProxy.java:198) ~[seata-all-1.3.0.jar:1.3.0]
    137. 	at io.seata.rm.datasource.ConnectionProxy.lambda$commit$0(ConnectionProxy.java:184) ~[seata-all-1.3.0.jar:1.3.0]
    138. 	at io.seata.rm.datasource.ConnectionProxy$LockRetryPolicy.execute(ConnectionProxy.java:289) ~[seata-all-1.3.0.jar:1.3.0]
    139. 	at io.seata.rm.datasource.ConnectionProxy.commit(ConnectionProxy.java:183) ~[seata-all-1.3.0.jar:1.3.0]
    140. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.lambda$executeAutoCommitTrue$0(AbstractDMLBaseExecutor.java:112) [seata-all-1.3.0.jar:1.3.0]
    141. 	at io.seata.rm.datasource.ConnectionProxy$LockRetryPolicy.doRetryOnLockConflict(ConnectionProxy.java:299) ~[seata-all-1.3.0.jar:1.3.0]
    142. 	... 104 common frames omitted
    143.  
    144. Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@3c0e5228]
    145. 2024-03-09 16:18:46.466 ERROR 2780 --- [nio-8011-exec-5] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: 
    146. ### Error updating database.  Cause: io.seata.rm.datasource.exec.LockWaitTimeoutException: Global lock wait timeout
    147. ### The error may exist in com/stock1Server/mapper/UserMapper.java (best guess)
    148. ### The error may involve com.stock1Server.mapper.UserMapper.update-Inline
    149. ### The error occurred while setting parameters
    150. ### SQL: UPDATE user  SET user_code=?      WHERE (id = ?)
    151. ### Cause: io.seata.rm.datasource.exec.LockWaitTimeoutException: Global lock wait timeout
    152. ; Global lock wait timeout; nested exception is io.seata.rm.datasource.exec.LockWaitTimeoutException: Global lock wait timeout] with root cause
    153.  
    154. io.seata.rm.datasource.exec.LockConflictException: null
    155. 	at io.seata.rm.datasource.ConnectionProxy.checkLock(ConnectionProxy.java:119) ~[seata-all-1.3.0.jar:1.3.0]
    156. 	at io.seata.rm.datasource.ConnectionProxy.processLocalCommitWithGlobalLocks(ConnectionProxy.java:205) ~[seata-all-1.3.0.jar:1.3.0]
    157. 	at io.seata.rm.datasource.ConnectionProxy.doCommit(ConnectionProxy.java:198) ~[seata-all-1.3.0.jar:1.3.0]
    158. 	at io.seata.rm.datasource.ConnectionProxy.lambda$commit$0(ConnectionProxy.java:184) ~[seata-all-1.3.0.jar:1.3.0]
    159. 	at io.seata.rm.datasource.ConnectionProxy$LockRetryPolicy.execute(ConnectionProxy.java:289) ~[seata-all-1.3.0.jar:1.3.0]
    160. 	at io.seata.rm.datasource.ConnectionProxy.commit(ConnectionProxy.java:183) ~[seata-all-1.3.0.jar:1.3.0]
    161. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.lambda$executeAutoCommitTrue$0(AbstractDMLBaseExecutor.java:112) ~[seata-all-1.3.0.jar:1.3.0]
    162. 	at io.seata.rm.datasource.ConnectionProxy$LockRetryPolicy.doRetryOnLockConflict(ConnectionProxy.java:299) ~[seata-all-1.3.0.jar:1.3.0]
    163. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor$LockRetryPolicy.execute(AbstractDMLBaseExecutor.java:155) ~[seata-all-1.3.0.jar:1.3.0]
    164. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.executeAutoCommitTrue(AbstractDMLBaseExecutor.java:110) ~[seata-all-1.3.0.jar:1.3.0]
    165. 	at io.seata.rm.datasource.exec.AbstractDMLBaseExecutor.doExecute(AbstractDMLBaseExecutor.java:74) ~[seata-all-1.3.0.jar:1.3.0]
    166. 	at io.seata.rm.datasource.exec.BaseTransactionalExecutor.execute(BaseTransactionalExecutor.java:115) ~[seata-all-1.3.0.jar:1.3.0]
    167. 	at io.seata.rm.datasource.exec.ExecuteTemplate.execute(ExecuteTemplate.java:113) ~[seata-all-1.3.0.jar:1.3.0]
    168. 	at io.seata.rm.datasource.exec.ExecuteTemplate.execute(ExecuteTemplate.java:51) ~[seata-all-1.3.0.jar:1.3.0]
    169. 	at io.seata.rm.datasource.PreparedStatementProxy.execute(PreparedStatementProxy.java:55) ~[seata-all-1.3.0.jar:1.3.0]
    170. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    171. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    172. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    173. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    174. 	at org.apache.ibatis.logging.jdbc.PreparedStatementLogger.invoke(PreparedStatementLogger.java:59) ~[mybatis-3.5.7.jar:3.5.7]
    175. 	at com.sun.proxy.$Proxy123.execute(Unknown Source) ~[na:na]
    176. 	at org.apache.ibatis.executor.statement.PreparedStatementHandler.update(PreparedStatementHandler.java:47) ~[mybatis-3.5.7.jar:3.5.7]
    177. 	at org.apache.ibatis.executor.statement.RoutingStatementHandler.update(RoutingStatementHandler.java:74) ~[mybatis-3.5.7.jar:3.5.7]
    178. 	at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:50) ~[mybatis-3.5.7.jar:3.5.7]
    179. 	at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:117) ~[mybatis-3.5.7.jar:3.5.7]
    180. 	at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:76) ~[mybatis-3.5.7.jar:3.5.7]
    181. 	at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:194) ~[mybatis-3.5.7.jar:3.5.7]
    182. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    183. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    184. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    185. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    186. 	at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:427) ~[mybatis-spring-2.0.6.jar:2.0.6]
    187. 	at com.sun.proxy.$Proxy82.update(Unknown Source) ~[na:na]
    188. 	at org.mybatis.spring.SqlSessionTemplate.update(SqlSessionTemplate.java:288) ~[mybatis-spring-2.0.6.jar:2.0.6]
    189. 	at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:64) ~[mybatis-plus-core-3.4.3.jar:3.4.3]
    190. 	at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148) ~[mybatis-plus-core-3.4.3.jar:3.4.3]
    191. 	at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89) ~[mybatis-plus-core-3.4.3.jar:3.4.3]
    192. 	at com.sun.proxy.$Proxy83.update(Unknown Source) ~[na:na]
    193. 	at com.baomidou.mybatisplus.extension.service.IService.update(IService.java:167) ~[mybatis-plus-extension-3.4.3.jar:3.4.3]
    194. 	at com.baomidou.mybatisplus.extension.service.IService.update(IService.java:157) ~[mybatis-plus-extension-3.4.3.jar:3.4.3]
    195. 	at com.stock1Server.service.impl.UserServiceImpl.updateTest(UserServiceImpl.java:24) ~[classes/:na]
    196. 	at com.stock1Server.service.impl.UserServiceImpl$$FastClassBySpringCGLIB$$3e673818.invoke() ~[classes/:na]
    197. 	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    198. 	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    199. 	at com.stock1Server.service.impl.UserServiceImpl$$EnhancerBySpringCGLIB$$c2539cd9.updateTest() ~[classes/:na]
    200. 	at com.stock1Server.controller.stockController.t6(stockController.java:118) ~[classes/:na]
    201. 	at com.stock1Server.controller.stockController$$FastClassBySpringCGLIB$$ae77ee83.invoke() ~[classes/:na]
    202. 	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) ~[spring-core-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    203. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:779) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    204. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    205. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    206. 	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:95) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    207. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    208. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    209. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.lambda$handleGlobalLock$0(GlobalTransactionalInterceptor.java:134) ~[seata-all-1.3.0.jar:1.3.0]
    210. 	at io.seata.rm.GlobalLockTemplate.execute(GlobalLockTemplate.java:48) ~[seata-all-1.3.0.jar:1.3.0]
    211. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.handleGlobalLock(GlobalTransactionalInterceptor.java:132) ~[seata-all-1.3.0.jar:1.3.0]
    212. 	at io.seata.spring.annotation.GlobalTransactionalInterceptor.invoke(GlobalTransactionalInterceptor.java:124) ~[seata-all-1.3.0.jar:1.3.0]
    213. 	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    214. 	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    215. 	at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:692) ~[spring-aop-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    216. 	at com.stock1Server.controller.stockController$$EnhancerBySpringCGLIB$$e2df0638.t6() ~[classes/:na]
    217. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_171]
    218. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_171]
    219. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_171]
    220. 	at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_171]
    221. 	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    222. 	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    223. 	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:105) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    224. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:878) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    225. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:792) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    226. 	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    227. 	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1040) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    228. 	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:943) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    229. 	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    230. 	at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    231. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:626) ~[tomcat-embed-core-9.0.46.jar:4.0.FR]
    232. 	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    233. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:733) ~[tomcat-embed-core-9.0.46.jar:4.0.FR]
    234. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    235. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    236. 	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.46.jar:9.0.46]
    237. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    238. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    239. 	at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    240. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    241. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    242. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    243. 	at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    244. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    245. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    246. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    247. 	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    248. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119) ~[spring-web-5.2.15.RELEASE.jar:5.2.15.RELEASE]
    249. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    250. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    251. 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202) ~[tomcat-embed-core-9.0.46.jar:9.0.46]
    252. 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97) [tomcat-embed-core-9.0.46.jar:9.0.46]
    253. 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:542) [tomcat-embed-core-9.0.46.jar:9.0.46]
    254. 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:143) [tomcat-embed-core-9.0.46.jar:9.0.46]
    255. 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.46.jar:9.0.46]
    256. 	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78) [tomcat-embed-core-9.0.46.jar:9.0.46]
    257. 	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:357) [tomcat-embed-core-9.0.46.jar:9.0.46]
    258. 	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:374) [tomcat-embed-core-9.0.46.jar:9.0.46]
    259. 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) [tomcat-embed-core-9.0.46.jar:9.0.46]
    260. 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893) [tomcat-embed-core-9.0.46.jar:9.0.46]
    261. 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1707) [tomcat-embed-core-9.0.46.jar:9.0.46]
    262. 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.46.jar:9.0.46]
    263. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_171]
    264. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_171]
    265. 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.46.jar:9.0.46]
    266. 	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_171]
    267.

    gateway路由网关：

    1.         <dependency>
    2.             <groupId>org.springframework.cloudgroupId>
    3.             <artifactId>spring-cloud-starter-gatewayartifactId>
    4.         dependency>

    gateway是springcloud发出的，由于Netflix组件没有继续维护了，所以spring官方就开发了一个网关路由。

    使用起来也是很简单，直接在配置文件中配置：

    1. server:
    2.   port: 8080
    3. spring:
    4.   application:
    5.     name: gateway-server
    6.   cloud:
    7.     gateway:
    8.       routes:
    9.         - id: oder_route
    10.           uri: lb://order1-server
    11.           predicates:
    12.             - Path=/oder/**
    13.           filters:
    14.             - StripPrefix=1
    15.     nacos:
    16.       server-addr: 192.168.126.1:8848
    17.       discovery:
    18.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    19.         group: TEST

    Path=/oder/**是将路径前面加一个前缀，用于区分服务之间的路径。

    StripPrefix=1是切割掉上面的前缀

    lb://order1-server是指定这个配置代理的服务。

    也可以直接开启自动代理，直接用服务名取调用：

    1. server:
    2.   port: 8080
    3. spring:
    4.   application:
    5.     name: gateway-server
    6.   cloud:
    7.     gateway:
    8.       discovery:
    9.         locator:
    10.           enabled: true
    11.     nacos:
    12.       server-addr: 192.168.126.1:8848
    13.       discovery:
    14.         namespace: c1102e00-c947-4d0c-8320-b98dc7fae641
    15.         group: TEST

    localhost:8080/order1-server/order1/getOder2/10010

    order1-server就是服务名。

    gateway全局过滤器

    1. package com.gateway.config;
    2.  
    3. import lombok.extern.slf4j.Slf4j;
    4. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
    5. import org.springframework.cloud.gateway.filter.GlobalFilter;
    6. import org.springframework.stereotype.Component;
    7. import org.springframework.web.server.ServerWebExchange;
    8. import reactor.core.publisher.Mono;
    9.  
    10. /**
    11.  * @program: springCloudAlibaba
    12.  * @author: quxiao
    13.  * @create: 2024-03-11 21:04
    14.  **/
    15. @Component
    16. @Slf4j
    17. public class GatewayFilter implements GlobalFilter {
    18.     @Override
    19.     public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    20.         //输出访问路径
    21.         log.info(exchange.getRequest().getPath().value());
    22.         return chain.filter(exchange);
    23.     }
    24. }

    集合sentinen：

    1.         
    2.         
    3.             com.alibaba.cloud
    4.             spring-cloud-alibaba-sentinel-gateway
    5.         
    6.  
    7.         
    8.             com.alibaba.cloud
    9.             spring-cloud-starter-alibaba-sentinel
    10.

    另一个要注意的是，这个可以根据api分组来限流熔断：

    只定义返回消息：

    1. package com.gateway.config;
    2.  
    3. import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
    4. import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
    5. import org.springframework.context.annotation.Configuration;
    6. import org.springframework.http.HttpStatus;
    7. import org.springframework.http.MediaType;
    8. import org.springframework.web.reactive.function.BodyInserters;
    9. import org.springframework.web.reactive.function.server.ServerResponse;
    10.  
    11. import javax.annotation.PostConstruct;
    12.  
    13. @Configuration
    14. public class SentinelConfiguration {
    15.  
    16.     @PostConstruct
    17.     private void initBlockHandler() {
    18.         BlockRequestHandler blockRequestHandler = (exchange, t) ->
    19.                 ServerResponse.status(HttpStatus.TOO_MANY_REQUESTS)
    20.                         .contentType(MediaType.APPLICATION_JSON)
    21.                         .body(BodyInserters.fromValue("限流了")
    22.                         );
    23.         GatewayCallbackManager.setBlockHandler(blockRequestHandler);
    24.     }
    25.  
    26. }

    skywalking链路追踪

    ksysalking可以查看服务中的调用路径，可以清楚看清服务之间的依赖。

    需要下载ksysalking的服务启动包：

    链接: https://pan.baidu.com/s/1-icaoGf_CLY2PYF2D6lbEg

    提取码: xrix 复制这段内容后打开百度网盘手机App，操作更方便哦

    然后修改配置文件：

    修改一个端口：

    然后启动服务：

    然后在配置文件中配置依赖：

    1.         
    2.         <dependency>
    3.             <groupId>org.apache.skywalkinggroupId>
    4.             <artifactId>apm-toolkit-logback-1.xartifactId>
    5.             <version>${skywalking.version}version>
    6.         dependency>
    7.  
    8.         
    9.         <dependency>
    10.             <groupId>org.apache.skywalkinggroupId>
    11.             <artifactId>apm-toolkit-traceartifactId>
    12.             <version>${skywalking.version}version>
    13.         dependency>

    连接skywalking

    在运行之前，加上VM配置：

    1. -javaagent:D:\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar
    2. -DSW_AGENT_NAME=gateway-server
    3. -DSW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800

    是skywalking服务文件中的探针服务：

    -javaagent:D:\apache-skywalking-apm-bin-es7\agent\skywalking-agent.jar

    服务名称
    -DSW_AGENT_NAME=gateway-server

    ksysalking的服务端口号
    -DSW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800

    然后再代码中指定接口链路：

    1.     @Trace
    2.     @Tags(value = {
    3.             @Tag(key = "print", value = "returnedObj")
    4.             , @Tag(key = "print", value = "arg[0]")
    5.     })
    6.     public MsgTxt print(String txt, int id) {
    7.         boolean b = userService.updateTest(txt, id);
    8.         return new MsgTxt(txt, b);
    9.     }

        @Trace

    标识查看调用这个方法的链路

        @Tags(value = {
                @Tag(key = "print", value = "returnedObj")
                , @Tag(key = "print", value = "arg[0]")
        })

    print是方法名

    returnedObj标识在skywalking查看是显示方法的返回值：

    arg[0]标识第一个参数

    性能剖析

    点击接口的调用，然后分析，能看见哪一句代码耗时最长：

    集成logback日志：

    上面已经导入了jar包，之后需要配置logback-spring.xml日志输出格式：

    1. "1.0" encoding="UTF-8"?>
    3.  
    4.     
    5.     "FILE_LOG_PATTERN" value="[%d{yyyy-MM-dd HH:mm:ss.SSS}] %green(%-5level) [%thread] %yellow([%tid]) %cyan(%logger{50}) : %msg%n" />
    6.  
    7.     "STDOUT" class="ch.qos.logback.core.ConsoleAppender">
    8.         
    9.         
    10.         
    11.         "ch.qos.logback.core.encoder.LayoutWrappingEncoder">
    12.             "org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
    13.                 ${FILE_LOG_PATTERN}
    14.             
    15.         
    16.     
    17.     
    18.     "ASYNC_STDOUT" class="ch.qos.logback.classic.AsyncAppender">
    19.         0
    20.         256
    21.         "STDOUT"/>
    22.     
    23.  
    24.     
    25.     "GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
    26.         "ch.qos.logback.core.encoder.LayoutWrappingEncoder">
    27.             "org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
    28.                 ${FILE_LOG_PATTERN}
    29.             
    30.         
    31.     
    32.     "info">
    33.         "ASYNC_STDOUT"/>
    34.         "GRPC_LOG"/>
    35.     
    36.  
    37.     "info">
    38.         "ASYNC_STDOUT"/>
    39.     
    41.

    skywalking警告

    这几配置了一些调用约束，一旦达成，就会发出skywalking警告消息，基本上都是时间段内调用时间、失败次数等的约束，而且还是调用指定的回调函数，方便发生警告后，执行一些自定义的方法：

    1. package com.stock1Api.api;/*
    2.  * Licensed to the Apache Software Foundation (ASF) under one or more
    3.  * contributor license agreements.  See the NOTICE file distributed with
    4.  * this work for additional information regarding copyright ownership.
    5.  * The ASF licenses this file to You under the Apache License, Version 2.0
    6.  * (the "License"); you may not use this file except in compliance with
    7.  * the License.  You may obtain a copy of the License at
    8.  *
    9.  *     http://www.apache.org/licenses/LICENSE-2.0
    10.  *
    11.  * Unless required by applicable law or agreed to in writing, software
    12.  * distributed under the License is distributed on an "AS IS" BASIS,
    13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    14.  * See the License for the specific language governing permissions and
    15.  * limitations under the License.
    16.  *
    17.  */
    18.  
    19. import lombok.Getter;
    20. import lombok.Setter;
    21.  
    22. /**
    23.  * Alarm message represents the details of each alarm.
    24.  */
    25. @Setter
    26. @Getter
    27. public class AlarmMessage {
    28.     private int scopeId;
    29.     private String scope;
    30.     private String name;
    31.     private String id0;
    32.     private String id1;
    33.     private String ruleName;
    34.     private String alarmMessage;
    35.     private long startTime;
    36.     private transient boolean onlyAsCondition;
    37.  
    38.     @Override
    39.     public String toString() {
    40.         return "AlarmMessage{" +
    41.                 "scopeId=" + scopeId +
    42.                 ", scope='" + scope + '\'' +
    43.                 ", name='" + name + '\'' +
    44.                 ", id0='" + id0 + '\'' +
    45.                 ", id1='" + id1 + '\'' +
    46.                 ", ruleName='" + ruleName + '\'' +
    47.                 ", alarmMessage='" + alarmMessage + '\'' +
    48.                 ", startTime=" + startTime +
    49.                 ", onlyAsCondition=" + onlyAsCondition +
    50.                 '}';
    51.     }
    52. }
    1.     @PostMapping("/ksysalkingMessage")
    2.     public void ksysalkingMessage(@RequestBody List mesgs) {
    3.         log.info(mesgs.toString());
    4.     }

  • 相关阅读:
    JDK21来了！附重要更新说明
    Linux安装MongoDB（简单详细）
    JS 对象总结
    SpringBoot项目本机和Linux环境部署
    NPM配置阿里云（淘宝）镜像仓库
    理解编辑距离算法
    Day 48 MySQL
    什么是Mirai僵尸网络
    Java设计模式-结构型模式-适配器模式
    nginx负载均衡配置及常见负载均衡策略
  • 原文地址：https://blog.csdn.net/qx020814/article/details/136284929