Jmeter学习笔记

SpringCloud Alibaba学习笔记

1、项目搭建

版本依赖关系：https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E

在这里插入图片描述
在这里插入图片描述

1.1、搭建父工程

spring-initializr构建项目
在这里插入图片描述
在这里插入图片描述

清理父工程中不必要的文件/文件夹
在这里插入图片描述

修改pom.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--父依赖--><!--<parent>--><!--    <groupId>org.springframework.boot</groupId>--><!--    <artifactId>spring-boot-starter-parent</artifactId>--><!--    <version>2.6.3</version>--><!--    <relativePath/> &lt;!&ndash; lookup parent from repository &ndash;&gt;--><!--</parent>--><!--项目信息--><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version><name>springcloud-demo</name><description>springcloud-demo</description><!--版本统一管控--><properties><java.version>1.8</java.version><spring-boot.revision>2.6.3</spring-boot.revision><spring-cloud.version>2021.0.1</spring-cloud.version><spring-cloud-alibaba.version>2021.0.1.0</spring-cloud-alibaba.version></properties><!--通用依赖--><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><!--依赖管理--><dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>${spring-boot.revision}</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></dependencies></dependencyManagement></project>

1.2、子项目

1、account

创建子项目
在这里插入图片描述

子项目添加启动类和配置文件
在这里插入图片描述

package com.example;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class AccountApplication {public static void main(String[] args) {SpringApplication.run(AccountApplication.class, args);}
}

server:port: 10010

子项目打包方式修改
在这里插入图片描述

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、blog

创建子项目
在这里插入图片描述

子项目添加启动类和配置文件
在这里插入图片描述

package com.example;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class BlogApplication {public static void main(String[] args) {SpringApplication.run(BlogApplication.class, args);}
}

server:port: 10020

子项目打包方式修改
在这里插入图片描述

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、Nacos

这里采用docker的方式部署

如果直接在主机上部署可以在https://github.com/alibaba/nacos/releases找需要的版本

2.1、部署Mysql

1、Mysql

docker run -d \-p 3306:3306 \--name mysql \-v mysql-data:/var/lib/mysql \-e MYSQL_ROOT_PASSWORD=123456 \--privileged=true \--restart=always \mysql:5.7.42

2、初始化

 /** Copyright 1999-2018 Alibaba Group Holding Ltd.** Licensed under the Apache License, Version 2.0 (the "License");* you may not use this file except in compliance with the License.* You may obtain a copy of the License at**      http://www.apache.org/licenses/LICENSE-2.0** Unless required by applicable law or agreed to in writing, software* distributed under the License is distributed on an "AS IS" BASIS,* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.* See the License for the specific language governing permissions and* limitations under the License.*//******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = config_info   */
