写点什么

springcloud(三)网关 zuul,2021Java 进阶学习资料

作者:Java高工P7
  • 2021 年 11 月 10 日
  • 本文字数:1868 字

    阅读完需:约 6 分钟

<dependency>


<groupId>org.springframework.cloud</groupId>


<artifactId>spring-cloud-starter-netflix-zuul</artifactId>


</dependency>

3.编写配置文件 bootstrap.yml

![](htt


《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
浏览器打开:qq.cn.hn/FTe 免费领取
复制代码


ps://img-blog.csdnimg.cn/20191127094444340.png)


server:


port: 8400


spring:


application:


name: cloud-zuul


cloud:


config:


discovery:


enabled: true #如果希通过在配置中心找服务名的方式招待配置中心,那么这个属性就要设置成 true 默认 false


service-id: cloud-config #配置中心的服务名


fail-fast: true #将这个设置成 true 表示连接配置中心失败,让程序启动失败


eureka:


client:


service-url:


defaultZone: http://localhost:8761/eureka/ #注册中心地址


zuul:


routes: #路由


user: #随意命名,用于区分多个路由的唯一标识


path: /user/** #需要被转发的规则


serviceId: cloud-user #需要被转发的服务名称


order:


path: /order/**


serviceId: cloud-order


这里我配置了 cloud.config,但是我在 git 上面并没有新建 zuul 服务的配置文件,因为到目前没有使用到配置文件,但是后续很顶会用到,所以在这里配置了,如果你不需要这一段,可以删除,同时移除 spring-cloud-starter-config 的依赖。


需要注意的就是下面这段代码:



路由的转发由这里完成,如果不配置,zuul 也能做转发,但是路径就有限制,必须是 ip(zuul)+端口(zuul)+服务名+uri,例如:127.0.0.1:8400/cloud-user/test,这样也是可以访问的。

4.编辑启动类

package com.ymy;


import org.springframework.boot.SpringApplication;


import org.springframework.boot.autoconfigure.SpringBootApplication;


import org.springframework.cloud.client.discovery.EnableDiscoveryClient;


import org.springframework.cloud.netflix.zuul.EnableZuulProxy;


@SpringBootApplication


@EnableZuulProxy


@EnableDiscoveryClient


public class CloudZuulApplication {


public static void main(String[] args) {


SpringApplication.run(CloudZuulApplication.class, args);


}


}


@SpringBootApplication:springboot 启动注解


@EnableZuulProxy:开启 zuul 网关注解


@EnableDiscoveryClient:将 zuul 网关注册到注册中心


启动 cloud-eureka、cloud-config、cloud-user、cloud-order


访问:localhost:8400/user/test:



访问:localhost:8400/order/test:



这就已经说明请求已经被网关转发到各自的服务。


ZuulFilter




ZuulFilter 是什么?它主要负责路由、权限校验等等。


新建 MyFilter:


package com.ymy.filter;


import com.google.common.util.concurrent.RateLimiter;


import com.netflix.zuul.ZuulFilter;


import com.netflix.zuul.context.RequestContext;


import com.netflix.zuul.exception.ZuulException;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Component;


import javax.servlet.http.HttpServletRequest;


import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.*;


@Component


@Slf4j


public class MyFilter extends ZuulFilter {


private static final RateLimiter RATE_LIMITER = RateLimiter.create(1);


@Override


public String filterType() {


return PRE_TYPE;


}


@Override


public int filterOrder() {


return SIMPLE_HOST_ROUTING_FILTER_ORDER -1;


}


/**


  • 判断哪些请求需要校验,哪些请求直接放行

  • true:需要校验 false:直接放行

  • @return


*/


@Override


public boolean shouldFilter() {


RequestContext ctx = RequestContext.getCurrentContext();


//我这里模拟一下 请求 uri 携带 nofilter 的直接放行 否者需要校验


if( ctx.getRequest().getRequestURI().indexOf("nofilter") != -1){


//放行


return false;


}


//进入 run 方法进行校验


return true;


}


/**


  • 执行校验的方法

  • 返回 null 表示放行

  • @return

  • @throws ZuulException


*/


@Override


public Object run() throws ZuulException {


log.info("校验开始==========>");


RequestContext ctx = RequestContext.getCurrentContext();


boolean flag = RATE_LIMITER.tryAcquire();


if(!flag){


ctx.setSendZuulResponse(false);// 过滤该请求,不对其进行路由


ctx.setResponseStatusCode(401);// 返回错误码


ctx.getResponse().setHeader("Content-Type", "application/json;charset=UTF-8");


ctx.setResponseBody("{"result":"请求过于频繁!"}");// 返回错误内容


ctx.set("isSuccess", false);


return null;


}


log.info("放行=========>");


return null;


}


}

用户头像

Java高工P7

关注

还未添加个人签名 2021.11.08 加入

还未添加个人简介

评论

发布
暂无评论
springcloud(三)网关zuul,2021Java进阶学习资料