Spring Cloud Alibaba 灰度发布教程#

1
  <properties>
2
        <java.version>17</java.version>
3
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
4
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
5
        <spring-boot.version>3.0.2</spring-boot.version>
6
        <spring-cloud-alibaba.version>2022.0.0.0</spring-cloud-alibaba.version>
7
    </properties>
8
    <dependencies>
9
        <dependency>
10
            <groupId>org.springframework.boot</groupId>
11
            <artifactId>spring-boot-starter-web</artifactId>
12
        </dependency>
13
        <dependency>
14
            <groupId>com.alibaba.cloud</groupId>
15
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
16
            <exclusions>
17
                <!-- 排除 Spring Cloud Alibaba 默认绑定的低版本 Nacos 客户端（2.2.x） -->
18
                <exclusion>
19
                    <groupId>com.alibaba.nacos</groupId>
20
                    <artifactId>nacos-client</artifactId>
21
                </exclusion>
22
            </exclusions>
23
        </dependency>
24
        <!-- 手动引入与服务端匹配的 Nacos 客户端 2.5.1 -->
25
        <dependency>
26
            <groupId>com.alibaba.nacos</groupId>
27
            <artifactId>nacos-client</artifactId>
28
            <version>2.5.1</version> <!-- 与你的 Nacos 服务端版本一致 -->
29
        </dependency>
30

31
        <dependency>
32
            <groupId>org.springframework.boot</groupId>
33
            <artifactId>spring-boot-starter-test</artifactId>
34
            <scope>test</scope>
35
        </dependency>
36
    </dependencies>
37
    <dependencyManagement>
38
        <dependencies>
39
            <dependency>
40
                <groupId>org.springframework.boot</groupId>
41
                <artifactId>spring-boot-dependencies</artifactId>
42
                <version>${spring-boot.version}</version>
43
                <type>pom</type>
44
                <scope>import</scope>
45
            </dependency>
46
            <dependency>
47
                <groupId>com.alibaba.cloud</groupId>
48
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
49
                <version>${spring-cloud-alibaba.version}</version>
50
                <type>pom</type>
51
                <scope>import</scope>
52
            </dependency>
53
        </dependencies>
54
    </dependencyManagement>

1
server:
2
  port: 8081
3
spring:
4
  application:
5
    name: my-service-v1  # 服务名称，必须一致以便网关发现
6
  cloud:
7
    nacos:
8
      discovery:
9
        server-addr: 127.0.0.1:8848  # Nacos 地址
10
#        namespace: gray-release  # 如果创建了自定义命名空间，使用此配置；否则删除此行，使用默认 public
11
        metadata:
12
          version: 1.0.0  # 元数据，用于版本区分
13
app:
14
  version: 1.0.0
15
logging:
16
  level:
17
    com.alibaba.nacos: DEBUG  # 启用 Nacos 注册日志，便于调试

1
server:
2
  port: 8082
3
spring:
4
  application:
5
    name: my-service-v2  # 服务名称，必须一致以便网关发现
6
  cloud:
7
    nacos:
8
      discovery:
9
        server-addr: 127.0.0.1:8848  # Nacos 地址
10
#        namespace: gray-release  # 如果创建了自定义命名空间，使用此配置；否则删除此行，使用默认 public
11
        metadata:
12
          version: 1.0.1  # 元数据，用于版本区分
13
app:
14
  version: 1.0.1
15
logging:
16
  level:
17
    com.alibaba.nacos: DEBUG  # 启用 Nacos 注册日志，便于调试

1
@RestController
2
@RequestMapping("/api")
3
public class TestController {
4
    @Value("${app.version}")
5
    private String version;
6

7
    @GetMapping("/test")
8
    public String test() {
9
        return "Version: " + version;
10
    }
11
}

1
    <properties>
2
        <java.version>17</java.version>
3
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
4
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
5
        <spring-boot.version>3.0.2</spring-boot.version>
6
        <spring-cloud-alibaba.version>2022.0.0.0</spring-cloud-alibaba.version>
7
        <spring-cloud.version>2022.0.1</spring-cloud.version>
8
    </properties>
9
    <dependencies>
10
        <dependency>
11
            <groupId>org.springframework.cloud</groupId>
12
            <artifactId>spring-cloud-starter-gateway</artifactId>
13
        </dependency>
14
        <dependency>
15
            <groupId>com.alibaba.cloud</groupId>
16
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
17
            <exclusions>
18
                <!-- 排除 Spring Cloud Alibaba 默认绑定的低版本 Nacos 客户端（2.2.x） -->
19
                <exclusion>
20
                    <groupId>com.alibaba.nacos</groupId>
