環(huán)境準(zhǔn)備

• 注冊(cè)中心Nacos，也可以其他
• springboot 2.6.8
• spring-cloud-dependencies 2021.0.3

1.pom依賴

parent包

<parent>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-parent</artifactId>
	<version>2.6.8</version>
</parent>

gateway依賴

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--服務(wù)注冊(cè)與發(fā)現(xiàn)-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
	<version>2021.0.1.0</version>
</dependency>
<!--遠(yuǎn)程服務(wù)路由-->
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-loadbalancer</artifactId>
</dependency>

springcloud版本管理

<dependencyManagement>
	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-dependencies</artifactId>
			<version>2021.0.3</version>
			<type>pom</type>
			<scope>import</scope>
		</dependency>
	</dependencies>
</dependencyManagement>

2.yaml配置

spring:
  application:
    name: gatewayservice
  cloud:
    #找對(duì)應(yīng)網(wǎng)段的網(wǎng)卡 不配置內(nèi)部服務(wù)就走外網(wǎng)
    inetutils:
      preferred-networks: 192.168.0
    nacos:
      discovery:
          #nacos注冊(cè)地址
        server-addr: 192.168.0.221:8848
    gateway:
      routes:
      - id: user
          #根據(jù)服務(wù)名轉(zhuǎn)發(fā) 只需要名稱 不用端口
        uri: lb://userservice
        #ip的形式轉(zhuǎn)發(fā)
#        uri: http://127.0.0.1:7540
        predicates:
        #路由規(guī)則
        - Path=/user/**
        filters:
        #1/去掉前綴 0/保持原路徑
        - StripPrefix=1
      #跨域配置 
      globalcors:
        cors-configurations:
          '[/**]':
            # 允許攜帶認(rèn)證信息
            allowCredentials: true
            # 允許跨域的源(網(wǎng)站域名/ip)，設(shè)置*為全部
            allowedOriginPatterns: "*"
            # 允許跨域的method， 默認(rèn)為GET和OPTIONS，設(shè)置*為全部
            allowedMethods: "*"
            # 允許跨域請(qǐng)求里的head字段，設(shè)置*為全部
            allowedHeaders: "*"

#本地靜態(tài)路由配置 jar包依賴不一樣
#my-load-balanced-service:
#  ribbon:
#    listOfServers: http://127.0.0.1:7540,http://127.0.0.1:7541
    #輪詢
#    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule

3.路由轉(zhuǎn)發(fā)和負(fù)載均衡測(cè)試

啟動(dòng)不同端口的user服務(wù)，然后通過(guò)gateway調(diào)用

user服務(wù)暴露接口

訪問(wèn)地址http://127.0.0.1:7500/user/test

@Value("${server.port}")
String port;
@GetMapping("/test")
public String test() {
    return new Date().getTime() + ":" + port;
}

返回結(jié)果輸出

1657261506117:7540
1657261509785:7541
1657261513874:7540
1657261517464:7541

可以正常路由轉(zhuǎn)發(fā)和負(fù)載均衡，默認(rèn)策略是輪詢

4.gateway熔斷實(shí)現(xiàn)

熔斷：就是通過(guò)在轉(zhuǎn)發(fā)過(guò)程中失敗的，從而采取的降級(jí)策略。良好的返回提示給前端。

4.1 熔斷代碼

@Component
public class FallbackHandler implements ErrorWebExceptionHandler {
    @Override
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
        String message = "服務(wù)正在維護(hù),請(qǐng)稍后再試!";
        byte[] bytes = String.format("{\"code\":-1,\"message\":\"%s\",\"data\":null}",
                message).getBytes(StandardCharsets.UTF_8);
        DataBuffer buffer = exchange.getResponse().bufferFactory().wrap(bytes);
        exchange.getResponse().getHeaders().setContentType(MediaType.APPLICATION_JSON);
        return exchange.getResponse().writeWith(Flux.just(buffer));
    }
}

本來(lái)是想通過(guò)Hystrix直接配置重定向的，奈何spring-cloud-starter-netflix-hystrix已經(jīng)不更新了，沒(méi)法兼容。直接采用一刀切算了。

4.2 測(cè)試

開(kāi)啟gateway和user服務(wù)訪問(wèn)后，然后停掉user。結(jié)果如下

{"code":-1,"message":"服務(wù)正在維護(hù),請(qǐng)稍后再試!","data":null}

在這里需要注意的兩個(gè)點(diǎn)

• 如果配置的是服務(wù)名，gateway先注冊(cè)轉(zhuǎn)發(fā)服務(wù)還沒(méi)注冊(cè)到Nacos時(shí)，訪問(wèn)就不會(huì)走熔斷，會(huì)提示No servers available for service: userservice
• 如果配置的是http地址，無(wú)對(duì)應(yīng)的服務(wù)存在時(shí)則可以正常走熔斷

5.gateway限流

用的是自帶的令牌桶算法，例如總共十個(gè)令牌，每秒恢復(fù)一個(gè)，那么一秒內(nèi)最大只能獲取10個(gè)令牌，超過(guò)的則直接控制掉返回429 Too Many Requests

5.1 需要集成redis

pom依賴如下

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>

5.2 yaml配置

#引入數(shù)據(jù)庫(kù)
redis:
  database: 0
  host: 192.168.0.100
  port: 6379

//限流策略
gateway:
  routes:
  - id: user
    uri: lb://userservice
    predicates:
    - Path=/user/**
    filters:
    #名稱不可修改
    - name: RequestRateLimiter
      args:
          #限流策略名 通過(guò)代碼注入到spring容器中去
        key-resolver: "#{@ipKeyResolver}"
        #令牌桶每秒填充平均速率
        redis‐rate‐limiter.replenishRate: 1
        #令牌桶總?cè)萘?br />        redis‐rate‐limiter.burstCapacity: 2
        # 每次請(qǐng)求獲取的令牌數(shù)
        redis-rate-limiter.requestedTokens: 1

上述配置含義：針對(duì)ip限流，總令牌數(shù)2，沒(méi)秒恢復(fù)一個(gè)，每次獲取一個(gè)。也就是說(shuō)一秒內(nèi)超過(guò)2次則會(huì)被限流。

注意上述限流配置缺一不可，不然啟動(dòng)也不會(huì)報(bào)錯(cuò)，也不會(huì)生效，重點(diǎn)是轉(zhuǎn)發(fā)也不成功了

5.3 注入到spring容器

//針對(duì)ip限流
@Primary
@Bean(value = "ipKeyResolver")
public KeyResolver ipKeyResolver() {
    return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getAddress().getHostAddress());
}
//針對(duì)路徑限流
//    @Bean(name = "apiKeyResolver")
public KeyResolver apiKeyResolver() {
    return exchange -> Mono.just(exchange.getRequest().getPath().value());
}

5.4 測(cè)試

訪問(wèn)http://127.0.0.1:7500/user/test，一秒內(nèi)訪問(wèn)三次

redis截圖

網(wǎng)頁(yè)端截圖

限流生效！

到此這篇關(guān)于SpringCloud Gateway詳細(xì)分析實(shí)現(xiàn)負(fù)載均衡與熔斷和限流的文章就介紹到這了,更多相關(guān)SpringCloud Gateway負(fù)載均衡內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論