主頁 > 後端開發 > springcloudalibaba入門

springcloudalibaba入門

2022-10-30 06:59:10 後端開發

1、父工程pom檔案

<?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>

    <modules>
        <module>order</module>
        <module>stock</module>
    </modules>

    <groupId>com.wanqi</groupId>
    <artifactId>springCloudAlibaba</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springCloudAlibaba</name>
    <description>springCloudAlibaba</description>
    <packaging>pom</packaging>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>2021.0.3</spring-cloud.version>
        <spring-cloud.alibaba.version>2021.1</spring-cloud.alibaba.version>
        <spring-cloud.alibaba.nacos.version>2021.1</spring-cloud.alibaba.nacos.version>
        <spring-boot.version>2.7.2</spring-boot.version>
        <spring-cloud.loadbalancer.version>3.1.3</spring-cloud.loadbalancer.version>

    </properties>


    <dependencyManagement>
        <dependencies>
            <!-- 考慮到企業可能有自己的父工程，spring-boot父工程參考改到dependencyManagement -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${spring-cloud.alibaba.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
                <version>${spring-cloud.alibaba.nacos.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!-- 高版本移除了Ribbon，改用loadbalancer -->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-loadbalancer</artifactId>
                <version>${spring-cloud.loadbalancer.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
                <version>${spring-cloud.alibaba.nacos.version}</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>

1.1、nacos服務本地部署啟動

1.1.1、github下載nacos服務
1.1.2、解壓后修改啟動檔案改為單機nacos/bin/startup.sh
解壓命令
tar -xvf nacos-server-2.1.0.tar.gz

# export MODE="cluster"
export MODE="standalone"
1.1.3、修改啟動埠nacos/conf/application.properties

image.png

1.1.4、啟動nacos通過nacos/bin/startup.sh
1.1.5、根據啟動提示找到日志nacos/logs/start.out
#看到一下提示表示啟動成功
INFO Nacos started successfully in stand alone mode. use embedded storage

image.png

1.1.6、找到日志中啟動logo的Console: http://192.168.110.57:8848/nacos/index.html使用瀏覽器打開，輸入默認用戶名密碼，均為：nacos

2、服務提供方pom檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springCloudAlibaba</artifactId>
        <groupId>com.wanqi</groupId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>stock</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
         <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    </dependencies>
</project>

2.1、application.yml組態檔

server:
  port: 8082
---
spring:
  cloud:
    nacos:
      server-addr: 39.105.101.111:12205
      discovery:
        ephemeral: true #是否臨時實體，false表示永久實體，掉線也不會消失
  application:
    name: stock-service

2.2、 撰寫測驗Controller

@RestController
@RequestMapping("/stock")
public class StockController {

    @Value("${server.port}")
    private String port;

    @RequestMapping("/add")
    public String add(){
        return "ok---" + port;
    }
}

3、 服務呼叫方pom檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springCloudAlibaba</artifactId>
        <groupId>com.wanqi</groupId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>order</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
         <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 高版本移除了Ribbon，改用loadbalancer -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
    </dependencies>

</project>

3.1、application.yml組態檔

server:
  port: 8081
spring:
  cloud:
    nacos:
      server-addr: 39.105.101.111:12205
      discovery:
        ephemeral: true #是否臨時實體，false表示永久實體，掉線也不會消失
  application:
    name: order-service

3.2、配置類，呼叫方注冊RestTemplate

@Configuration
public class AppConfig {
    @Bean
    @LoadBalanced //解決 java.net.UnknownHostException
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

3.3、controller使用RestTemplate

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/add")
    public String add(){
        return restTemplate.getForObject("http://stock-service/stock/add",String.class);
    }

}

4、Nacos集群部署，并使用nginx實作負載均衡

  • 虛擬機準備

image.png

  • mysql準備，安裝并創建nacos庫
  • nginx安裝

4.1、github下載nacos服務

4.1.1、解壓nacos并修改nacos/conf/application.properties檔案
  • 修改埠號，配置放開并修改資料庫相關資料
server.port=8849
#*************** Config Module Related Configurations ***************#
### If use MySQL as datasource:
spring.datasource.platform=mysql

### Count of DB:
db.num=1

### Connect URL of DB:
db.url.0=jdbc:mysql://39.105.101.111:3306/nacos?characterEncoding=utf-8&useSSL=true&serverTimezone=Asia/Shanghai
db.user.0=wq
db.password.0=123456

4.2、資料庫表相關sql，nacos/conf/nacos-mysql.sql

4.3、修改啟動腳本nacos/bin/startup.sh

    # *根據服務器實際記憶體情況酌情修改*
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
    #JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
    JAVA_OPT="${JAVA_OPT} -XX:-OmitStackTraceInFastThrow -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=${BASE_DIR}/logs/java_heapdump.hprof"
    JAVA_OPT="${JAVA_OPT} -XX:-UseLargePages"
     # *新增以下引數設定本機ip地址，云服務器如果不修改會默認多一個使用網卡ip注冊的節點*
    JAVA_OPT="${JAVA_OPT} -Dnacos.server.ip=114.67.111.165"

4.5、在nacos/conf下新建cluster.conf檔案配置集群

  • 一臺機器模擬埠最好分散一點不容易翻車，多臺的話默認8848即可
#單臺機器模擬
114.67.111.165:8849
114.67.111.165:8851
114.67.111.165:8853
#多臺虛擬機
172.16.156.134:8848
172.16.156.135:8848
172.16.156.136:8848

4.5、啟動并驗證是否成功參考單機模式

4.6、啟動成功后把這個nacos再復制2個修改埠然后啟動即可

4.7、nginx配置新增在http下

    upstream  nacosServer{
      #nacos集群ip與埠
         server 114.67.111.165:8849;
         server 114.67.111.165:8851;
         server 114.67.111.165:8853;
    }
    server {
      #監聽埠
       listen       12205;
        #nginx服務器ip
       server_name  39.105.101.111;
       location /nacos{
            proxy_pass http://nacosServer/nacos;
       }
    # 靜態資源處理
    location ~ .* {
                proxy_pass      http://nacosServer;
                proxy_set_header Host $http_host;
                proxy_set_header X-Real-IP $remote_addr;
                proxy_set_header X-Fonwarded-For $proxy_add_x_forwarded_for;
         }

    }

4.8、訪問nginx配置的監聽埠與請求

http://39.105.101.111:12205/nacos

image.png

5、集成openfeign

5.1、服務呼叫方匯入依賴

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>       
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>

5.2、使用示例

5.2.1、服務提供方Controller
@RestController
public class StockController {
    @Autowired
    StockMapper stockMapper;

    @PostMapping("/add")
    public int add(@RequestParam("orderId") Long id) {
        Stock select = stockMapper.select();
       
        int x =  stockMapper.update(id);
        System.out.println(select);
        return x;
    }

    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql){
        MyTest test = new MyTest(sqlId,sql);
        System.out.println(test);
        return test.toString();
    }

}
5.2.2、呼叫方Feign介面
/**
 * name 指定呼叫服務提供方介面所對應的服務名
 * path 指定呼叫介面所在StockController指定的@RequestMapping("/stock")，如果沒有則不需要
 * contextId 多個feign介面使用@FeignClient注解呼叫同一個名稱的微服務時增加contextId屬性，
 * 確保每個feignclient的contextId唯一
 */
@FeignClient(name = "stock-db",contextId = "stock-db")
public interface StockFeignService {
    
    @PostMapping("/add")
    public int add(@RequestParam("orderId") Long orderId);

    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql);
5.2.3、使用@EnableFeignClients開啟Feign
@SpringBootApplication
@EnableDiscoveryClient //高版本可省略
@EnableFeignClients
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class);
    }
}
5.2.4、呼叫方service
@RestController
public class OrderController {

