spring:
  cloud:
	gateway:
	  routes:
	  - id: manager						# 路由唯一標(biāo)識(shí)
		uri: lb://manager_server		# 路由指向目的地URL或服務(wù)名，客戶(hù)端請(qǐng)求最終被轉(zhuǎn)發(fā)到的微服務(wù)
		predicates:
		- Path=/manager/** 				# 斷言：以manager開(kāi)頭的請(qǐng)求都負(fù)載到manager_server服務(wù)
		filters:
		- RewritePath=/manager/(?<segment>.*), /$\{segment} # 過(guò)濾器：過(guò)濾掉url里的manager,例如http://ip:port/manager/test -> http://ip:port/test
		order: 5						# 用于多個(gè)Route之間的排序，數(shù)值越小越靠前，匹配優(yōu)先級(jí)越高

spring:
  cloud:
    gateway:
      routes:
      - id: manager
        uri: https://manager_server
        predicates:
        - After=2017-01-20T17:42:47.789-07:00[America/Denver]	# 時(shí)間點(diǎn)后匹配
		- Before=2017-01-20T17:42:47.789-07:00[America/Denver]	# 時(shí)間點(diǎn)前匹配
		- Between=2017-01-20T17:42:47.789-07:00[America/Denver],2017-01-21T17:42:47.789-07:00[America/Denver]	# 時(shí)間區(qū)間匹配
		- Cookie=chocolate, ch.p						# 指定cookie正則匹配
		- Header=X-Request-Id, \d+						# 指定Header正則匹配
		- Host=**.somehost.org,**.anotherhost.org		# 請(qǐng)求Host匹配
		- Method=GET,POST								# 請(qǐng)求Method匹配指定請(qǐng)求方式
		- Path=/red/{segment},/blue/{segment}			# 請(qǐng)求路徑正則匹配
		- Query=green									# 請(qǐng)求包含某參數(shù)
		- Query=red, gree.								# 請(qǐng)求包含某參數(shù)并且參數(shù)值匹配正則表達(dá)式(匹配red;green,greet,gree...)
		- RemoteAddr=192.168.1.1/24						# 遠(yuǎn)程地址匹配
		# 設(shè)置分組和權(quán)重，按照路由權(quán)重選擇同一個(gè)分組中的路由
      - id: preManager1
        uri: https://preManager1
        predicates:
		- Weight=group1, 2
      - id: preManager2
        uri: https://preManager2
        predicates:
		- Weight=group1, 8

spring:
  cloud:
    gateway:
      routes:
      - id: gateway_filter
        uri: https://example.org
		predicates:
        - Path=/red/{segment}
        filters:
		# 1、為原始請(qǐng)求添加Header。headerName：X-Request-red，headerValue：blue。
        - AddRequestHeader=X-Request-red, blue		
		- AddRequestHeadersIfNotPresent=X-Request-Color-1:blue,X-Request-Color-2:green
		# 2、為原始請(qǐng)求添加參數(shù)。參數(shù)名,參數(shù)值
		- AddRequestParameter=red, blue
		# 3、為原始響應(yīng)添加Header
		- AddResponseHeader=X-Response-Red, Blue
		# 4、剔除響應(yīng)頭中重復(fù)的值
		- DedupeResponseHeader=Access-Control-Allow-Credentials Access-Control-Allow-Origin
		# 5、為原始請(qǐng)求路徑添加前綴
		- PrefixPath=/mypath
		# 6、配置該過(guò)濾器后，會(huì)原始請(qǐng)求的host頭信息，并原封不動(dòng)的轉(zhuǎn)發(fā)出去，而不是被gateway的http客戶(hù)端重置。
		- PreserveHostHeader
		# 7、將原始請(qǐng)求重定向到指定的URL，參數(shù)為http狀態(tài)碼及重定向的url
		- RedirectTo=302, https://acme.org
		# 8、移除響應(yīng)Body中的指定key
		- RemoveJsonAttributesResponseBody=id,color
		# 9、移除原始請(qǐng)求中的指定Header
		- RemoveRequestHeader=X-Request-Foo
		# 10、移除原始請(qǐng)求中的指定參數(shù)
		- RemoveRequestParameter=red
		# 11、移除響應(yīng)中的指定Header
		- RemoveResponseHeader=X-Response-Foo

spring:
  cloud:
    gateway:
      routes:
      - id: gateway_filter
        uri: https://example.org
		predicates:
        - Path=/red/{segment}
        filters:
		# 12、請(qǐng)求限流，限流算法為令牌桶，以下示例為根據(jù)用戶(hù)id做限流
		# @Configuration
		# public class RateLimiterConfig {
		#	  @Bean
		#	  public KeyResolver userKeyResolver() {
		#		  return exchange -> Mono.just(Objects.requireNonNull(exchange.getRequest().getQueryParams().getFirst("userId")));
		#     }
		# }
		- name: RequestRateLimiter
          args:
            redis-rate-limiter.replenishRate: 10	# 允許用戶(hù)每秒處理的請(qǐng)求數(shù)
            redis-rate-limiter.burstCapacity: 20	# 令牌桶的容量，即允許在 1 秒內(nèi)完成的最大請(qǐng)求數(shù)。設(shè)置為 0 則表示拒絕所有請(qǐng)求。
            key-resolver: "#{@userKeyResolver}"		# 一個(gè)引用名為 userKeyResolver 的 bean 的 SpEL 表達(dá)式
		# 13、重寫(xiě)原始的請(qǐng)求路徑
		- RewritePath=/red/?(?<segment>.*), /$\{segment}
		# 14、重寫(xiě)響應(yīng)中的某個(gè)Header
		- RewriteResponseHeader=X-Response-Red, , password=[^&]+, password=***
		# 15、在轉(zhuǎn)發(fā)請(qǐng)求之前，強(qiáng)制執(zhí)行websession::save操作，保存會(huì)話(huà)狀態(tài)
		- SaveSession
		# 16、修改原始的請(qǐng)求路徑
		- SetPath=/{segment}
		# 17、修改原始請(qǐng)求中的指定Header值
		- SetRequestHeader=X-Request-Red, Blue
		# 18、修改原始響應(yīng)中的指定Header值
		- SetResponseHeader=X-Response-Red, Blue
		# 19、修改原始響應(yīng)的響應(yīng)碼
		- SetStatus=401
		# 20、剝離原始請(qǐng)求路徑
		- StripPrefix=2
		# 21、請(qǐng)求重試
		- name: Retry
          args:
            retries: 3						# 重試次數(shù)
            statuses: BAD_GATEWAY			# 應(yīng)被重試的 HTTP Status Codes
            methods: GET,POST				# 應(yīng)被重試的 HTTP Methods
            backoff:						# 為重試配置指數(shù)級(jí)的 backoff。重試時(shí)間間隔的計(jì)算公式為 firstBackoff * (factor ^ n)，n 是重試的次數(shù)；如果設(shè)置了 maxBackoff，最大的 backoff 限制為 maxBackoff. 如果 basedOnPreviousValue 設(shè)置為 true, backoff 計(jì)算公式為 prevBackoff * factor.
              firstBackoff: 10ms
              maxBackoff: 50ms
              factor: 2
              basedOnPreviousValue: false
		# 22、設(shè)置允許接收最大請(qǐng)求包的大小。如果請(qǐng)求包大小超過(guò)設(shè)置的值，則返413Payload Too Large
		- name: RequestSize
          args:
            maxSize: 5000000

/**
* 定義全局過(guò)濾器，會(huì)對(duì)所有路由生效
*/
@Slf4j
@Component // 讓容器掃描到，等同于注冊(cè)了
public class BlackListFilter implements GlobalFilter, Ordered {
	// 模擬黑名單（實(shí)際可以去數(shù)據(jù)庫(kù)或者redis中查詢(xún)）
	private static List<String> blackList = new ArrayList<>();
	static {
		blackList.add("0:0:0:0:0:0:0:1"); // 模擬本機(jī)地址
	}
	/**
	* 過(guò)濾器核心方法
	* @param exchange 封裝了request和response對(duì)象的上下文
	* @param chain 網(wǎng)關(guān)過(guò)濾器鏈（包含全局過(guò)濾器和單路由過(guò)濾器）
	* @return
	*/
	@Override
	public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
		// 思路：獲取客戶(hù)端ip，判斷是否在黑名單中，在的話(huà)就拒絕訪(fǎng)問(wèn)，不在的話(huà)就放行
		ServerHttpRequest request = exchange.getRequest();
		ServerHttpResponse response = exchange.getResponse();
		// 從request對(duì)象中獲取客戶(hù)端ip
		String clientIp = request.getRemoteAddress().getHostString();
		// 拿著clientIp去黑名單中查詢(xún)，存在的話(huà)就決絕訪(fǎng)問(wèn)
		if(blackList.contains(clientIp)) {
			// 拒絕訪(fǎng)問(wèn)，返回
			response.setStatusCode(HttpStatus.UNAUTHORIZED); // 狀態(tài)碼
			log.debug("=====>IP:" + clientIp + " 在?名單中，將被拒絕訪(fǎng)問(wèn)！");
			String data = "Request be denied!";
			DataBuffer wrap = response.bufferFactory().wrap(data.getBytes());
			return response.writeWith(Mono.just(wrap));
		}
		// 合法請(qǐng)求，放行，執(zhí)行后續(xù)的過(guò)濾器
		return chain.filter(exchange);
	}
	/**
	* @return 過(guò)濾器的順序(優(yōu)先級(jí))，數(shù)值越小，優(yōu)先級(jí)越高
	*/
	@Override
	public int getOrder() {
		return 0;
	}
}

