Spring Cloud之Config分布式配置应⽤

package com.qf.product.fifter; import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.cloud.gateway.filter.GlobalFilter; import org.springframework.core.Ordered; import org.springframework.core.io.buffer.DataBuffer; import org.springframework.http.HttpStatus; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.http.server.reactive.ServerHttpResponse; import org.springframework.stereotype.Component; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; import java.util.ArrayList; import java.util.List; /** * 定义全局过滤器，会对所有路由⽣效 */ @Slf4j @Component public class BlackListGlobalFilter implements GlobalFilter, Ordered { // 模拟⿊名单(实际可以去数据库或者Redis中查询) private static List<String> blackList = new ArrayList<>(); static { // 模拟本机地址 blackList.add("127.0.0.1"); blackList.add("10.48.185.11"); } /** * 过滤器核⼼⽅法 * * @param exchange 封装了request和response对象的上下⽂ * @param chain ⽹关过滤器链(包含全局过滤器和单路由过滤器) * @return */ @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { /* 实现思路：获取客户端IP，判断是否在⿊名单中，在的话就拒绝访问，不在的话就放⾏ */ // 从上下⽂中取出request和response对象 ServerHttpRequest request = exchange.getRequest(); ServerHttpResponse response = exchange.getResponse(); // 从request对象中获取客户端IP String clientIP = request.getRemoteAddress().getHostString(); log.info("=====>IP: " + clientIP); // 获取到客户端IP后去⿊名单中查询，存在的话就决绝访问 if (blackList.contains(clientIP)) { // 状态码 response.setStatusCode(HttpStatus.UNAUTHORIZED); String data = "Request be denied!"; //响应的字符串转化成字节数组，将来输出返回客户端 DataBuffer wrap = response.bufferFactory().wrap(data.getBytes()); // 决绝访问，直接返回指定结果数据 return response.writeWith(Mono.just(wrap)); } // 合法请求，放⾏，执⾏后续的过滤器 return chain.filter(exchange); } /** * 返回值表示当前过滤器的顺序(优先级)，数值越⼩，优先级越⾼ */ @Override public int getOrder() { return 0; } }