    @Autowired
    StockFeignService stockFeignService;


    @GetMapping("add2/{orderId}")
    public int add2(@PathVariable("orderId") Long orderId) {
        return stockFeignService.add(orderId);
    }


    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql){
        MyTest test = new MyTest(sqlId,sql);
        String msg = stockFeignService.genSqlFile(test.getSqlId(),test.getSql());
        System.out.println(msg + "呼叫成功啦！！！");
        return msg;
    }
}

5.5、openfeign日志配置示例

5.5.1、使用組態檔
feign:
  client:
    config:
      # 全域使用default，指定feign默認使用feignName，如果配置了contextId必須使用contextId
      stock: #@FeignClient(name = "stock-service",path = "/stock",contextId = "stock")
        # 連接超時時間，默認2s
        connectTimeout: 5000
        # 請求處理超時時間，默認5秒
        readTimeout: 3000
        # 指定feign攔截器
        requestInterceptors[0]: com.wanqi.interceptor.FeignInterceptor
        # 指定日志級別，需要開啟spring日志
        loggerLevel: BASIC
# 開啟Spring日志        
logging:
  level:
    com.wanqi.feign: debug  #指定feign包的日志級別為debug
5.5.2、使用注解
  • 全域配置直接使用@Configuration
/**
 * 全域配置直接使用 @Configuration
 * 區域配置配合@FeignClient使用：configuration = FeignConfig.class
 */
@Configuration
public class FeignConfig {
    /**
     * NONE【性能最佳，適用于生產】：不記錄任何日志（默認值）
     * BASIC【適用于生產環境追蹤問題】：僅記錄請求方法、URL、回應狀態代碼以及執行時間，
     * HEADERS：記錄BASIC級別的基礎上，記錄請求和回應的neader，
     * FULL【比較適用于開發及測驗環境定位問題】：記錄請求和回應的header、body和元資料，
     */
    @Bean
    public Logger.Level feignLoggerLevel(){
        return Logger.Level.FULL;
    }
}
  • 區域配置，去掉FeignConfig配置類上的@Configuration注解，在需要指定的FeignClient屬性上加上configuration = FeignConfig.class（FeignConfig配置類不要加@Configuration注解，否則這將是一個全域配置），
/**
 * name 指定呼叫rest介面所對應的服務名
 * path 指定呼叫介面所在StockController指定的@RequestMapping("/stock")
 * contextId 多個feign介面使用@FeignClient注解呼叫同一個名稱的微服務時增加contextId屬性，
 * 確保每個feignclient的contextId唯一
 * configuration 引入配置類
 */
@FeignClient(name = "stock-service",path = "/stock"
        ,contextId = "stock"
        ,configuration = FeignConfig.class
)
public interface StockFeignService {
    // 介面方法對應呼叫服務的方法，即對應服務Controller里面的方法名和引數一一對應
    @RequestMapping("/add2")
    String add2();

  /*  @RestController
    @RequestMapping("/stock")
    public class StockController {

        @Value("${server.port}")
        private String port;

        @RequestMapping("/add2")
        public String add2(){
            System.out.println("add2");
            return "add2---" + port;
        }
    */
}

5.6、feign自定義攔截器，實作RequestInterceptor介面重寫apply方法,注冊bean

  • 自定義攔截器
public class FeignInterceptor implements RequestInterceptor {
    Logger logger = LoggerFactory.getLogger(this.getClass());
    @Override
    public void apply(RequestTemplate requestTemplate) {
        logger.info("--------------FeignInterceptor---------------" + requestTemplate.path());
        logger.info("--------------FeignInterceptor---------------" + requestTemplate.request().url());
        logger.info("--------------FeignInterceptor---------------" + requestTemplate.url());

    }
}
  • 配置類@Bean注冊，或者直接在自定義攔截器上加上@Component注解（全域配置）
/**
* 自定義攔截器
*/
@Bean
public FeignInterceptor feignInterceptor(){
    return new FeignInterceptor();
    }
  • application.yml組態檔注冊（可以指定具體FeignClient）
feign:
  client:
    config:
      # 全域使用default，指定feign默認使用feignName，如果配置了contextId必須使用contextId
      stock: #@FeignClient(name = "stock-service",path = "/stock",contextId = "stock")
        # 指定feign攔截器
        requestInterceptors[0]: com.wanqi.interceptor.FeignInterceptor
  • 使用FeignClient屬性configuration配置（可以指定具體FeignClient）
/**
 * name 指定呼叫rest介面所對應的服務名
 * path 指定呼叫介面所在StockController指定的@RequestMapping("/stock")
 * contextId 多個feign介面使用@FeignClient注解呼叫同一個名稱的微服務時增加contextId屬性，
 * 確保每個feignclient的contextId唯一
 * configuration 引入配置類
 */
@FeignClient(name = "stock-service",path = "/stock"
        ,contextId = "stock"
        ,configuration = {FeignConfig.class, FeignInterceptor.class}
)
public interface StockFeignService {
    // 介面方法對應呼叫服務的方法，即對應服務Controller里面的方法名和引數一一對應
    @RequestMapping("/add2")
    String add2();

  /*  @RestController
    @RequestMapping("/stock")
    public class StockController {

        @Value("${server.port}")
        private String port;

        @RequestMapping("/add2")
        public String add2(){
            System.out.println("add2");
            return "add2---" + port;
        }
    */
}

5.7、feign超時時間配置

  • 配置類的方式
   /**
     * 超時時間配置
     */
    @Bean
    public Request.Options options(){
        return new Request.Options(5, TimeUnit.SECONDS,10,TimeUnit.SECONDS,true);
    }
  • application.yml組態檔
feign:
  client:
    config:
      # 全域使用default，指定feign默認使用feignName，如果配置了contextId必須使用contextId
      product:
        # 連接超時時間，默認2s
        connectTimeout: 5000
        # 請求處理超時時間，默認5秒
        readTimeout: 3000

6、Nacos-config配置使用

  • 建議所有組態檔的名字即data-id都加上檔案擴展名如：test.properties，test.yml等

6.1、pom檔案匯入依賴

         <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <!--   新版nacos-config要使用bootstrap.yml必須引入     -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
        </dependency>

