java造轮子:快速搭建一个网关服务,动态路由、鉴权看完就会(含流程图)
前言
本文记录一下我是如何使用Gateway搭建网关服务及实现动态路由的,帮助大家学习如何快速搭建一个网关服务,了解路由相关配置,鉴权的流程及业务处理,有兴趣的一定看到最后,非常适合没接触过网关服务的同学当作入门教程。
搭建服务
框架
SpringBoot 2.1
<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.0.RELEASE</version>
</parent>
Spring-cloud-gateway-core
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-gateway-core</artifactId>
</dependency>
common-lang3
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId>
</dependency>
路由配置
网关作为请求统一入口,路由就相当于是每个业务系统的入口,通过路由规则则可以匹配到对应微服务的入口,将请求命中到对应的业务系统中
server:port: 8080spring:cloud:gateway:enabled: trueroutes:- id: demo-serveruri: http://localhost:8081predicates:- Path=/demo-server/**filters:- StripPrefix= 1
routes
解读配置
现在有一个服务demo-server部署在本机,地址和端口为
127.0.0.1:8081
,所以路由配置uri为http://localhost:8081
使用网关服务路由到此服务,
predicates -Path=/demo-server/**
,网关服务的端口为8080,启动网关服务,访问localhost:8080/demo-server
,路由断言就会将请求路由到demo-server直接访问demo-server的接口
localhost:8081/api/test
,通过网关的访问地址则为localhost:8080/demo-server/api/test,predicates
配置将请求断言到此路由,filters-StripPrefix=1
代表将地址中/后的第一个截取,所以demo-server就截取掉了
使用gateway通过配置文件即可完成路由的配置,非常方便,我们只要充分的了解配置项的含义及规则就可以了;但是这些配置如果要修改则需要重启服务,重启网关服务会导致整个系统不可用,这一点是无法接受的,下面介绍如何通过Nacos实现动态路由
动态路由
使用nacos结合gateway-server实现动态路由,我们需要先部署一个nacos服务,可以使用docker部署或下载源码在本地启动,具体操作可以参考官方文档即可
Nacos配置
groupId: 使用网关服务名称即可
dataId: routes
配置格式:json
[{"id": "xxx-server","order": 1, #优先级"predicates": [{ #路由断言"args": {"pattern": "/xxx-server/**"},"name": "Path"}],"filters":[{ #过滤规则"args": {"parts": 0 #k8s服务内部访问容器为http://xxx-server/xxx-server的话,配置0即可},"name": "StripPrefix" #截取的开始索引}],"uri": "http://localhost:8080/xxx-server" #目标地址}]
json格式配置项与yaml中对应,需要了解配置在json中的写法
比对一下json配置与yaml配置
{"id":"demo-server","predicates":[{"args":{"pattern":"/demo-server/**"},"name":"Path"}],"filters":[{"args":{"parts":1},"name":"StripPrefix"}],"uri":"http://localhost:8081"
}
spring:cloud:gateway:enabled: trueroutes:- id: demo-serveruri: http://localhost:8081predicates:- Path=/demo-server/**filters:- StripPrefix= 1
代码实现
Nacos实现动态路由的方式核心就是通过Nacos配置监听,配置发生改变后执行网关相关api创建路由
@Component
public class NacosDynamicRouteService implements ApplicationEventPublisherAware {private static final Logger LOGGER = LoggerFactory.getLogger(NacosDynamicRouteService.class);@Autowiredprivate RouteDefinitionWriter routeDefinitionWriter;private ApplicationEventPublisher applicationEventPublisher;/** 路由id */private static List<String> routeIds = Lists.newArrayList();/*** 监听nacos路由配置,动态改变路由* @param configInfo*/@NacosConfigListener(dataId = "routes", groupId = "gateway-server")public void routeConfigListener(String configInfo) {clearRoute();try {List<RouteDefinition> gatewayRouteDefinitions = JSON.parseArray(configInfo, RouteDefinition.class);for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {addRoute(routeDefinition);}publish();LOGGER.info("Dynamic Routing Publish Success");} catch (Exception e) {LOGGER.error(e.getMessage(), e);}}/*** 清空路由*/private void clearRoute() {for (String id : routeIds) {routeDefinitionWriter.delete(Mono.just(id)).subscribe();}routeIds.clear();}@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.applicationEventPublisher = applicationEventPublisher;}/*** 添加路由* * @param definition*/private void addRoute(RouteDefinition definition) {try {routeDefinitionWriter.save(Mono.just(definition)).subscribe();routeIds.add(definition.getId());} catch (Exception e) {LOGGER.error(e.getMessage(), e);}}/*** 发布路由、使路由生效*/private void publish() {this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this.routeDefinitionWriter));}
}
过滤器
gateway提供GlobalFilter及Ordered两个接口用来定义过滤器,我们自定义过滤器只需要实现这个两个接口即可
GlobalFilter filter()
实现过滤器业务Ordered getOrder()
定义过滤器执行顺序
通常一个网关服务的过滤主要包含 鉴权(是否登录、是否黑名单、是否免登录接口...) 限流(ip限流等等)功能,我们今天简单介绍鉴权过滤器的流程实现
鉴权过滤器
需要实现鉴权过滤器,我们先得了解登录及鉴权流程,如下图所示
由图可知,我们鉴权过滤核心就是验证token是否有效,所以我们网关服务需要与业务系统在同一个redis库,先给网关添加redis依赖及配置
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>
spring:redis:host: redis-serverport: 6379password:database: 0
代码实现
定义过滤器AuthFilter
获取请求对象 从请求头或参数或cookie中获取token(支持多种方式传token对于客户端更加友好,比如部分web下载请求会新建一个页面,在请求头中传token处理起来比较麻烦)
没有token,返回401
有token,查询redis是否有效
无效则返回401,有效则完成验证放行
重置token过期时间、添加内部请求头信息方便业务系统权限处理
@Component
public class AuthFilter implements GlobalFilter, Ordered {@Autowiredprivate RedisTemplate<String, String> redisTemplate;private static final String TOKEN_HEADER_KEY = "auth_token";@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.获取请求对象ServerHttpRequest request = exchange.getRequest();// 2.获取tokenString token = getToken(request);ServerHttpResponse response = exchange.getResponse();if (StringUtils.isBlank(token)) {// 3.token为空 返回401response.setStatusCode(HttpStatus.UNAUTHORIZED);return response.setComplete();}// 4.验证token是否有效String userId = getUserIdByToken(token);if (StringUtils.isBlank(userId)) {// 5.token无效 返回401response.setStatusCode(HttpStatus.UNAUTHORIZED);return response.setComplete();}// token有效,后续业务处理// 从写请求头,方便业务系统从请求头获取用户id进行权限相关处理ServerHttpRequest.Builder builder = exchange.getRequest().mutate();request = builder.header("user_id", userId).build();// 延长缓存过期时间-token缓存用户如果一直在操作就会一直重置过期// 这样避免用户操作过程中突然过期影响业务操作及体验,只有用户操作间隔时间大于缓存过期时间才会过期resetTokenExpirationTime(token, userId);// 完成验证return chain.filter(exchange);}@Overridepublic int getOrder() {// 优先级 越小越优先return 0;}/*** 从redis中获取用户id* 在登录操作时候 登陆成功会生成一个token, redis得key为auth_token:token 值为用户id** @param token* @return*/private String getUserIdByToken(String token) {String redisKey = String.join(":", "auth_token", token);return redisTemplate.opsForValue().get(redisKey);}/*** 重置token过期时间** @param token* @param userId*/private void resetTokenExpirationTime(String token, String userId) {String redisKey = String.join(":", "auth_token", token);redisTemplate.opsForValue().set(redisKey, userId, 2, TimeUnit.HOURS);}/*** 获取token** @param request* @return*/private static String getToken(ServerHttpRequest request) {HttpHeaders headers = request.getHeaders();// 从请求头获取tokenString token = headers.getFirst(TOKEN_HEADER_KEY);if (StringUtils.isBlank(token)) {// 请求头无token则从url获取tokentoken = request.getQueryParams().getFirst(TOKEN_HEADER_KEY);}if (StringUtils.isBlank(token)) {// 请求头和url都没有token则从cookies获取HttpCookie cookie = request.getCookies().getFirst(TOKEN_HEADER_KEY);if (cookie != null) {token = cookie.getValue();}}return token;}
}
总结
Gateway通过配置项可以实现路由功能,整合Nacos及配置监听可以实现动态路由,实现GlobalFilter, Ordered两个接口可以快速实现一个过滤器,文中也详细的介绍了登录后的请求鉴权流程,如果有不清楚地方可以评论区见咯。
往期推荐
面试官:作为架构师,请你谈谈Saas 应用如何搭建?
设计微服务架构,相关设计模式如何运用?
SpringBoot中微服务技术中进程间通信原理
Spring Boot 接入支付宝支付案例教程!
纯干货 | 从淘宝到云端的高可用架构演进
到底什么是"超融合"呢?
MySQL 定时备份数据库(非常全),值得收藏!
回复【干货】获取精选干货视频教程
回复【加群】加入疑难问题攻坚交流群
回复【mat】获取内存溢出问题分析详细文档教程
回复【赚钱】获取用java写一个能赚钱的微信机器人
回复【副业】获取程序员副业攻略一份
好文请点赞+分享
java造轮子:快速搭建一个网关服务,动态路由、鉴权看完就会(含流程图)相关推荐
- 快速搭建一个网关服务,动态路由、鉴权看完就会(含流程图)
[文章来源]https://sourl.cn/tcbSPi 前 言 本文记录一下我是如何使用Gateway搭建网关服务及实现动态路由的,帮助大家学习如何快速搭建一个网关服务,了解路由相关配置,鉴权的流 ...
- 创建微服务架构的步骤_如何快速搭建一个微服务架构?
原标题:如何快速搭建一个微服务架构? 微服务火了很久,但网上很少有文章能做到成熟地将技术传播出来,同时完美地照顾"初入微服务领域人员",从 0 开始,采用通俗易懂的语言去讲解微服务 ...
- 如何快速搭建一个微服务架构
何谓微服务架构的简单模式? 相对于大型互联网平台动辄几万并发的访问量,或者每天多次的在线版本发布,绝大多数企业和项目并没有这样的需求.他们关注的是如何更好地提高开发效率,如何更快地实现新需求,如何更便 ...
- 【技术分享】Sanic+Amis:3天快速搭建一个web服务
前言 测试工作中,需要搭建一些生产力小工具来提高工作效率. 基于web的服务,无需终端可多人协作,易部署,成为第一选择. 问题:搭建web服务需要全栈知识,编写http服务和前端样式需要一定技术门槛. ...
- Java 通过gecco快速搭建一个爬虫框架
Java gecco 爬虫Demo Gecco是一款用java语言开发的轻量化的易用的网络爬虫框架. 官网: http://www.geccocrawler.com/ 1.导入依赖 <depen ...
- 快速正确的搭建一个微服务架构需要了解的那几个点
原文:https://my.oschina.net/u/3636867/blog/1803023 作者:烂猪皮 一.微服务架构四大特性 好的微服务架构是什么样的呢?想要搭建好一个微服务架构,必须要具备 ...
- 流媒体视频服务:快速搭建一个简单的流媒体视频服务(一)
快速搭建一个简单的流媒体视频服务 前言 系统组成 RTMP协议简介 Red5 概述 Red5 服务器搭建 前言 最近自己在研究有关于流媒体播放的技术,网上资料甚少.出于开源精神以及在查阅资料得到各位大 ...
- 动手造轮子:实现一个简单的依赖注入(二) --- 服务注册优化
动手造轮子:实现一个简单的依赖注入(二) --- 服务注册优化 Intro 之前实现的那版依赖注入框架基本可用,但是感觉还是不够灵活,而且注册服务和解析服务在同一个地方感觉有点别扭,有点职责分离不够. ...
- 使用Azure认知服务快速搭建一个目标检测平台
文章目录 前言 1. 认知服务 2. 环境配置 2.1 创建资源 2.2 创建python环境 3. 代码实现 3.1 图片检测 3.2 视频检测 4. 检测效果 结束语 前言 博主参与了由CSD ...
最新文章
- 新思科技Chekib:AI芯片架构创新面临四大挑战
- How does asp.net web api work?
- python爬取王者皮肤_Python爬取王者荣耀英雄皮肤高清图片
- 视音频数据处理入门:AAC音频码流解析
- C++ STL 中提供的算法
- java通过桥访问excel_通过jdbc-odbc桥来访问excel文件
- oracle创建表不在对应表空间,oracle创建表空间
- 数据库startup报错_SQL Server数据库恢复过程内部–数据库STARTUP命令
- 深度剖析 Linux 的 3 种“拷贝”命令
- 遇到问题的时候,要学会问问题
- Stick ------ 剪枝神题
- 时间管理之-----《暗时间》-刘未鹏
- 如何让Ubuntu联网
- PYTHON2.day14
- 【Day1.1】快速通道落地签,豪华大巴去华欣
- PHP的GD库函数大全
- win10系统解决office16的VBE6EXT.OLB不能被加载的问题
- 记应聘:华为 可信理论、技术与工程实验室 产品数据工程师
- 解放双手!无需注解快速生成API文档,跟SpringBoot绝配!
- 二十五个摸鱼,哦,不对,是炫酷(可以玩一整天)的网站!!!