/******************************************/
CREATE DATABASE nacos;
USE nacos;
CREATE TABLE `config_info` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',`data_id` varchar(255) NOT NULL COMMENT 'data_id',`group_id` varchar(255) DEFAULT NULL,`content` longtext NOT NULL COMMENT 'content',`md5` varchar(32) DEFAULT NULL COMMENT 'md5',`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',`src_user` text COMMENT 'source user',`src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',`app_name` varchar(128) DEFAULT NULL,`tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',`c_desc` varchar(256) DEFAULT NULL,`c_use` varchar(64) DEFAULT NULL,`effect` varchar(64) DEFAULT NULL,`type` varchar(64) DEFAULT NULL,`c_schema` text,PRIMARY KEY (`id`),UNIQUE KEY `uk_configinfo_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = config_info_aggr   */
/******************************************/
CREATE TABLE `config_info_aggr` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',`data_id` varchar(255) NOT NULL COMMENT 'data_id',`group_id` varchar(255) NOT NULL COMMENT 'group_id',`datum_id` varchar(255) NOT NULL COMMENT 'datum_id',`content` longtext NOT NULL COMMENT '内容',`gmt_modified` datetime NOT NULL COMMENT '修改时间',`app_name` varchar(128) DEFAULT NULL,`tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',PRIMARY KEY (`id`),UNIQUE KEY `uk_configinfoaggr_datagrouptenantdatum` (`data_id`,`group_id`,`tenant_id`,`datum_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='增加租户字段';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = config_info_beta   */
/******************************************/
CREATE TABLE `config_info_beta` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',`data_id` varchar(255) NOT NULL COMMENT 'data_id',`group_id` varchar(128) NOT NULL COMMENT 'group_id',`app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',`content` longtext NOT NULL COMMENT 'content',`beta_ips` varchar(1024) DEFAULT NULL COMMENT 'betaIps',`md5` varchar(32) DEFAULT NULL COMMENT 'md5',`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',`src_user` text COMMENT 'source user',`src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',`tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',PRIMARY KEY (`id`),UNIQUE KEY `uk_configinfobeta_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_beta';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = config_info_tag   */
/******************************************/
CREATE TABLE `config_info_tag` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',`data_id` varchar(255) NOT NULL COMMENT 'data_id',`group_id` varchar(128) NOT NULL COMMENT 'group_id',`tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',`tag_id` varchar(128) NOT NULL COMMENT 'tag_id',`app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',`content` longtext NOT NULL COMMENT 'content',`md5` varchar(32) DEFAULT NULL COMMENT 'md5',`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',`src_user` text COMMENT 'source user',`src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',PRIMARY KEY (`id`),UNIQUE KEY `uk_configinfotag_datagrouptenanttag` (`data_id`,`group_id`,`tenant_id`,`tag_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_tag';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = config_tags_relation   */
/******************************************/
CREATE TABLE `config_tags_relation` (`id` bigint(20) NOT NULL COMMENT 'id',`tag_name` varchar(128) NOT NULL COMMENT 'tag_name',`tag_type` varchar(64) DEFAULT NULL COMMENT 'tag_type',`data_id` varchar(255) NOT NULL COMMENT 'data_id',`group_id` varchar(128) NOT NULL COMMENT 'group_id',`tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',`nid` bigint(20) NOT NULL AUTO_INCREMENT,PRIMARY KEY (`nid`),UNIQUE KEY `uk_configtagrelation_configidtag` (`id`,`tag_name`,`tag_type`),KEY `idx_tenant_id` (`tenant_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_tag_relation';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = group_capacity   */
/******************************************/
CREATE TABLE `group_capacity` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',`group_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Group ID，空字符表示整个集群',`quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',`usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',`max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',`max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数，，0表示使用默认值',`max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',`max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',PRIMARY KEY (`id`),UNIQUE KEY `uk_group_id` (`group_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='集群、各Group容量信息表';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = his_config_info   */
/******************************************/
CREATE TABLE `his_config_info` (`id` bigint(64) unsigned NOT NULL,`nid` bigint(20) unsigned NOT NULL AUTO_INCREMENT,`data_id` varchar(255) NOT NULL,`group_id` varchar(128) NOT NULL,`app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',`content` longtext NOT NULL,`md5` varchar(32) DEFAULT NULL,`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,`src_user` text,`src_ip` varchar(50) DEFAULT NULL,`op_type` char(10) DEFAULT NULL,`tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',PRIMARY KEY (`nid`),KEY `idx_gmt_create` (`gmt_create`),KEY `idx_gmt_modified` (`gmt_modified`),KEY `idx_did` (`data_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='多租户改造';/******************************************/
/*   数据库全名 = nacos_config   */
/*   表名称 = tenant_capacity   */
/******************************************/
CREATE TABLE `tenant_capacity` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',`tenant_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Tenant ID',`quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',`usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',`max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',`max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数',`max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',`max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',`gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',`gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',PRIMARY KEY (`id`),UNIQUE KEY `uk_tenant_id` (`tenant_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='租户容量信息表';CREATE TABLE `tenant_info` (`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',`kp` varchar(128) NOT NULL COMMENT 'kp',`tenant_id` varchar(128) default '' COMMENT 'tenant_id',`tenant_name` varchar(128) default '' COMMENT 'tenant_name',`tenant_desc` varchar(256) DEFAULT NULL COMMENT 'tenant_desc',`create_source` varchar(32) DEFAULT NULL COMMENT 'create_source',`gmt_create` bigint(20) NOT NULL COMMENT '创建时间',`gmt_modified` bigint(20) NOT NULL COMMENT '修改时间',PRIMARY KEY (`id`),UNIQUE KEY `uk_tenant_info_kptenantid` (`kp`,`tenant_id`),KEY `idx_tenant_id` (`tenant_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='tenant_info';CREATE TABLE `users` (`username` varchar(50) NOT NULL PRIMARY KEY,`password` varchar(500) NOT NULL,`enabled` boolean NOT NULL
);CREATE TABLE `roles` (`username` varchar(50) NOT NULL,`role` varchar(50) NOT NULL,UNIQUE INDEX `idx_user_role` (`username` ASC, `role` ASC) USING BTREE
);CREATE TABLE `permissions` (`role` varchar(50) NOT NULL,`resource` varchar(255) NOT NULL,`action` varchar(8) NOT NULL,UNIQUE INDEX `uk_role_permission` (`role`,`resource`,`action`) USING BTREE
);INSERT INTO users (username, password, enabled) VALUES ('nacos', '$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu', TRUE);INSERT INTO roles (username, role) VALUES ('nacos', 'ROLE_ADMIN');

2.2、部署Nacos

docker run -itd \-e MODE=standalone \-e SPRING_DATASOURCE_PLATFORM=mysql \-e MYSQL_SERVICE_HOST=150.158.24.200 \-e MYSQL_SERVICE_PORT=3306 \-e MYSQL_SERVICE_DB_NAME=nacos \-e MYSQL_SERVICE_USER=root \-e MYSQL_SERVICE_PASSWORD=123456 \-p 8848:8848 \--name nacos \--restart=always \nacos/nacos-server:1.4.2

2.3、可视化界面

可视化界面：http://150.158.24.200:8848/nacos/

初始账号密码为：nacos/nacos
在这里插入图片描述
在这里插入图片描述

2.4、项目配置注册中心

2.5、pom.xml添加nacos

均在子项目中配置

1、account

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、blog

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2.6、application.yaml添加nacos

1、account

server:port: 10010
spring:# 应用名称application:name: accountcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false

2、blog

server:port: 10020
spring:# 应用名称application:name: blogcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false

2.7、服务调用

可在面板里面打开service面板（有时候无法显示出来springboot服务面板，可以在services->±>run configuration->springboot）
在这里插入图片描述

1、account

服务提供者

controller

// account/src/main/java/com/example/controller/HelloController.java
@RestController
public class HelloController {@Value("${server.port}")String port;@RequestMapping("/account")public String hello() {return "Hello xumeng03-"+port;}
}

2、blog

服务调用者

Configuration

// blog/src/main/java/com/example/CustomConfiguration.java
@Configuration
public class CustomConfiguration {@Bean@LoadBalancedpublic RestTemplate restTemplate(RestTemplateBuilder builder){return builder.build();}
}

controller

// blog/src/main/java/com/example/controller/HelloController.java
@RestController
public class HelloController {@AutowiredRestTemplate restTemplate;@RequestMapping("/blog")public String hello() {return restTemplate.getForObject("http://account/account", String.class);}
}

在这里插入图片描述

2.8、应用启动多实例

在service面板里面选中要复制的应用，右键选择Copy Configuration
在这里插入图片描述
修改服务名称和端口（Environment variables如果没有的话，可以在Modify options选项里面勾选上）
在这里插入图片描述

3、Openfeign

3.1、pom.xml添加openfeign

1、account

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、blog

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

3.2、服务调用

1、account

// account/src/main/java/com/example/controller/HelloController.java
@RestController
public class HelloController {@Value("${server.port}")String port;@RequestMapping("/account/{name}")public String hello(@PathVariable("name") String name) {return "Hello " + name + " " + port;}
}

2、blog

// blog/src/main/java/com/example/openfeign/AccountOpenfeign.java
// name指定服务名，path指定Controller的RequestMapping，configuration用于指定特殊的配置
@FeignClient(name = "account")
public interface AccountOpenfeign {@RequestMapping("/account/{name}")String hello(@PathVariable("name") String name);
}

// blog/src/main/java/com/example/controller/HelloController.java
@RestController
public class HelloController {@AutowiredRestTemplate restTemplate;@AutowiredAccountOpenfeign accountOpenfeign;@RequestMapping("/blog")public String hello() {return accountOpenfeign.hello("xumeng03");}
}

3.3、修改启动类

// blog/src/main/java/com/example/BlogApplication.java
@SpringBootApplication
// 添加启用FeignClients
@EnableFeignClients
public class BlogApplication {public static void main(String[] args) {SpringApplication.run(BlogApplication.class, args);}
}

3.4、Openfeign日志级别

1、配置类

// blog/src/main/java/com/example/config/CustomConfiguration.java
@Configuration
public class CustomConfiguration {@Bean@LoadBalancedpublic RestTemplate restTemplate(RestTemplateBuilder builder){return builder.build();}@Beanpublic Logger.Level openFeignLoggerLevel(){// 输出完整日志return Logger.Level.FULL;}
}

因为springboot的默认日志级别info大于openFeign的debug，所以要再配置文件中单独配置下

# blog/src/main/resources/application.yaml
server:port: 10020
spring:# 应用名称application:name: blogcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug

2、配置文件

# blog/src/main/resources/application.yaml
server:port: 10020
spring:# 应用名称application:name: blogcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug
feign:client:config:account:logger-level: BASIC

3.5、Openfeign超时时间

1、配置类

// blog/src/main/java/com/example/config/CustomConfiguration.java
@Configuration
public class CustomConfiguration {@Bean@LoadBalancedpublic RestTemplate restTemplate(RestTemplateBuilder builder){return builder.build();}@Beanpublic Logger.Level openFeignLoggerLevel(){// 输出完整日志return Logger.Level.FULL;}@Beanpublic Request.Options openFeignRequestOption(){// connectTimeoutMillis连接超时时间(默认2s)，readTimeoutMillis请求处理超时时间(默认5s)return new Request.Options(3000,10000);}
}

2、配置文件

# blog/src/main/resources/application.yaml
server:port: 10020
spring:# 应用名称application:name: blogcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug
# openfeign配置
feign:client:config:account:# 日志级别logger-level: BASIC# 连接超时时间，默认2sconnect-timeout: 3000# 请求处理超时时间，默认5sreadTimeout: 10000

4、配置中心

配置文档：https://github.com/alibaba/spring-cloud-alibaba/wiki/Nacos-config

http://150.158.24.200:8848/nacos/#/configurationManagement

4.1、添加配置

在这里插入图片描述

4.2、添加依赖

1、account

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、blog

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

4.3、bootstrap.properties

必须使用bootstrap.properties/bootstrap.yaml指定nacos server的地址

1、account

# account/src/main/resources/bootstrap.yaml
spring:application:# 需和配置文件的DataId一致（如果不一致需要使用extension-configs或shared-configs，extension-configs优先级更高）name: accountcloud:# nacos配置nacos:config:# nacos地址server-addr: 150.158.24.200:8848# 配置文件后缀（只针对默认配置文件和profile文件）file-extension: yaml

2、blog

# account/src/main/resources/bootstrap.yaml
spring:application:# 需和配置文件的DataId一致（如果不一致需要使用extension-configs或shared-configs，extension-configs优先级更高）name: accountcloud:# nacos配置nacos:config:# nacos地址server-addr: 150.158.24.200:8848# 配置文件后缀（只针对默认配置文件和profile文件）file-extension: yaml

4.4、修改controller

1、account

// account/src/main/java/com/example/controller/HelloController.java
@RestController
// 一定要加，否则@Value无法获取动态更新的值
@RefreshScope
public class HelloController {@Value("${server.port}")String port;@Value("${user.name}")String userName;@Value("${user.age}")String age;@RequestMapping("/account/{name}")public String hello(@PathVariable("name") String name) {System.out.println(name);return "Hello " + userName + " " + age;}
}

可以看到此时获取到了文件内容并且会随着配置文件更新而更新
在这里插入图片描述

在这里插入图片描述

2、blog

// blog/src/main/java/com/example/controller/HelloController.java
@RestController
@RefreshScope
public class HelloController {@AutowiredRestTemplate restTemplate;@AutowiredAccountOpenfeign accountOpenfeign;@Value("${environment.name}")String env;@RequestMapping("/blog")public String hello() {return accountOpenfeign.hello("xumeng03") + " " + env;}
}

blog为了演示profiles效果，结果如下小节所示

4.5、修改配置文件

1、account

保持不变

2、blog

server:port: 10020
spring:# 应用名称application:name: blog# 设置激活配置文件profiles:active: devcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicloadbalancer:cache:enabled: false
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug

可以看到对应的内容被输出出来了（并且若指定激活的配置文件没有对应的内容会去默认的配置文件中寻到对应的内容进行填充）
在这里插入图片描述

5、Sentinal

5.1、下载运行

要根据springcloud-alibaba版本下载对应的版本：https://github.com/alibaba/Sentinel/releases/download/1.8.3/sentinel-dashboard-1.8.3.jar

java -jar -Dserver.port=8858 -Dsentinel.dashboard.auth.username=sentinel -Dsentinel.dashboard.auth.password=sentinel sentinel-dashboard-1.8.3.jar

5.2、添加依赖

1、account

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

2、blog

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

5.3、修改配置文件

1、account

server:port: 10010
spring:# 应用名称application:name: accountcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: public# sentinel配置sentinel:transport:dashboard: localhost:8858loadbalancer:cache:enabled: false

2、blog

server:port: 10020
spring:# 应用名称application:name: blog# 设置激活配置文件profiles:active: devcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: public# sentinel配置sentinel:transport:dashboard: localhost:8858loadbalancer:cache:enabled: false
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug

5.4、修改controller

1、account

// account/src/main/java/com/example/controller/HelloController.java
@RestController
@RefreshScope
public class HelloController {@Value("${server.port}")String port;@Value("${user.name}")String userName;@Value("${user.age}")String age;@RequestMapping("/account/{name}")@SentinelResourcepublic String hello(@PathVariable("name") String name) {System.out.println(name);return "Hello " + userName + " " + age;}@RequestMapping("/account/common")@SentinelResourcepublic String common() {return JSON.toJSONString(new Account("xumeng03", 22));}
}

2、blog

// blog/src/main/java/com/example/controller/HelloController.java
@RestController
@RefreshScope
public class HelloController {@AutowiredRestTemplate restTemplate;@AutowiredAccountOpenfeign accountOpenfeign;@Value("${environment.name}")String env;@RequestMapping("/blog")@SentinelResourcepublic String hello() {return accountOpenfeign.hello("xumeng03") + " " + env;}@RequestMapping("/blog/common")@SentinelResourcepublic String common() {return JSON.toJSONString(new Blog("title", "content"));}
}

5.5、服务面板

访问几次服务接口，就可以在sentinel dashboard里面看到服务
在这里插入图片描述

在这里插入图片描述

5.6、限流（QPS）

1、account

配置服务降级

// account/src/main/java/com/example/controller/HelloController.java
@RestController
@RefreshScope
public class HelloController {@Value("${server.port}")String port;@Value("${user.name}")String userName;@Value("${user.age}")String age;@RequestMapping("/account/{name}")@SentinelResource(value = "account", blockHandler = "blockHandler")public String hello(@PathVariable("name") String name) {System.out.println(name);return "Hello " + userName + " " + age;}@RequestMapping("/account/common")@SentinelResource(value = "account-common", blockHandler = "blockHandler")public String common() {return JSON.toJSONString(new Account("xumeng03", 22));}public String blockHandler(BlockException blockException) {return "流控";}
}

添加流控
在这里插入图片描述

在这里插入图片描述

多刷新几次
在这里插入图片描述

5.7、限流（并发线程）

1、blog

配置服务降级

// blog/src/main/java/com/example/controller/HelloController.java
@RestController
@RefreshScope
public class HelloController {@AutowiredRestTemplate restTemplate;@AutowiredAccountOpenfeign accountOpenfeign;@Value("${environment.name}")String env;@RequestMapping("/blog")@SentinelResource(value = "blog", blockHandler = "blockHandler")public String hello() {return accountOpenfeign.hello("xumeng03") + " " + env;}@RequestMapping("/blog/common")@SentinelResource(value = "blog-common", blockHandler = "blockHandler")public String common() throws InterruptedException {Thread.sleep(5000);return JSON.toJSONString(new Blog("title", "content"));}public String blockHandler(BlockException blockException) {return "流控" + blockException.toString();}
}

添加流控
在这里插入图片描述

在这里插入图片描述

多刷新几次
在这里插入图片描述

5.8、异常统一处理

1、设置统一异常处理

// blog/src/main/java/com/example/exception/BlockException.java
@Configuration
public class BlockException implements BlockExceptionHandler {@Overridepublic void handle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, com.alibaba.csp.sentinel.slots.block.BlockException e) throws Exception {String msg = "";if (e instanceof FlowException) {msg = "接口限流";} else if (e instanceof DegradeException) {msg = "服务降级";} else if (e instanceof ParamFlowException) {msg = "热点参数限流";} else if (e instanceof SystemBlockException) {msg = "触发系统保护规则";} else if (e instanceof AuthorityException) {msg = "授权规则不通过";}httpServletResponse.setStatus(500);httpServletResponse.setCharacterEncoding("utf-8");httpServletResponse.setHeader("content-type", "text/html; charset=UTF-8");httpServletResponse.getWriter().write(msg);}
}

2、设置流控

在这里插入图片描述

3、测试

在这里插入图片描述

5.9、限流（关联）

当接口具有资源竞争的时候，接口便有了关联，此时若重要接口访问频率变高，需要限制不重要的接口的访问

1、添加流控

在这里插入图片描述

在这里插入图片描述

2、Jmeter访问

线程组配置
在这里插入图片描述

取样器配置
在这里插入图片描述

3、测试

在这里插入图片描述

在这里插入图片描述

5.10、限流（链路）

1、修改配置文件

server:port: 10010
spring:# 应用名称application:name: accountcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: public# sentinel配置sentinel:transport:dashboard: localhost:8858# 添加链路展开web-context-unify: falseloadbalancer:cache:enabled: false

2、修改service

@Service
public class Blogservice {@SentinelResource(value = "new-account")public String newAccount() {return JSON.toJSONString(new Account("xumeng03", 22));}
}

3、修改controller

@RestController
public class LinkController {@AutowiredBlogservice blogservice;@RequestMapping("/blog/link1")public String link1() {return blogservice.newAccount();}@RequestMapping("/blog/link2")public String link2() {return blogservice.newAccount();}
}

4、修改流控

在这里插入图片描述

在这里插入图片描述

5、测试

在这里插入图片描述

5.11、熔断（慢调用）

1、controller

@RestController
public class BlowController {@RequestMapping("/blog/blow")public String blow() throws InterruptedException {Thread.sleep(2000);return "blow";}
}

2、修改熔断

在这里插入图片描述

在这里插入图片描述

3、测试

在这里插入图片描述

等待一分钟，第一次访问正常，但因为超时，随后再次进入熔断

5.12、熔断（异常）

1、controller

@RestController
public class BlowController {@RequestMapping("/blog/blow")public String blow() throws InterruptedException {Thread.sleep(2000);return "blow";}@RequestMapping("/blog/blow1")public String blow1() {throw new  RuntimeException("自定义异常");}
}

2、修改熔断

在这里插入图片描述
在这里插入图片描述

3、测试

在这里插入图片描述

等待一分钟，第一次访问正常，但因为超时，随后再次进入熔断

5.13、整合openfeign

1、account

@RestController
@RefreshScope
public class HelloController {@Value("${server.port}")String port;@Value("${user.name}")String userName;@Value("${user.age}")String age;@RequestMapping("/account/{name}")@SentinelResource(value = "account", blockHandler = "blockHandler")public String hello(@PathVariable("name") String name) {return "Hello " + userName + " " + age;}@RequestMapping("/account1/{name}")@SentinelResource(value = "account", blockHandler = "blockHandler")public String hello1(@PathVariable("name") String name) {int a = 1 / 0;return "Hello " + userName + " " + age;}@RequestMapping("/account/common")@SentinelResource(value = "account-common", blockHandler = "blockHandler")public String common() {return JSON.toJSONString(new Account("xumeng03", 22));}public String blockHandler(BlockException blockException) {return "流控";}
}

2、blog

FeignClient

@FeignClient(name = "account", fallback = AccountOpenfeignFallback.class)
public interface AccountOpenfeign {@RequestMapping("/account/{name}")String hello(@PathVariable("name") String name);@RequestMapping("/account1/{name}")String hello1(@PathVariable("name") String name);
}

FeignClientFallback

@Component
public class AccountOpenfeignFallback implements AccountOpenfeign  {@Override@RequestMapping("/account/{name}")public String hello(@PathVariable("name") String name){return "远程服务异常，服务降级";}@Override@RequestMapping("/account1/{name}")public String hello1(@PathVariable("name") String name){return "远程服务异常，服务降级";}
}

controller

@RestController
@RefreshScope
public class HelloController {@AutowiredRestTemplate restTemplate;@Qualifier("com.example.openfeign.AccountOpenfeign")@AutowiredAccountOpenfeign accountOpenfeign;@Value("${environment.name}")String env;@RequestMapping("/blog")@SentinelResource(value = "blog", blockHandler = "blockHandler")public String hello() {return accountOpenfeign.hello("xumeng03") + " " + env;}@RequestMapping("/blog1")public String hello1() {System.out.println("blog1");return accountOpenfeign.hello1("xumeng03") + " " + env;}@RequestMapping("/blog/common")@SentinelResource(value = "blog-common", blockHandler = "blockHandler")public String common() throws InterruptedException {Thread.sleep(5000);return JSON.toJSONString(new Blog("title", "content"));}public String blockHandler(BlockException blockException) {return "流控" + blockException.toString();}
}

3、测试

在这里插入图片描述

5.14、热点流控

1、设置流控

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

2、测试

在这里插入图片描述

5.15、系统保护规则

在这里插入图片描述

6、Seata

6.1、下载

要根据springcloud-alibaba版本下载对应的版本：https://github.com/seata/seata/releases/download/v1.4.2/seata-server-1.4.2.zip

6.2、数据库准备

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE DATABASE seata;
USE seata;
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_gmt_modified_status` (`gmt_modified`, `status`),KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8;-- 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 = InnoDBDEFAULT CHARSET = utf8;-- 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),`gmt_create`     DATETIME,`gmt_modified`   DATETIME,PRIMARY KEY (`row_key`),KEY `idx_branch_id` (`branch_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8;

6.3、存储模式(DB)

seata-server-1.4.2\conf\file.conf

## transaction log store, only used in seata-server
store {## store mode: file、db、redismode = "db"## rsa decryption public keypublicKey = ""## database store propertydb {## the implement of javax.sql.DataSource, such as DruidDataSource(druid)/BasicDataSource(dbcp)/HikariDataSource(hikari) etc.datasource = "druid"## mysql/oracle/postgresql/h2/oceanbase etc.dbType = "mysql"driverClassName = "com.mysql.jdbc.Driver"## if using mysql to store the data, recommend add rewriteBatchedStatements=true in jdbc connection paramurl = "jdbc:mysql://150.158.24.200:3306/seata?rewriteBatchedStatements=true"user = "root"password = "123456"minConn = 5maxConn = 100globalTable = "global_table"branchTable = "branch_table"lockTable = "lock_table"queryLimit = 100maxWait = 5000}
}

6.4、整合Nacos

要根据springcloud-alibaba版本下载对应的版本：https://github.com/seata/seata/tree/1.4.2 (script\config-center\nacos)

seata-server-1.4.2\conf\registry.conf

registry {# file 、nacos 、eureka、redis、zk、consul、etcd3、sofatype = "nacos"nacos {application = "seata-server"serverAddr = "150.158.24.200:8848"group = "SEATA_GROUP"namespace = ""cluster = "default"username = "nacos"password = "nacos"}
}config {# file、nacos 、apollo、zk、consul、etcd3type = "nacos"nacos {serverAddr = "150.158.24.200:8848"namespace = ""group = "SEATA_GROUP"username = "nacos"password = "nacos"dataId = "seataServer.properties"}
}

6.5、配置中心

script\config-center\config.txt

新增seataServer.properties

transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
service.vgroupMapping.my_test_tx_group=default
service.default.grouplist=127.0.0.1:8091
service.enableDegrade=false
service.disableGlobalTransaction=false
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000
store.mode=db
store.publicKey=
store.file.dir=file_store/data
store.file.maxBranchSessionSize=16384
store.file.maxGlobalSessionSize=512
store.file.fileWriteBufferCacheSize=16384
store.file.flushDiskMode=async
store.file.sessionReloadReadSize=100
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://150.158.24.200:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123456
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
store.redis.mode=single
store.redis.single.host=127.0.0.1
store.redis.single.port=6379
store.redis.sentinel.masterName=
store.redis.sentinel.sentinelHosts=
store.redis.maxConn=10
store.redis.minConn=1
store.redis.maxTotal=100
store.redis.database=0
store.redis.password=
store.redis.queryLimit=100
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
log.exceptionRate=100
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

6.6、启动

seata-server-1.4.2\bin\seata-server.bat

6.7、配置数据库

CREATE DATABASE user;
USE user;
CREATE TABLE user.user(id int primary key auto_increment,name varchar(20),coin int
);
-- 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 = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';CREATE DATABASE blog;
USE blog;
CREATE TABLE blog.blog(id int primary key auto_increment,title varchar(100),coin_number int
);
-- 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 = InnoDBAUTO_INCREMENT = 1DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table';

6.8、项目添加数据库配置

1、account

添加依赖

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</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-jdbc</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.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.8</version></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {private int id;private String name;private int coin;
}

mapper

@Repository
public interface UserMapper {@Select("select * from user where id=#{id}")User selectUser(@Param("id") int id);@Update("update user set coin=#{coin} where id=#{id}")int updateUser(User user);
}

service

@Service
public class UserService {@AutowiredUserMapper userMapper;public User selectUser(int id) {return userMapper.selectUser(id);}public int updateUser(int id) {User user = userMapper.selectUser(id);user.setCoin(user.getCoin() - 1);return userMapper.updateUser(user);}
}

controller

@RestController
@RefreshScope
public class HelloController {@Value("${server.port}")String port;@Value("${user.name}")String userName;@Value("${user.age}")String age;@AutowiredUserService userService;@RequestMapping("/account/{name}")@SentinelResource(value = "account", blockHandler = "blockHandler")public String hello(@PathVariable("name") String name) {return "Hello " + userName + " " + age;}@RequestMapping("/account1/{name}")public String hello1(@PathVariable("name") String name) {int a = 1 / 0;System.out.println("blog1");return "Hello " + userName + " " + age;}@RequestMapping("/account/common")@SentinelResource(value = "account-common", blockHandler = "blockHandler")public String common() {return JSON.toJSONString(new Account("xumeng03", 22));}public String blockHandler(@PathVariable("name") String name, BlockException blockException) {return "流控";}@RequestMapping("/account2/{id}")public String hello(@PathVariable("id") int id) {return JSON.toJSONString(userService.selectUser(id));}@RequestMapping("/account3/{id}")public int updateUser(@PathVariable("id") int id) {return userService.updateUser(id);}
}

修改启动类

@SpringBootApplication
@MapperScan("com.example.mapper")
public class AccountApplication {public static void main(String[] args) {SpringApplication.run(AccountApplication.class, args);}
}

2、blog

添加依赖

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</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-jdbc</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.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.8</version></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

实体类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Blog1 {private int id;private String title;private int coin_number;
}

mapper

@Repository
public interface BlogMapper {@Select("select * from blog where id=#{id}")Blog1 selectBlog(@Param("id") int id);@Update("update blog set coin_number=#{coin_number} where id=#{id}")int updateBlog(Blog1 blog1);
}

service

@Service
public class Blogservice {@AutowiredBlogMapper blogMapper;@AutowiredRestTemplate restTemplate;@Qualifier("com.example.openfeign.AccountOpenfeign")@AutowiredAccountOpenfeign accountOpenfeign;@SentinelResource(value = "new-account")public String newAccount() {return JSON.toJSONString(new Account("xumeng03", 22));}public Blog1 selectBlog(int id) {return blogMapper.selectBlog(id);}@Transactionalpublic String seata(int id) {Blog1 blog1 = blogMapper.selectBlog(id);blog1.setCoin_number(blog1.getCoin_number() + 1);blogMapper.updateBlog(blog1);accountOpenfeign.updateUser(1);//restTemplate.getForObject("http://account/account3/1", String.class);return "success";}
}

controller

@RestController
@RefreshScope
public class HelloController {@AutowiredRestTemplate restTemplate;@AutowiredBlogservice blogservice;@Qualifier("com.example.openfeign.AccountOpenfeign")@AutowiredAccountOpenfeign accountOpenfeign;@Value("${environment.name}")String env;@RequestMapping("/blog")@SentinelResource(value = "blog", blockHandler = "blockHandler")public String hello() {return accountOpenfeign.hello("xumeng03") + " " + env;}@RequestMapping("/blog1")public String hello1() {System.out.println("blog1");return accountOpenfeign.hello1("xumeng03") + " " + env;}@RequestMapping("/blog/common")@SentinelResource(value = "blog-common", blockHandler = "blockHandler")public String common() throws InterruptedException {Thread.sleep(5000);return JSON.toJSONString(new Blog("title", "content"));}public String blockHandler(BlockException blockException) {return "流控" + blockException.toString();}@RequestMapping("/blog/{id}")public String selectBlog(@PathVariable("id") int id) {return JSON.toJSONString(blogservice.selectBlog(id));}@RequestMapping("/blog/seata")public String seata() {return blogservice.seata(1);}
}

修改启动类

@SpringBootApplication
// 添加启用FeignClients
@EnableFeignClients
@MapperScan("com.example.mapper")
public class BlogApplication {public static void main(String[] args) {SpringApplication.run(BlogApplication.class, args);}
}

6.9、测试

测试发现正常扣减，可在Blogservice.java添加异常，此时Transactional事务将不会回滚远程服务的数据

6.10、配置分布式事务

1、account

添加依赖

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>account</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</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-jdbc</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.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.8</version></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

application.yaml

server:port: 10010
spring:# 应用名称application:name: accountcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicgroup: SEATA_GROUP# sentinel配置sentinel:transport:dashboard: localhost:8858web-context-unify: falseloadbalancer:cache:enabled: falsedatasource:driver-class-name: com.mysql.jdbc.Driverusername: rootpassword: 123456url: jdbc:mysql://150.158.24.200:3306/user?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
seata:enabled: truetx-service-group: my_test_tx_groupservice:# 事务群组vgroupMapping:my_test_tx_group: default  # default 的值为集群的名字，在配置 seata service 的时候指定的registry:type: nacosnacos:# nacos地址server-addr: 150.158.24.200:8848application: seata-server# nacos用户名username: nacos# nacos密码password: nacosgroup: SEATA_GROUPconfig:type: nacosnacos:# nacos地址server-addr: 150.158.24.200:8848# nacos用户名username: nacos# nacos密码password: nacosgroup: SEATA_GROUPdataId: seataServer.properties

2、blog

添加依赖

<?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"><modelVersion>4.0.0</modelVersion><parent><groupId>com.example</groupId><artifactId>springcloud-demo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>blog</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>com.example</groupId><artifactId>common</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</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-bootstrap</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</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-jdbc</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.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.8</version></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId></dependency></dependencies><!--构建相关--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.revision}</version><executions><execution><goals><!--可以把依赖的包都打包到生成的Jar包中--><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

application.yaml

server:port: 10020
spring:# 应用名称application:name: blog# 设置激活配置文件profiles:active: devcloud:# nacos配置nacos:# nacos地址server-addr: 150.158.24.200:8848discovery:# nacos用户名username: nacos# nacos密码password: nacos# nacos命名空间namespace: publicgroup: SEATA_GROUP# sentinel配置sentinel:transport:dashboard: localhost:8858web-context-unify: falseloadbalancer:cache:enabled: falsedatasource:driver-class-name: com.mysql.jdbc.Driverusername: rootpassword: 123456url: jdbc:mysql://150.158.24.200:3306/blog?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
logging:level:# 路径为FeignClient的路径com.example.openfeign.AccountOpenfeign: debug
feign:sentinel:enabled: true
seata:enabled: trueenable-auto-data-source-proxy: truetx-service-group: my_test_tx_groupservice:# 事务群组vgroupMapping:my_test_tx_group: default  # default 的值为集群的名字，在配置 seata service 的时候指定的registry:type: nacosnacos:# nacos地址server-addr: 150.158.24.200:8848application: seata-server# nacos用户名username: nacos# nacos密码password: nacosgroup: SEATA_GROUPconfig:type: nacosnacos:# nacos地址server-addr: 150.158.24.200:8848# nacos用户名username: nacos# nacos密码password: nacosgroup: SEATA_GROUPdataId: seataServer.properties

service

@Service
public class Blogservice {@AutowiredBlogMapper blogMapper;@AutowiredRestTemplate restTemplate;@Qualifier("com.example.openfeign.AccountOpenfeign")@AutowiredAccountOpenfeign accountOpenfeign;@SentinelResource(value = "new-account")public String newAccount() {return JSON.toJSONString(new Account("xumeng03", 22));}public Blog1 selectBlog(int id) {return blogMapper.selectBlog(id);}//@Transactional@GlobalTransactionalpublic String seata(int id) {Blog1 blog1 = blogMapper.selectBlog(id);blog1.setCoin_number(blog1.getCoin_number() + 1);blogMapper.updateBlog(blog1);accountOpenfeign.updateUser(1);//restTemplate.getForObject("http://account/account3/1", String.class);return "success";}
}

6.11、测试

测试发现正常扣减，可在Blogservice.java添加异常，此时Transactional事务将回滚所有数据库操作

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/17717.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

（LFPAK56）BUK7Y7R0-40HX 40V、N 通道BUK9Y6R5-40HX表面贴装汽车用MOSFET器件

（LFPAK56）BUK7Y7R0-40HX 40V、N 通道BUK9Y6R5-40HX表面贴装汽车用MOSFET器件

汽车用MOSFET将低压超级结技术与先进的封装设计相结合&#xff0c;以实现高性能和耐用性。Trench 9 MOSFET系列产品全部符合AEC-Q101标准&#xff0c;且超越了这一国际汽车级标准的要求&#xff0c;在包括温度循环 (TC)、耐高温栅极偏置 (HTGB)、耐高温反向偏置 (HTRB) 和断续工…
阅读更多...
开篇（变量、运算符、进制）

开篇（变量、运算符、进制）

一、Java简介 JDK&#xff08;JRE&#xff08;JVM & API&#xff09;、Java language&#xff08;tools & APIs&#xff09;&#xff09;&#xff1b;java源文件 → javac的编译 → class类&#xff08;会生成一个或多个class文件&#xff09;&#xff1b; * 使用 jav…
阅读更多...
ARM_异常处理流程_编写软中断swi验证保存现场和恢复现场

ARM_异常处理流程_编写软中断swi验证保存现场和恢复现场

keil .text .global _start _start:1.构建异常向量表b resetb undefb software_interruptb prefetch_abortb data_abortb .b irqb fiq reset:系统上电之后处于svc模式初始化svc模式下的栈指针ldr sp,0x400008002.从SVC模式切换到user模式 msr cpsr,#0xD0mrs r0,cpsrorr r0,r0,…
阅读更多...
时序预测 | Matlab+Python实现基于高斯混合模型聚类结合CNN-BiLSTM-Attention的风电场短期功率预测

时序预测 | Matlab+Python实现基于高斯混合模型聚类结合CNN-BiLSTM-Attention的风电场短期功率预测

时序预测 | MatlabPython实现基于高斯混合模型聚类结合CNN-BiLSTM-Attention的风电场短期功率预测 目录 时序预测 | MatlabPython实现基于高斯混合模型聚类结合CNN-BiLSTM-Attention的风电场短期功率预测效果一览基本介绍模型描述程序设计参考资料 效果一览 基本介绍 基于高斯混…
阅读更多...
LinearAlgebraMIT_4_矩阵的LU分解

LinearAlgebraMIT_4_矩阵的LU分解

矩阵做逆变换需要要反过来&#xff0c;如下&#xff0c; 转置的逆等于逆的转置。 在知道了上面的基础知识后&#xff0c;我们进行矩阵的分解&#xff0c;常见如LU分解和LDU分解&#xff0c;如下&#xff0c; 在这里&#xff0c;我们首先具有一个矩阵A&#xff0c;我们对矩阵A进…
阅读更多...
(转载)极限学习机(extreme learning machine, ELM)的回归拟合及分类(matlab实现)

(转载)极限学习机(extreme learning machine, ELM)的回归拟合及分类(matlab实现)

单隐含层前馈神经网络(single-hidden layer feedforward neural network,SLFN)以其良好的学习能力在许多领域中得到了广泛的应用。然而&#xff0c;传统的学习算法(如BP算法等)固有的一些缺点&#xff0c;成为制约其发展的主要瓶颈。前馈神经网络大多采用梯度下降方法&#xff…
阅读更多...
C语言，指针易错点

C语言，指针易错点

1、封装函数&#xff0c;用指针实现字符串连接 #include <stdio.h> #include <string.h> void MyStrcat(char *dest,char *src) {int i;for(i0;*(desti);i);for(int j0;*(srcj);j)*(desti)*(srcj);*(desti)0; } int main(int argc, const char *argv[]) {char des…
阅读更多...
Sentinel持久化实战

Sentinel持久化实战

前言 Sentinel有pull&#xff08;拉&#xff09;模式&#xff0c;和push&#xff08;推&#xff09;模式。本文是使用reids实现pull模式。 通过SPI机制引入自己的类 在项目的 resources > META-INF > services下创建新文件&#xff0c;文件名如下&#xff0c;内容是自…
阅读更多...
宝塔 安装/使用/备份数据 Jenkins-图文小白教程

宝塔 安装/使用/备份数据 Jenkins-图文小白教程

一、Jenkins包下载 大家可以从Jenkins官网&#xff08;https://www.jenkins.io/&#xff09;根据自己的需要下载最新的版本。 但Jenkins官网下载较慢&#xff0c;容易造成下载失败。可以去国内的开源镜像网站下载Jenkins最新版本。目前博主使用的是清华大学的开源镜像网站&…
阅读更多...
浅谈Node.js中的npm和yarn

浅谈Node.js中的npm和yarn

官方文档&#xff1a; npmhttps://www.npmjs.cn/ yarnhttps://yarn.bootcss.com/ npm和yarn的作用 yarn和npm都是构建和打包javascript代码的工具 区别 npm&#xff1a; 1npm使得js开发者易于分享其为解决特定问题而编写的代码&#xff0c;且可供其他开发者在他们自己的应…
阅读更多...
第十一章：C语言数据结构与算法初阶之排序

第十一章：C语言数据结构与算法初阶之排序

系列文章目录 文章目录 系列文章目录前言排序的概念及其运用排序的概念常见的排序算法 常见排序算法的实现1.直接插入排序2. 希尔排序&#xff08;缩小增量排序&#xff09;3. 直接选择排序4. 堆排序5. 冒泡排序6. 快速排序将区间按照基准值划分为左右两半部分的常见方式&#…
阅读更多...
4 切割纸片

4 切割纸片

4 切割纸片 作者: 赵晓鹏时间限制: 1S章节: 动态规划与贪心 ---------------------------------输入 6 4 1 1 0 1 0 0 0 1 0 0 0 1 0 0 0 1 0 0 1 1 0 0 1 1 --------------------输出结果 4 #include <iostream> #include <vector> #include <climits&g…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023