6.2、撰寫bootstrap.yml檔案

6.2.1、推薦模式根據namespace來控制不同環境的配置
spring:
  cloud:
    nacos:
      config:
        server-addr: 172.16.156.137:8847
        # 指定命名空間,不明確配置的話，默認是public
        namespace: dev
        # 指定檔案名即配置的Data ID
        name: com.wanqi.config-mac.yml
        username: nacos
        password: nacos
        # 組態檔型別
        file-extension: yml
6.2.2、支持profile粒度的配置
組態檔名com.wanqi.config-mac.yml，必須顯示的指定檔案格式
profile粒度的配置dataid即檔案名格式：${spring.application.name}-${profile}.${file-extension:properties}
${spring.application.name}對應：com.wanqi.config，屬性名spring.cloud.nacos.config.name
${profile}對應：mac，屬性名springprofiles.active
${file-extension:properties}對應：yml，屬性名spring.cloud.nacos.config.file-extension

spring:
  cloud:
    nacos:
      config:
        server-addr: 172.16.156.137:8847
        # 指定命名空間,不明確配置的話，默認是public
        namespace: dev
        #組態檔名即Data ID為com.wanqi.config-mac.yml
        # 指定檔案名${spring.application.name}=com.wanqi.config
        name: com.wanqi.config
        username: nacos
        password: nacos
        # 組態檔型別${file-extension:properties}=yml
        file-extension: yml
  # profile粒度${profile}=mac
  profiles:
    active: mac
6.2.3、多配置、共享配置bootstrap.yml
spring:
  cloud:
    nacos:
      config:
        server-addr: 172.16.156.137:8847
        # 指定命名空間,不明確配置的話，默認是public
        namespace: test
        # 指定檔案名 
#        name: com.wanqi.config
        username: nacos
        password: nacos
        # 組態檔型別
        file-extension: yml
#        shared-configs[0]:
#          data-id: test.properties
#          refresh: true
#        shared-configs[1]:
#          data-id: test01.properties
#          refresh: true
        shared-configs:
          - data-id: test.properties
#            不明確配置的話，默認是 DEFAULT_GROUP，
#            group: DEFAULT_GROUP
          # refresh是否支持應用中可動態重繪， 感知到最新的配置值，默認是不支持的，
            refresh: true
#          - data-id: test01.properties
#           refresh: true
        extension-configs:
          - data-id: test01.properties
            refresh: true

6.3、使用

6.3.1、硬編碼
@SpringBootApplication
public class NacosConfigApplication {
    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(NacosConfigApplication.class, args);
        String name = context.getEnvironment().getProperty("wq.name");
        System.out.println(name);
    }
}
6.3.2、注解@RefreshScope和 @Value
@Controller
@RefreshScope
public class NacosController {

    @Value("${wq.name}")
    private String name;
    @Value("${wq.age}")
    private int age;
    @Value("${wq.msg}")
    private String msg;

    @ResponseBody
    @RequestMapping("nacos")
    public String nacos(){
        return name + msg;
    }
}

6.4、配置的優先級

Spring Cloud Alibaba Nacos Config 目前提供了三種配置能力從 Nacos 拉取相關的配置，
A: 通過 spring.cloud.nacos.config.shared-configs[n].data-id 支持多個共享 Data Id 的配置
B: 通過 spring.cloud.nacos.config.extension-configs[n].data-id 的方式支持多個擴展 Data Id 的配置
C: 通過內部相關規則(應用名、應用名+ Profile )自動生成相關的 Data Id 配置
當三種方式共同使用時，他們的一個優先級關系是:A < B < C

  • 多個 Data Id 同時配置時，他的優先級關系是 spring.cloud.nacos.config.extension-configs[n].data-id 其中 n 的值越大，優先級越高，

7、sentinel集成

7.1、普通spring boot專案使用sentinel

7.1.1、引入依賴
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--   sentinel核心庫     -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-core</artifactId>
            <version>1.8.4</version>
        </dependency>
        <!--   sentinel注解支持     -->
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-annotation-aspectj</artifactId>
            <version>1.8.4</version>
        </dependency>
        <!--   spring aop配合sentinel注解支持     -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
7.1.2、定義規則可使用@PostConstruct注解
    private static final String SENTINEL = "sentinel";
    private static final String HELLO = "hello";
    private static final String QIFENG = "qifeng";

    @PostConstruct
    private void initFlowRules(){
        List<FlowRule> rules = new ArrayList<>();
        FlowRule rule = new FlowRule();
        //流控的資源
        rule.setResource(SENTINEL);
        //流控規則為QPS
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        // 設定QPS
        rule.setCount(1);
        rules.add(rule);

        rule = new FlowRule();
        //流控的資源
        rule.setResource(HELLO);
        //流控規則為QPS
        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
        // 設定QPS
        rule.setCount(1);
        rules.add(rule);
        FlowRuleManager.loadRules(rules);
        initDegradeRule();
    }
    private void initDegradeRule() {
        List<DegradeRule> rules = new ArrayList<>();
        DegradeRule rule = new DegradeRule();
        rule.setResource(HELLO);
        //設定規則，熔斷策略，支持慢呼叫比例/例外比例/例外數策略
        rule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_COUNT);
        // 熔斷時長，單位為 s, 10 ms
        rule.setTimeWindow(10);
        //熔斷觸發的最小請求數，請求數小于該值時即使例外比率超出閾值也不會熔斷
        rule.setMinRequestAmount(2);
        //統計時長（單位為 ms），如 60*1000 代表分鐘級
        rule.setStatIntervalMs(60*1000);
        //慢呼叫比例模式下為慢呼叫臨界 RT（超出該值計為慢呼叫）；例外比例/例外數模式下為對應的閾值
        rule.setCount(2);
        rules.add(rule);
        DegradeRuleManager.loadRules(rules);
    }
7.1.3、定義資源
7.1.3.1、拋出例外的方式定義資源
    //拋出例外的方式定義資源
    @GetMapping("sentinel")
    @ResponseBody
    public String helloSentinel(){
        try (Entry entry = SphU.entry(SENTINEL)) {
            // 被保護的邏輯
            return "hello sentinel";
        } catch (BlockException ex) {
            // 處理被流控的邏輯
            return "請求被流控啦！！！！";
        }

    }