21
                    <artifactId>nacos-client</artifactId>
22
                </exclusion>
23
            </exclusions>
24
        </dependency>
25
        <!-- 手动引入与服务端匹配的 Nacos 客户端 2.5.1 -->
26
        <dependency>
27
            <groupId>com.alibaba.nacos</groupId>
28
            <artifactId>nacos-client</artifactId>
29
            <version>2.5.1</version> <!-- 与你的 Nacos 服务端版本一致 -->
30
        </dependency>
31
        <dependency>
32
            <groupId>com.alibaba.cloud</groupId>
33
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
34
        </dependency>
35
        <dependency>
36
            <groupId>org.springframework.boot</groupId>
37
            <artifactId>spring-boot-starter-test</artifactId>
38
            <scope>test</scope>
39
        </dependency>
40
        <dependency>
41
            <groupId>org.springframework.cloud</groupId>
42
            <artifactId>spring-cloud-starter-loadbalancer</artifactId>
43
        </dependency>
44
    </dependencies>
45
    <dependencyManagement>
46
        <dependencies>
47
            <dependency>
48
                <groupId>org.springframework.cloud</groupId>
49
                <artifactId>spring-cloud-dependencies</artifactId>
50
                <version>${spring-cloud.version}</version>
51
                <type>pom</type>
52
                <scope>import</scope>
53
            </dependency>
54
            <dependency>
55
                <groupId>org.springframework.boot</groupId>
56
                <artifactId>spring-boot-dependencies</artifactId>
57
                <version>${spring-boot.version}</version>
58
                <type>pom</type>
59
                <scope>import</scope>
60
            </dependency>
61
            <dependency>
62
                <groupId>com.alibaba.cloud</groupId>
63
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
64
                <version>${spring-cloud-alibaba.version}</version>
65
                <type>pom</type>
66
                <scope>import</scope>
67
            </dependency>
68
        </dependencies>
69
    </dependencyManagement>

1
server:
2
  port: 8083
3
spring:
4
  application:
5
    name: gateway
6
  config:
7
    import: "optional:nacos:gateway.yaml"
8
  cloud:
9

10
    nacos:
11
      config:
12
        server-addr: localhost:8848
13
        file-extension: yaml
14
        name: gateway
15
        extension-configs:
16
          - data-id: gateway.yaml
17
            group: DEFAULT
18
            refresh: true
19
      discovery:
20
        server-addr: localhost:8848
21
logging:
22
  level:
23
    com.alibaba.nacos: DEBUG
24
    org.springframework.cloud.gateway: DEBUG  # 启用 Gateway 日志
25
    org.springframework.cloud.loadbalancer: TRACE  # 更详细的负载均衡日志
26

27
# 开启健康检查端点
28
management:
29
  endpoints:
30
    web:
31
      exposure:
32
        include: health,info
33
  endpoint:
34
    health:
35
      show-details: always

1
spring:
2
  cloud:
3
    gateway:
4
      discovery:
5
        locator:
6
          enabled: false  # 必须为false
7
      routes:
8
      - id: gray_route
9
        uri: lb://my-service-v2
10
        predicates:
11
        - Path=/api/**
12
        - Weight=group1, 50 #使用权重路由
13
        #- Header=gray-version, 1.0.1  # 精确匹配header
14
        metadata:
15
          version: 1.0.1
16
      - id: stable_route
17
        uri: lb://my-service-v1
18
        predicates:
19
        - Path=/api/**
20
        - Weight=group1, 50
21
        metadata:
22
          version: 1.0.0

1
import org.springframework.cloud.gateway.handler.predicate.AbstractRoutePredicateFactory;
2
import org.springframework.stereotype.Component;
3
import org.springframework.web.server.ServerWebExchange;
4

5
import java.util.function.Predicate;
6

7
@Component
8
public class GrayRoutePredicateFactory extends AbstractRoutePredicateFactory<GrayRoutePredicateFactory.Config> {
9
    public GrayRoutePredicateFactory() {
10
        super(Config.class);
11
    }
12

13
    @Override
14
    public Predicate<ServerWebExchange> apply(Config config) {
15
        return exchange -> {
16
            String userId = exchange.getRequest().getHeaders().getFirst("user-id");
17
            if (userId != null) {
18
                return Math.abs(userId.hashCode()) % 100 < config.getGrayPercentage();
19
            }
20
            return false;
21
        };
22
    }
23

24
    public static class Config {
25
        private int grayPercentage = 0;
26

27
        public int getGrayPercentage() {
28
            return grayPercentage;
29
        }
30

31
        public void setGrayPercentage(int grayPercentage) {
32
            this.grayPercentage = grayPercentage;
33
        }
34
    }
35
}