springcloud下的nacos集群与gateway网关

server:
  port: 7000
 
spring:
  application:
    name: springcloud-gateway

(4)创建 主启动类

@SpringBootApplication
public class GatewayApp {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApp.class,args);
    }
}

发现 : 路由配置时 uri 的地址还是一个固定的网络地址，如果后期微服务地址发送改变，也需要修改网关的配置。 不能完成负载均衡。

解决 : gateway 也是一个微服务，它可以从注册中心拉取服务信息

gateway 自动路由

2.3 介绍Gateway断言

2.4.过滤器

全局过滤器

1.引入fastjson依赖

        <dependency>
            <groupId>com.alibabagroupId>
            <artifactId>fastjsonartifactId>
            <version>1.2.83version>
        dependency>

2.创建Anon实体类

@Component
@ConfigurationProperties(prefix = "anon")
public class Anon {
    private List url;
    public List getUrl(){
        return url;
    }
    public void setUrl(List url){
        this.url=url;
    }
}

3.定义全局过滤器

@Component
public class LoginFilter implements GlobalFilter, Ordered {
 
    @Autowired
    private Anon anon;
 
    //过滤方法 过滤业务
    @Override
    public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        //获取请求
        String path = request.getPath().toString();
        //判断当前的请求路径是否为放行路径
        if(anon.getUrl().contains(path)){
            //放行
            return chain.filter(exchange);
        }
 
        //判断是否携带token
        String token = request.getHeaders().getFirst("token");
        //redis
        if(StringUtils.hasText(token)&&"admin".equals(token)){
            //放行
            return chain.filter(exchange);
        }
 
        //返回一个json数据
        //设置状态码
        response.setStatusCode(HttpStatus.UNAUTHORIZED);
 
        //封装返回数据
        Map map = new HashMap<>();
        map.put("msg","未登录");
        map.put("code",4000);
 
        //json转换
        byte[] bytes = JSON.toJSONString(map).getBytes(StandardCharsets.UTF_8);
 
        //调用bufferFactory方法，生成DataBuffer对象
        DataBuffer buffer = response.bufferFactory().wrap(bytes);
 
        //调用Mono中的just方法,返回给前端的json数据
        return response.writeWith(Mono.just(buffer));
    }
 
    @Override
    // 优先级 返回的值越小优先级越高
    public int getOrder() {
        return 0;
    }
}