7.1.3.2、注解方式定義資源
 //注解方式定義資源
    // 原函式
    @GetMapping("qifeng/{age}")
    @ResponseBody
    @SentinelResource(value = https://www.cnblogs.com/wandaren/archive/2022/10/29/QIFENG, blockHandler ="exceptionHandler", fallback = "helloFallback")
    public QiFeng qifeng(@PathVariable("age") int age) {
        return new QiFeng("齊豐",age);
    }

    // Fallback 函式,例外處理，函式簽名與原函式一致或加一個 Throwable 型別的引數.
    public QiFeng helloFallback(int age,Throwable throwable) {
        throwable.printStackTrace();
        return new QiFeng("例外啦！！！！", age);
    }


    // Block 例外處理函式，引數最后多一個 BlockException，其余與原函式一致.
    public QiFeng exceptionHandler(int age, BlockException ex) {
        // Do some log here.
        ex.printStackTrace();
        return new QiFeng("請求被流控啦！！！",age);
    }


    //注解方式定義資源
    @GetMapping("hello")
    @ResponseBody
    @SentinelResource(value = https://www.cnblogs.com/wandaren/archive/2022/10/29/HELLO,blockHandler ="hellBlockHandler")
    public String hell(String name){
        int x = 1/0;
        return "hello DegradeRule!!!";
    }

    // Block 例外處理函式，引數最后多一個 BlockException，其余與原函式一致.
    public String hellBlockHandler(String name, BlockException ex) {
        // Do some log here.
        ex.printStackTrace();
        return "熔斷降級啦！！！！";
    }
7.1.3.3、注解需要將SentinelResourceAspect注冊一個為Spring Bean
    @Bean
    public SentinelResourceAspect sentinelResourceAspect() {
        return new SentinelResourceAspect();
    }
  • 更多規則定義參考官方檔案

7.2、Spring Cloud整合控制臺sentinel、nacos、openfeign

  • 官方檔案
7.2.1、下載控制臺jar包并啟動
java -Dserver.port=8080 -jar sentinel-dashboard.jar
7.2.2、引入依賴
 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 解決 java.net.UnknownHostException -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
7.2.3、yaml配置
server:
  port: 7779
spring:
  main:
    allow-circular-references: true
  cloud:
    sentinel:
      transport:
        # sentinel控制臺地址
        dashboard: 172.16.156.139:9999
        port: 8720
      web-context-unify: false # 關閉默認呼叫鏈路收斂
      # sentinel持久化配置
      datasource:
        flowrule: #可以自定義
         nacos:
          serverAddr: 172.16.156.139:8847
          username: nacos
          password: nacos
          groupId: SENTINEL_GROUP
          # nacos上組態檔的dataId
          dataId: order-feign-sentinel-win-flowrule
          # 規則分類
          RuleType: flow
    nacos:
      server-addr: 172.16.156.139:8847
      discovery:
        ephemeral: true #是否臨時實體，false表示永久實體，掉線也不會消失
      username: nacos
      password: nacos
  application:
    name: order-feign-sentinel
---
feign:
  client:
    config:
      # 全域使用default，指定feign默認使用feignName，如果配置了contextId必須使用contextId
      stock:
        # 連接超時時間，默認2s
        connectTimeout: 5000
        # 請求處理超時時間，默認5秒
        readTimeout: 3000
        # 指定feign攔截器
#        requestInterceptors[0]: com.wanqi.interceptor.FeignInterceptor
        loggerLevel: Full
  sentinel:
  # 打開 Sentinel 對 Feign 的支持
    enabled: true

---
logging:
  level:
    com.wanqi.feign: debug
---
7.2.4、示例代碼
7.2.4.1、feign介面配置與回呼
public class FeignConfig {
    @Bean
    public StockFeignServiceFallback stockFeignServiceImpl(){
        return new StockFeignServiceFallback();
    }
}


/**
* name 指定呼叫rest介面所對應的服務名
* path 指定呼叫介面所在StockController類上指定的@RequestMapping("/stock")
* contextId 多個feign介面使用@FeignClient注解呼叫同一個名稱的微服務時增加contextId屬性，
* 確保每個feignclient的contextId唯一
* configuration 引入配置類
*/
@FeignClient(name = "stock-service", path = "/stock"
             , contextId = "stock"
             , fallback = StockFeignServiceFallback.class
             , configuration = {FeignConfig.class}
            )
    public interface StockFeignService {

        @RequestMapping("/test1")
        String test1();
        @RequestMapping("/test2")
        String test2();
        @RequestMapping("/get/{id}")
        public String getById(@PathVariable("id") int id);
    }

public class StockFeignServiceFallback implements StockFeignService{
    @Override
    public String test1() {
        return "test1熔斷降級啦！！！！";
    }

    @Override
    public String test2() {
        return "test2熔斷降級啦！！！！";
    }

    @Override
    public String getById(int id) {
        return "介面例外熔斷降級啦！！！！";
    }
}
7.2.4.2、controller層
@RestController
public class OrderController {
    @Autowired
    private StockFeignService stockFeignService;

    @GetMapping("/test1")
    public String test1(){
        return stockFeignService.test1();
    }

    @GetMapping("/test2")
    public String test2(){
        return stockFeignService.test2();
    }

    /**
     * 熱點引數流控須要使用Sentinel
     * @param id
     * @return
     */
    @RequestMapping("/get/{id}")
    @SentinelResource(value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/getById",blockHandler = "getByIdBlockHandler")
    public String getById(@PathVariable("id") int id){
        return stockFeignService.getById(id);
    }

    public String getByIdBlockHandler(int id, BlockException e){
        return "getByIdBlockHandler--熱點例外處理" + id;
    }

}
7.2.4.3、啟動類
@SpringBootApplication
// 開啟nacos
@EnableDiscoveryClient
// 開啟feign
@EnableFeignClients
public class OrderFeignSentinelApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderFeignSentinelApplication.class,args);
    }
}
7.2.4.4、nacos實作動態規則配置

image.png

7.2.4.4.1、yaml配置增加
spring:
  cloud:
    sentinel:
      datasource:
        flowrule: #可以自定義
          nacos:
            serverAddr: 172.16.156.139:8847
            username: nacos
            password: nacos
            groupId: SENTINEL_GROUP
            dataId: order-feign-sentinel-win-flowrule
            RuleType: flow

    @GetMapping("/sentinel/nacos")
    @SentinelResource(value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/sentinelNacos",blockHandler = "sentinelNacosBlockHandler"
            , fallback ="sentinelNacosFallback")
    public String sentinelNacos(){
        return "sentinelNacos正常回傳！！！";
    }

    // Fallback 函式,例外處理，函式簽名與原函式一致或加一個 Throwable 型別的引數.
    public String sentinelNacosFallback(Throwable throwable) {
        return "Fallback: "+ throwable.getMessage();
    }

    // Block 例外處理函式，引數最后多一個 BlockException，其余與原函式一致.
    public String sentinelNacosBlockHandler(BlockException ex) {
        // Do some log here.
        return "BlockHandler: "+ ex.getMessage();

    }

8、Spring Cloud Gateway

  • 可以使用nginx實作負載均衡

8.1、引入依賴

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!--spring cloud gateway-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

        <!--    spring cloud gateway整合sentinel的依賴-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
        </dependency>
        <!--    sentinel的依賴-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 解決 java.net.UnknownHostException -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>

8.2、yaml配置

server:
  port: 9527
