gateway:
  ignoreUrls:
    - /auth/login
    - /auth/register
    - /public/**

package com.cyt.gateway.filter;
@Component // 聲明為Spring容器中的一個Bean
@RequiredArgsConstructor // 生成構(gòu)造方法，注入final成員變量
@EnableConfigurationProperties(AuthProperties.class) // 啟用配置類AuthProperties的屬性注入
public class AuthGlobalFilter implements GlobalFilter, Ordered {
    // 從配置文件中注入白名單路徑列表，用于存放不需要JWT校驗的路徑
    @Value("${gateway.ignoreUrls}")
    private List<String> ignoreUrls;
    private final JwtTool jwtTool; // JWT工具類，用于解析和校驗JWT
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 1. 獲取Request對象，以訪問請求的相關(guān)信息
        ServerHttpRequest request = exchange.getRequest();
        // 2. 判斷請求路徑是否在白名單中（無需JWT校驗）
        if (isIgnoreUrl(request.getPath().toString())) {
            // 路徑在白名單中，直接放行請求
            return chain.filter(exchange);
        }
        // 3. 獲取請求頭中的token（假設(shè)token放在"authorization"頭部）
        String token = null;
        List<String> headers = request.getHeaders().get("authorization");
        if (!CollUtils.isEmpty(headers)) { // 如果請求頭包含authorization字段
            token = headers.get(0); // 獲取第一個token值
        }
        // 4. 使用jwtTool校驗并解析token
        Long userId = null;
        try {
            userId = jwtTool.parseToken(token); // 解析并獲取用戶ID
        } catch (UnauthorizedException e) {
            // 如果token無效或解析失敗，則返回401狀態(tài)碼并攔截請求
            ServerHttpResponse response = exchange.getResponse();
            response.setRawStatusCode(401);
            return response.setComplete(); // 返回空的響應(yīng)結(jié)束處理
        }
        // TODO 5. 如果token有效，可在此處傳遞用戶信息（如通過exchange.getAttributes()）
        System.out.println("userId = " + userId); // 打印用戶ID供調(diào)試
        // 6. 放行請求
        return chain.filter(exchange);
    }
    /**
     * 判斷路徑是否在白名單中
     *
     * @param path 請求路徑
     * @return 如果路徑在白名單中返回true，否則返回false
     */
    private boolean isIgnoreUrl(String path) {
        for (String ignoreUrl : ignoreUrls) {
            // 使用正則匹配白名單路徑中的通配符 "**"
            if (path.matches(ignoreUrl.replace("**", ".*"))) {
                return true; // 路徑匹配白名單中的某一項，返回true
            }
        }
        return false; // 沒有匹配到任何白名單路徑，返回false
    }
    @Override
    public int getOrder() {
        return 0; // 設(shè)置過濾器優(yōu)先級，值越小優(yōu)先級越高
    }
}

// 5.傳遞用戶信息
// 將解析出的用戶ID轉(zhuǎn)換為字符串，以便可以在請求頭中傳遞
String userInfo = userId.toString();
// 使用 exchange.mutate() 方法創(chuàng)建一個新的 ServerWebExchange 對象，
// 該對象將攜帶額外的請求頭 "user-info"，包含用戶ID信息。
// .mutate() 方法用于復(fù)制當(dāng)前請求并進行修改。
// 在這里，我們使用 request(builder -> builder.header(...)) 方式為請求添加一個新的頭部。
ServerWebExchange modifiedExchange = exchange.mutate()
        .request(builder -> builder.header("user-info", userInfo)) // 將 "user-info" 頭設(shè)置為用戶ID字符串
        .build(); // 完成新的 ServerWebExchange 對象的構(gòu)建
// 6.放行
// 使用修改后的 ServerWebExchange 對象繼續(xù)執(zhí)行過濾鏈。
// 這樣，下游服務(wù)可以通過 "user-info" 請求頭獲取到用戶ID信息。
return chain.filter(modifiedExchange);

@Bean
public RequestInterceptor userInfoRequestInterceptor(){
    // 定義一個 Feign 的 RequestInterceptor Bean，用于在請求發(fā)出前執(zhí)行自定義攔截操作
    return new RequestInterceptor() {
        @Override
        public void apply(RequestTemplate template) {
            // 獲取當(dāng)前登錄用戶的ID
            // UserContext 是一個上下文工具類，用于存儲和獲取當(dāng)前線程的用戶信息
            Long userId = UserContext.getUser();
            // 檢查用戶ID是否為 null，如果為 null 則表示用戶未登錄或無法獲取用戶信息
            if(userId == null) {
                // 如果用戶ID為空，不做任何處理，直接返回，跳過攔截器邏輯
                return;
            }
            // 如果用戶ID不為空，將用戶ID作為請求頭添加到 Feign 請求中
            // "user-info" 是請求頭的鍵，下游微服務(wù)可以從該請求頭中獲取用戶ID
            template.header("user-info", userId.toString());
        }
    };
}