@Component
public class MyGlobalFilter implements GlobalFilter,Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        boolean token = exchange.getRequest().getHeaders().containsKey("token");
        System.out.println("----全局過(guò)濾器token----"+token);
        if (!token){
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            ServerHttpResponse response = exchange.getResponse();
            return response.setComplete();
        }
        return chain.filter(exchange);
    }
    @Override
    public int getOrder() {
        return 1;
    }
}

spring:
  cloud:
    gateway:
      discovery:
        locator:
          # 表明Gateway開(kāi)啟服務(wù)注冊(cè)和發(fā)現(xiàn)的功能，并且Spring Cloud Gateway自動(dòng)根據(jù)服務(wù)發(fā)現(xiàn)為每一個(gè)服務(wù)創(chuàng)建了一個(gè)router，這個(gè)router將以服務(wù)名開(kāi)頭的請(qǐng)求路徑轉(zhuǎn)發(fā)到對(duì)應(yīng)的服務(wù)
          enabled: true
          # 將請(qǐng)求路徑上的服務(wù)名配置為小寫(xiě)（因?yàn)榉?wù)注冊(cè)的時(shí)候，向注冊(cè)中心注冊(cè)時(shí)將服務(wù)名轉(zhuǎn)成大寫(xiě)的了）
          lower-case-service-id: true
      routes:
	  # 系統(tǒng)管理
      - id: sys-mgt
        uri: lb://sysmgt
        predicates:
        - Path=/sys-mgt/** 	#以sys-mgt開(kāi)頭的請(qǐng)求都負(fù)載到sysmgt服務(wù)
		- Method=GET		#只匹配GET請(qǐng)求
        filters:
        - RewritePath=/sys-mgt/(?<segment>.*), /$\{segment} #過(guò)濾掉url里的sys-mgt,例如http://ip:port/sys-mgt/test -> http://ip:port/test
		- PrefixPath=/mgt									#為請(qǐng)求添加/mgt前綴,再結(jié)合RewritePath過(guò)濾器，http://ip:port/sys-mgt/test -> http://ip:port/mgt/test