spring:
  application:
    name: api-gateway
  cloud:
    ## 整合sentinel，配置sentinel控制臺的地址
    sentinel:
      transport:
        ## 指定控制臺的地址，默認埠8080
        dashboard: 172.16.156.139:9999
        port: 8722
    nacos:
      ## 注冊中心配置
      discovery:
        # nacos的服務地址，nacos-server中IP地址:埠號
        server-addr: 172.16.156.139:8847
        username: nacos
        password: nacos
    gateway:
      ## 路由
      routes:
        ## id只要唯一即可，名稱任意
        - id: gateway-provider
          # 需要轉發的地址
          #lb://service-name
          #lb：uri 的協議，表示開啟 Spring Cloud Gateway 的負載均衡功能，
          #service-name：服務名，Spring Cloud Gateway 會根據它獲取到具體的微服務地址，
          uri: lb://stock-service
          ## 配置斷言
          predicates:
            # Path Route Predicate Factory斷言，滿足/stock-service/**這個請求路徑的都會被路由到stock-service這個服務中
            # 自定義前綴避免介面重復 
            - Path=/stock-service/**
            # 過濾器，轉發之前過濾掉第一層路徑即stock-service/
            # http://localhost:9527/stock-service/stock/get/1 轉發到stock-service服務上，http://stock-service/stock/get/1
          filters:
            - StripPrefix=1

8.3、訪問http://localhost:9527/stock-service/stock/get/1會自動路由到stock-service服務上

image.png
image.pngimage.png

8.4、自定義全域流控例外

@Configuration
public class GatewayConfig {

    @PostConstruct
    public void init(){
        BlockRequestHandler blockRequestHandler = new BlockRequestHandler() {
            @Override
            public Mono<ServerResponse> handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {
                Map<String,Object> map = new HashMap<>();
                map.put("code", HttpStatus.TOO_MANY_REQUESTS.value());
                map.put("msg", "請求太多，限流了");
                return ServerResponse.status(HttpStatus.OK)
                        .contentType(MediaType.APPLICATION_JSON)
                        .bodyValue(map);
            }
        };
        GatewayCallbackManager.setBlockHandler(blockRequestHandler);
    }
}

9、seata使用

9.1、部署steata服務并啟動

9.1.1、資料庫準備
  • 資源地址
  • client

存放client端sql腳本 (包含 undo_log表) ，引數配置

  • config-center

各個配置中心引數匯入腳本，config.txt(包含server和client，原名nacos-config.txt)為通用引數檔案

  • server

server端資料庫腳本 (包含 lock_table、branch_table 與 global_table) 及各個容器配置

9.1.2、下載seata服務
9.1.3、執行sql腳本seata/script/server/db/mysql.sql
-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `global_table`
(
    `xid`                       VARCHAR(128) NOT NULL,
    `transaction_id`            BIGINT,
    `status`                    TINYINT      NOT NULL,
    `application_id`            VARCHAR(32),
    `transaction_service_group` VARCHAR(32),
    `transaction_name`          VARCHAR(128),
    `timeout`                   INT,
    `begin_time`                BIGINT,
    `application_data`          VARCHAR(2000),
    `gmt_create`                DATETIME,
    `gmt_modified`              DATETIME,
    PRIMARY KEY (`xid`),
    KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),
    KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(
    `branch_id`         BIGINT       NOT NULL,
    `xid`               VARCHAR(128) NOT NULL,
    `transaction_id`    BIGINT,
    `resource_group_id` VARCHAR(32),
    `resource_id`       VARCHAR(256),
    `branch_type`       VARCHAR(8),
    `status`            TINYINT,
    `client_id`         VARCHAR(64),
    `application_data`  VARCHAR(2000),
    `gmt_create`        DATETIME(6),
    `gmt_modified`      DATETIME(6),
    PRIMARY KEY (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
    `row_key`        VARCHAR(128) NOT NULL,
    `xid`            VARCHAR(128),
    `transaction_id` BIGINT,
    `branch_id`      BIGINT       NOT NULL,
    `resource_id`    VARCHAR(256),
    `table_name`     VARCHAR(32),
    `pk`             VARCHAR(36),
    `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
    `gmt_create`     DATETIME,
    `gmt_modified`   DATETIME,
    PRIMARY KEY (`row_key`),
    KEY `idx_status` (`status`),
    KEY `idx_branch_id` (`branch_id`),
    KEY `idx_xid_and_branch_id` (`xid` , `branch_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

CREATE TABLE IF NOT EXISTS `distributed_lock`
(
    `lock_key`       CHAR(20) NOT NULL,
    `lock_value`     VARCHAR(20) NOT NULL,
    `expire`         BIGINT,
    primary key (`lock_key`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);
9.1.4、修改組態檔seata/conf/application.yml
server:
  port: 7091

spring:
  application:
    name: seata-server

logging:
  config: classpath:logback-spring.xml
  file:
    path: ${user.home}/logs/seata
#  extend:
#    logstash-appender:
#      destination: 127.0.0.1:4560
#    kafka-appender:
#      bootstrap-servers: 127.0.0.1:9092
#      topic: logback_to_logstash

console:  
  user:
    username: seata
    password: seata

seata:
  config:
    # support: nacos, consul, apollo, zk, etcd3
    type: nacos
    nacos:
      server-addr: 172.16.156.139:8847
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43
      group: SEATA_GROUP
      username: nacos
      password: nacos
      ##if use MSE Nacos with auth, mutex with username/password attribute
      #access-key: ""
      #secret-key: ""
#      data-id: seataServer.properties
  registry:
    # support: nacos, eureka, redis, zk, consul, etcd3, sofa
    type: nacos
#    preferred-networks: 30.240.*
    nacos:
      application: seata-server
      server-addr: 172.16.156.139:8847
      group: SEATA_GROUP
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43
      cluster: default
      username: nacos
      password: nacos
  store:
    # support: file 、 db 、 redis
    mode: db
#  server:
#    service-port: 8091 #If not configured, the default is '${server.port} + 1000'
  security:
    secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017
    tokenValidityInMilliseconds: 1800000
    ignore:
      urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.ico,/console-fe/public/**,/api/v1/auth/login
9.1.5、修改seata/script/config-center/config.txt檔案中資料庫連接
# 改為db
store.mode=db
store.lock.mode=db
store.session.mode=db
# 改為對應的資料庫連接地址
store.db.driverClassName=com.mysql.cj.jdbc.Driver
store.db.url=jdbc:mysql://114.67.111.175:3306/seata_server?useUnicode=true&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&useSSL=false
store.db.user=root
store.db.password=123456
9.1.6、進入seata/script/config-center/nacos執行腳本上傳配置到nacos
./nacos-config.sh -h 172.16.156.139 -p 8847 -g SEATA_GROUP -t 170ee694-566d-4c3a-b316-fe233d984d43 -u nacos -w nacos
  • -h: 注冊注冊中心的ip
  • -p：注冊中心的埠
  • -g: 注冊到注冊中心的Group
  • -t: 注冊到注冊中心的命名空間
  • -u: 注冊中心的賬號
  • -w: 注冊中心的密碼
9.1.7、進入seata/bin啟動seata服務
./seata-server.sh -h 127.0.0.1 -p 8091
  • -h：seata服務地址
  • -p：監聽埠，從8091開始

9.2、客戶端client

  • 準備在需要開啟分布式事務的各資料庫新建undo_log表，主要通過 BeforeImage 和 AfterImage 保存前后邏輯 , 用于回退處理，使用at模式
-- for AT mode you must to init this sql for you business database. the seata server not need it.
CREATE TABLE IF NOT EXISTS `undo_log`
(
    `branch_id`     BIGINT       NOT NULL COMMENT 'branch transaction id',
    `xid`           VARCHAR(128) NOT NULL COMMENT 'global transaction id',
    `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',
    `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info',
    `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status',
    `log_created`   DATETIME(6)  NOT NULL COMMENT 'create datetime',
    `log_modified`  DATETIME(6)  NOT NULL COMMENT 'modify datetime',
    UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB
  AUTO_INCREMENT = 1
  DEFAULT CHARSET = utf8mb4 COMMENT ='AT transaction mode undo table';
9.2.1、匯入依賴
9.2.1.1、服務提供方
 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.11</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>io.seata</groupId>
            <artifactId>seata-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>io.seata</groupId>
                    <artifactId>seata-spring-boot-starter</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>
9.2.1.2、服務呼叫方
<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.11</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-loadbalancer</artifactId>
        </dependency>
        <dependency>
            <groupId>io.seata</groupId>
            <artifactId>seata-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>io.seata</groupId>
                    <artifactId>seata-spring-boot-starter</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>
9.2.2、組態檔
9.2.2.1、服務提供方
server:
  port: 6062
spring:
  main:
    allow-circular-references: true
  application:
    name: stock-db
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://114.67.111.175:3306/test?allowPublicKeyRetrieval=true&useSSL=false&serverTimezone=Asia/Shanghai
    username: root
    password: 123456
  cloud:
    nacos:
      server-addr: 172.16.156.139:8847
      username: nacos
      password: nacos
    alibaba:
      seata:
        # 事務分組，可自定義，對應屬性 service.vgroupMapping.default_tx_group=default
        tx-service-group: default_tx_group
---
mybatis:
  type-aliases-package: com.wanqi.pojo
  mapper-locations: classpath:mapper/*.xml
---
seata:
  tx-service-group: default_tx_group
  registry:
    type: nacos # 配置seata的注冊中心，告訴seata client如何訪問seata server
    nacos:
      server-addr: 172.16.156.139:8847 # seata server注冊的nacos中心
      group: SEATA_GROUP # seata server注冊的分組
      application: seata-server # seata server注冊的服務名
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43 # seata server注冊的命名空間
      cluster: default # seata server集群名稱
      username: nacos # nacos賬號
      password: nacos # nacos密碼
  config:
    type: nacos
    nacos:
      server-addr: 172.16.156.139:8847 # seata配置注冊的nacos中心
      group: SEATA_GROUP # 配置注冊的分組
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43 # 配置注冊的命名空間
      username: nacos # nacos賬號
      password: nacos # nacos密碼
9.2.2.2、服務呼叫方，在需要開啟事務的方法上使用@GlobalTransactional開啟全域事務
server:
  port: 6061
spring:
  main:
    allow-circular-references: true
  application:
    name: order-db
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://39.104.101.11:3306/test
    username: wq
    password: 123456
  cloud:
    nacos:
      server-addr: 172.16.156.139:8847
      password: nacos
      username: nacos
    alibaba:
      seata:
        # 事務分組，可自定義，對應屬性 service.vgroupMapping.default_tx_group=default
        tx-service-group: default_tx_group

---
mybatis:
  type-aliases-package: com.wanqi.pojo
  mapper-locations: classpath:mapper/*.xml
---
feign:
  client:
    config:
      default:
        loggerLevel: Full
        connectTimeout: 6000
        readTimeout: 6000
---
logging:
  level:
    com.wanqi.feign: debug
---
seata:
  tx-service-group: default_tx_group
  registry:
    type: nacos
    nacos:
      server-addr: 172.16.156.139:8847 # seata服務注冊的nacos中心
      group: SEATA_GROUP # 注冊的分組
      application: seata-server # 注冊的服務名
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43 # 注冊的命名空間
      cluster: default # 集群名稱
      username: nacos # nacos賬號
      password: nacos # nacos密碼
  config:
    type: nacos
    nacos:
      server-addr: 172.16.156.139:8847 # seata配置注冊的nacos中心
      group: SEATA_GROUP # 配置注冊的分組
      namespace: 170ee694-566d-4c3a-b316-fe233d984d43 # 配置注冊的命名空間
      username: nacos # nacos賬號
      password: nacos # nacos密碼
9.2.3、client介面與呼叫
9.2.3.1、服務提供方介面
@RestController
public class StockController {
    @Autowired
    StockMapper stockMapper;

    @PostMapping("/add")
    public int add(@RequestParam("orderId") Long id) {
        System.out.println(id);
        Stock select = stockMapper.select();
        int x =  stockMapper.update(id);
        System.out.println(select);
        return x;
    }

    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql){
        MyTest test = new MyTest(sqlId,sql);
        System.out.println(test);
        return test.toString();
    }

}
9.2.3.2、呼叫方介面
@FeignClient(name = "stock-db",contextId = "stock-db")
public interface StockFeignService {

    @PostMapping("/add")
    public int add(@RequestParam("orderId") Long orderId);

    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql);
}

@RestController
public class OrderController {
    @Autowired
    OrderService orderService;
    @Autowired
    StockFeignService stockFeignService;

    @GetMapping("add/{name}")
    public String add(@PathVariable("name") String name){
        System.out.println(name);
        orderService.add(name);
        return "ok";
    }

    @GetMapping("add2/{orderId}")
    public int add2(@PathVariable("orderId") Long orderId) {
        return stockFeignService.add(orderId);
    }


    @PostMapping(value = "https://www.cnblogs.com/sqlFile")
    public String genSqlFile(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql){
        MyTest test = new MyTest(sqlId,sql);
        String msg = stockFeignService.genSqlFile(test.getSqlId(),test.getSql());
        System.out.println(msg + "呼叫成功啦！！！");
        return msg;
    }
}

@Service
public class OrderService {

    @Autowired
    StockFeignService stockFeignService;
    @Autowired
    OrderMapper orderMapper;
    //注解開啟全域事務
    @GlobalTransactional
    public String add(String name) {
        orderMapper.save(name);

        stockFeignService.add(Long.valueOf("999"));
        int a = 1/0;
        return "ok";
    }
}

10、SkyWalking鏈路追蹤，安裝包使用阿里云鏡像地址

image.png

10.1、解壓后修改為mysql模式，apache-skywalking-apm-bin/config/application.yml

  • 設定為mysql，默認是h2
storage:
  selector: ${SW_STORAGE:mysql}
  • 新建資料庫swtest，修改jdbcUrl地址為自己的資料庫地址
  mysql:
    properties:
      jdbcUrl: ${SW_JDBC_URL:"jdbc:mysql://114.67.111.165:3306/swtest?rewriteBatchedStatements=true"}
      dataSource.user: ${SW_DATA_SOURCE_USER:root}
      dataSource.password: ${SW_DATA_SOURCE_PASSWORD:123456}

10.2、修改web埠，apache-skywalking-apm-bin/webapp/webapp.yml

  • 可選操作，默認埠8080使用頻率較高避免重復
server:
  port: 8868

10.3、啟動服務，apache-skywalking-apm-bin/bin/startup.sh

image.png

10.4、訪問UI界面

image.png

10.5、idea接入，配置啟動引數然后啟動即可

-DSW_AGENT_NAME=api-gateway
-DSW_AGENT_COLLECTOR_BACKEND_SERVICES=172.16.156.139:11800
-javaagent:/Users/wandaren/Downloads/Compressed/skywalking-agent/skywalking-agent.jar

image.png

10.6、logback日志集成

10.6.1、引入依賴
        <dependency>
            <groupId>org.apache.skywalking</groupId>
            <artifactId>apm-toolkit-logback-1.x</artifactId>
            <version>8.11.0</version>
        </dependency>
10.6.2、修改agent配置增加以下內容
  • 檔案：skywalking-agent/config/agent.config
plugin.toolkit.log.grpc.reporter.server_host=${SW_GRPC_LOG_SERVER_HOST:172.16.156.139}
plugin.toolkit.log.grpc.reporter.server_port=${SW_GRPC_LOG_SERVER_PORT:11800}
plugin.toolkit.log.grpc.reporter.max_message_size=${SW_GRPC_LOG_MAX_MESSAGE_SIZE:10485760}
plugin.toolkit.log.grpc.reporter.upstream_timeout=${SW_GRPC_LOG_GRPC_UPSTREAM_TIMEOUT:30}
10.6.3、撰寫logback日志配置，檔案名logback-spring.xml
  • 如果不是使用的logback-spring.xml檔案名，需要在組態檔中指application.yml定
logging:
  # 如果不想配置必須使用檔案名：logback-spring.xml
  config: classpath:logback.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
    <!--定義日志檔案的存盤地址 勿在 LogBack 的配置中使用相對路徑-->
    <property name="LOG_HOME" value="https://www.cnblogs.com/data/log" />
    <!-- 控制臺輸出 -->
    <appender name="STDOUT" >
        <encoder >
            <!--格式化輸出：%d表示日期，%thread表示執行緒名，%-5level：級別從左顯示5個字符寬度%msg：日志訊息，%n是換行符-->
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
        </encoder>
    </appender>
    <!-- GRPCLogClientAppender處理器上傳日志到skywalking -->
    <appender name="gpr-log" >
        <!-- 日志輸出編碼 -->
        <encoder>
            <!--格式化輸出：%d表示日期，%thread表示執行緒名，%-5level：級別從左顯示5個字符寬度%msg：日志訊息，%n是換行符-->
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n
            </pattern>
        </encoder>
    </appender>

    <!--mybatis log configure-->
    <logger name="com.apache.ibatis" level="TRACE"/>
    <logger name="java.sql.Connection" level="DEBUG"/>
    <logger name="java.sql.Statement" level="DEBUG"/>
    <logger name="java.sql.PreparedStatement" level="DEBUG"/>

    <!-- 日志輸出級別 -->
    <root level="INFO">
        <appender-ref ref="STDOUT" />
        <appender-ref ref="gpr-log"/>
        </root>
</configuration>

image.png

10.7、自定義鏈路追蹤

10.7.1、引入依賴
        <dependency>
            <groupId>org.apache.skywalking</groupId>
            <artifactId>apm-toolkit-trace</artifactId>
            <version>8.11.0</version>
        </dependency>
10.7.2、使用注解指定方法，示例
    @Trace
    @Tag(key = "select",value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/returnedObj")
    public String select(){
        return stockFeignService.select();
    }

   @PostMapping(value = "https://www.cnblogs.com/myTest")
    @Trace
    @Tags({@Tag(key = "sqlId",value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/arg[0]"),
            @Tag(key = "sql",value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/arg[1]"),
            @Tag(key = "sqlId",value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/returnedObj.sqlId"),
            @Tag(key = "sql",value = "https://www.cnblogs.com/wandaren/archive/2022/10/29/returnedObj.sql")})
    public MyTest myTest(@RequestParam("sqlId")String sqlId,@RequestParam("sql")String sql){
        return new MyTest(sqlId + "111",sql + "222");
    }

image.png
image.png

10.8、告警參考官網

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/523088.html

標籤：其他

上一篇：13個QA帶你了解線上壓測的知識點

下一篇：高精度HighAccuracy_acwing.cpp

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • 【C++】Microsoft C++、C 和匯編程式檔案

    ......

    uj5u.com 2020-09-10 00:57:23 more
  • 例外宣告

    相比于斷言適用于排除邏輯上不可能存在的狀態，例外通常是用于邏輯上可能發生的錯誤。 例外宣告 Item 1：當函式不可能拋出例外或不能接受拋出例外時，使用noexcept 理由 如果不打算拋出例外的話，程式就會認為無法處理這種錯誤，并且應當盡早終止，如此可以有效地阻止例外的傳播與擴散。 示例 //不可 ......

    uj5u.com 2020-09-10 00:57:27 more
  • Codeforces 1400E Clear the Multiset(貪心 + 分治)

    鏈接：https://codeforces.com/problemset/problem/1400/E 來源：Codeforces 思路：給你一個陣列，現在你可以進行兩種操作，操作1：將一段沒有 0 的區間進行減一的操作，操作2：將 i 位置上的元素歸零。最終問：將這個陣列的全部元素歸零后操作的最少 ......

    uj5u.com 2020-09-10 00:57:30 more
  • UVA11610 【Reverse Prime】

    本人看到此題沒有翻譯，就附帶了一個自己的翻譯版本 思考 這一題，它的第一個要求是找出所有 $7$ 位反向質數及其質因數的個數。 我們應該需要質數篩篩選1~$10^{7}$的所有數，這里就不慢慢介紹了。但是，重讀題，我們突然發現反向質數都是 $7$ 位，而將它反過來后的數字卻是 $6$ 位數，這就說明 ......

    uj5u.com 2020-09-10 00:57:36 more
  • 統計區間素數數量

    1 #pragma GCC optimize(2) 2 #include <bits/stdc++.h> 3 using namespace std; 4 bool isprime[1000000010]; 5 vector<int> prime; 6 inline int getlist(int ......

    uj5u.com 2020-09-10 00:57:47 more
  • C/C++編程筆記：C++中的 const 變數詳解，教你正確認識const用法

    1、C中的const 1、區域const變數存放在堆疊區中，會分配記憶體（也就是說可以通過地址間接修改變數的值）。測驗代碼如下： 運行結果： 2、全域const變數存放在只讀資料段（不能通過地址修改，會發生寫入錯誤）， 默認為外部聯編，可以給其他源檔案使用（需要用extern關鍵字修飾） 運行結果： ......

    uj5u.com 2020-09-10 00:58:04 more
  • 【C++犯錯記錄】VS2019 MFC添加資源不懂如何修改資源宏ID

    1. 首先在資源視圖中，添加資源 2. 點擊新添加的資源，復制自動生成的ID 3. 在解決方案資源管理器中找到Resource.h檔案，編輯，使用整個專案搜索和替換的方式快速替換 宏宣告 4. Ctrl+Shift+F 全域搜索，點擊查找全部，然后逐個替換 5. 為什么使用搜索替換而不使用屬性視窗直 ......

    uj5u.com 2020-09-10 00:59:11 more
  • 【C++犯錯記錄】VS2019 MFC不懂的批量添加資源

    1. 打開資源頭檔案Resource.h，在其中預先定義好宏 ID（不清楚其實ID值應該設定多少，可以先新建一個相同的資源項，再在這個資源的ID值的基礎上遞增即可） 2. 在資源視圖中選中專案資源，按F7編輯資源檔案，按 ID 型別 相對路徑的形式添加 資源。（別忘了先把檔案拷貝到專案中的res檔案 ......

    uj5u.com 2020-09-10 01:00:19 more
  • C/C++編程筆記：關于C++的參考型別，專供新手入門使用

    今天要講的是C++中我最喜歡的一個用法——參考，也叫別名。 參考就是給一個變數名取一個變數名，方便我們間接地使用這個變數。我們可以給一個變數創建N個參考，這N + 1個變數共享了同一塊記憶體區域。(參考型別的變數會占用記憶體空間，占用的記憶體空間的大小和指標型別的大小是相同的。雖然參考是一個物件的別名，但 ......

    uj5u.com 2020-09-10 01:00:22 more
  • 【C/C++編程筆記】從頭開始學習C ++：初學者完整指南

    眾所周知，C ++的學習曲線陡峭，但是花時間學習這種語言將為您的職業帶來奇跡，并使您與其他開發人員區分開。您會更輕松地學習新語言，形成真正的解決問題的技能，并在編程的基礎上打下堅實的基礎。 C ++將幫助您養成良好的編程習慣（即清晰一致的編碼風格，在撰寫代碼時注釋代碼，并限制類內部的可見性），并且由 ......

    uj5u.com 2020-09-10 01:00:41 more
最新发布
  • Rust中的智能指標:Box<T> Rc<T> Arc<T> Cell<T> RefCell<T> Weak

    Rust中的智能指標是什么 智能指標（smart pointers）是一類資料結構，是擁有資料所有權和額外功能的指標。是指標的進一步發展 指標（pointer）是一個包含記憶體地址的變數的通用概念。這個地址參考，或 ” 指向”（points at）一些其 他資料 。參考以 & 符號為標志并借用了他們所 ......

    uj5u.com 2023-04-20 07:24:10 more
  • Java的值傳遞和參考傳遞

    值傳遞不會改變本身，參考傳遞（如果傳遞的值需要實體化到堆里）如果發生修改了會改變本身。 1.基本資料型別都是值傳遞 package com.example.basic; public class Test { public static void main(String[] args) { int ......

    uj5u.com 2023-04-20 07:24:04 more
  • [2]SpinalHDL教程——Scala簡單入門

    第一個 Scala 程式 shell里面輸入 $ scala scala> 1 + 1 res0: Int = 2 scala> println("Hello World!") Hello World! 檔案形式 object HelloWorld { /* 這是我的第一個 Scala 程式 * 以 ......

    uj5u.com 2023-04-20 07:23:58 more
  • 理解函式指標和回呼函式

    理解 函式指標 指向函式的指標。比如： 理解函式指標的偽代碼 void (*p)(int type, char *data); // 定義一個函式指標p void func(int type, char *data); // 宣告一個函式func p = func; // 將指標p指向函式func ......

    uj5u.com 2023-04-20 07:23:52 more
  • Django筆記二十五之資料庫函式之日期函式

    本文首發于公眾號：Hunter后端 原文鏈接：Django筆記二十五之資料庫函式之日期函式 日期函式主要介紹兩個大類，Extract() 和 Trunc() Extract() 函式作用是提取日期，比如我們可以提取一個日期欄位的年份，月份，日等資料 Trunc() 的作用則是截取，比如 2022-0 ......

    uj5u.com 2023-04-20 07:23:45 more
  • 一天吃透JVM面試八股文

    什么是JVM？ JVM，全稱Java Virtual Machine（Java虛擬機），是通過在實際的計算機上仿真模擬各種計算機功能來實作的。由一套位元組碼指令集、一組暫存器、一個堆疊、一個垃圾回收堆和一個存盤方法域等組成。JVM屏蔽了與作業系統平臺相關的資訊，使得Java程式只需要生成在Java虛擬機 ......

    uj5u.com 2023-04-20 07:23:31 more
  • 使用Java接入小程式訂閱訊息！

    更新完微信服務號的模板訊息之后，我又趕緊把微信小程式的訂閱訊息給實作了！之前我一直以為微信小程式也是要企業才能申請，沒想到小程式個人就能申請。 訊息推送平臺🔥推送下發【郵件】【短信】【微信服務號】【微信小程式】【企業微信】【釘釘】等訊息型別。 https://gitee.com/zhongfuch ......

    uj5u.com 2023-04-20 07:22:59 more
  • java -- 緩沖流、轉換流、序列化流

    緩沖流 緩沖流, 也叫高效流, 按照資料型別分類： 位元組緩沖流：BufferedInputStream，BufferedOutputStream 字符緩沖流：BufferedReader，BufferedWriter 緩沖流的基本原理，是在創建流物件時，會創建一個內置的默認大小的緩沖區陣列，通過緩沖 ......

    uj5u.com 2023-04-20 07:22:49 more
  • Java-SpringBoot-Range請求頭設定實作視頻分段傳輸

    老實說，人太懶了，現在基本都不喜歡寫筆記了，但是網上有關Range請求頭的文章都太水了 下面是抄的一段StackOverflow的代碼...自己大修改過的，寫的注釋挺全的，應該直接看得懂，就不解釋了 寫的不好...只是希望能給視頻網站開發的新手一點點幫助吧. 業務場景：視頻分段傳輸、視頻多段傳輸（理 ......

    uj5u.com 2023-04-20 07:22:42 more
  • Windows 10開發教程_編程入門自學教程_菜鳥教程-免費教程分享

    教程簡介 Windows 10開發入門教程 - 從簡單的步驟了解Windows 10開發，從基本到高級概念，包括簡介，UWP，第一個應用程式，商店，XAML控制元件，資料系結，XAML性能，自適應設計，自適應UI，自適應代碼，檔案管理，SQLite資料庫，應用程式到應用程式通信，應用程式本地化，應用程式 ......

    uj5u.com 2023-04-20 07:22:35 more

Copyright © 2010-2020 有解無憂