<!--nacos注冊(cè)中心-->
    <dependency>
      <groupId>com.alibaba.cloud</groupId>
      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</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>

server:
  port: 8100
logging:
  path: d:/
spring:
  application:
    name: gateway-service
  cloud:
    nacos:
      server-addr: localhost:8848
    sentinel:
      transport:
        dashboard: localhost:8080
    gateway:
      routes:
        - id: mqtt-service-route
          uri: lb://mqtt-service
          predicates:
            - Path=/mqtt/**
        - id: usermgr-service-route
          uri: lb://usermgr-service
          predicates:
            - Path=/usermgr/**

spring:
  cloud:
    ## 整合sentinel，配置sentinel控制臺(tái)的地址
    sentinel:
      #配置限流之后，響應(yīng)內(nèi)容
      scg:
        fallback:
          ## 兩種模式，一種是response返回文字提示信息，
          ## 一種是redirect，重定向跳轉(zhuǎn)，需要同時(shí)配置redirect(跳轉(zhuǎn)的uri)
          mode: response
          ## 響應(yīng)的狀態(tài)
          response-status: 200
          ## 響應(yīng)體
          response-body: '{"code": 200,"message": "請(qǐng)求失敗，稍后重試！"}'

{
    "code": 200,
    "message": "請(qǐng)求失敗，稍后重試！"
}

spring:
  cloud:
    ## 整合sentinel，配置sentinel控制臺(tái)的地址
    sentinel:
      #配置限流之后，響應(yīng)內(nèi)容
      scg:
        fallback:
          ## 兩種模式，一種是response返回文字提示信息，一種是redirect，重定向跳轉(zhuǎn)，需要同時(shí)配置redirect(跳轉(zhuǎn)的uri)
          mode: redirect
          ## 跳轉(zhuǎn)的URL
          redirect: http://www.baidu.com

package com.spacetime.gateway.config;

import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerResponse;

import javax.annotation.PostConstruct;
import java.util.HashMap;
import java.util.Map;

@Configuration
public class GatewayConfig {
    /**
     * 自定義限流處理器
     */
    @PostConstruct
    public void initBlockHandlers() {
        BlockRequestHandler blockHandler = (serverWebExchange, throwable) -> {
            Map map = new HashMap();
            map.put("code",200);
            map.put("message","請(qǐng)求失敗，稍后重試！");
            return ServerResponse.status(HttpStatus.OK)
                    .contentType(MediaType.APPLICATION_JSON_UTF8)
                    .body(BodyInserters.fromObject(map));
        };
        GatewayCallbackManager.setBlockHandler(blockHandler);
    }
}