如何在springboot中使用zuul实现网关？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
1 添加依赖
计算
安全
数据库
网络和加速
企业服务
dependencies {
implementation('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client')
implementation('org.springframework.cloud:spring-cloud-starter-netflix-zuul')
testImplementation('org.springframework.boot:spring-boot-starter-test')
implementation('com.marcosbarbero.cloud:spring-cloud-zuul-ratelimit:1.3.2.RELEASE')
}2 添加yml
server:
port: 8300
spring:
application:
name: microservice-gateway-zuul
eureka:
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://localhost:6761/eureka
instance:
ip-address: true
zuul:
routes:
users:
path: /lind/** #以lind开头的路径被重定向到lind服务
serviceId: lind
add-host-header: true #显示真实的http头
retryable: false #关闭Hystrix的重试功能
ratelimit:
enabled: true
# repository: REDIS
behind-proxy: true
policies:
users:
limit: 5 #限流，每分钟请求5次
refresh-interval: 60
type:
- user
- origin
- url
# url类型的限流就是通过请求路径区分
# origin是通过客户端IP地址区分
# user是通过授权用户进行区分，也包括匿名用户3 添加实现代码
http拦截器，获取用户ID，为子服务进行传递
public class PreRequestLogFilter extends ZuulFilter {
private static final Logger logger = LoggerFactory.getLogger(PreRequestLogFilter.class);
private final RateLimiter rateLimiter = RateLimiter.create(1000.0);
@Override
public Object run() {
try {
RequestContext currentContext = RequestContext.getCurrentContext();
HttpServletResponse response = currentContext.getResponse();
HttpServletRequest reqeust = currentContext.getRequest();
currentContext.addZuulRequestHeader("userId","123");//向子系统http头写数据
currentContext.addZuulRequestHeader("userName","test");
PreRequestLogFilter.logger.info(
String.format("send %s request to %s",
reqeust.getMethod(),
reqeust.getRequestURL().toString()));
if (!rateLimiter.tryAcquire()) {
HttpStatus httpStatus = HttpStatus.TOO_MANY_REQUESTS;
response.setContentType(MediaType.TEXT_PLAIN_VALUE);
response.setStatus(httpStatus.value());
response.getWriter().append(httpStatus.getReasonPhrase());
currentContext.setSendZuulResponse(false);
throw new ZuulException(
httpStatus.getReasonPhrase(),
httpStatus.value(),
httpStatus.getReasonPhrase()
);
}
} catch (java.lang.Exception e) {
ReflectionUtils.rethrowRuntimeException(e);
}
return null;
}
@Override
public boolean shouldFilter() {
// 判断是否需要过滤
return true;
}
@Override
public String filterType() {
return FilterConstants.PRE_TYPE;
}
@Override
public int filterOrder() {
return Ordered.HIGHEST_PRECEDENCE;
}
}在主程中注入这个过滤器
@Bean
public PreRequestLogFilter preRequestLogFilter() {
return new PreRequestLogFilter();
}看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注亿速云行业资讯频道，感谢您对亿速云的支持。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
