zuul动态配置路由规则,从DB读取
前面已经讲过zuul在application.yml里配置路由规则,将用户请求分发至不同微服务的例子。
zuul作为一个网关,是用户请求的入口,担当鉴权、转发的重任,理应保持高可用性和具备动态配置的能力。
我画了一个实际中可能使用的配置框架,如图。
当用户发起请求后,首先通过并发能力强、能承担更多用户请求的负载均衡器进行第一步的负载均衡,将大量的请求分发至多个网关服务。这是分布式的第一步。如果是使用docker的话,并且使用rancher进行docker管理,那么可以很简单的使用rancher自带的负载均衡,创建HaProxy,将请求分发至多个Zuul的docker容器。使用多个zuul的原因即是避免单点故障,由于网关非常重要,尽量配置多个实例。
然后在Zuul网关中,执行完自定义的网关职责后,将请求转发至另一个HaProxy负载的微服务集群,同样是避免微服务单点故障和性能瓶颈。
最后由具体的微服务处理用户请求并返回结果。
那么为什么要设置zuul的动态配置呢,因为网关其特殊性,我们不希望它重启再加载新的配置,而且如果能实时动态配置,我们就可以完成无感知的微服务迁移替换,在某种程度还可以完成服务降级的功能。
zuul的动态配置也很简单,这里我们参考http://blog.csdn.net/u013815546/article/details/68944039 并使用他的方法,从数据库读取配置信息,刷新配置。
看实现类
配置文件里我们可以不配置zuul的任何路由,全部交给数据库配置。
package com.tianyalei.testzuul.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.cloud.netflix.zuul.filters.RefreshableRouteLocator;
import org.springframework.cloud.netflix.zuul.filters.SimpleRouteLocator;
import org.springframework.cloud.netflix.zuul.filters.ZuulProperties;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.util.StringUtils;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
public class CustomRouteLocator extends SimpleRouteLocator implements RefreshableRouteLocator {
public final static Logger logger = LoggerFactory.getLogger(CustomRouteLocator.class);
private JdbcTemplate jdbcTemplate;
private ZuulProperties properties;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public CustomRouteLocator(String servletPath, ZuulProperties properties) {
super(servletPath, properties);
this.properties = properties;
logger.info("servletPath:{}", servletPath);
}
//父类已经提供了这个方法,这里写出来只是为了说明这一个方法很重要!!!
// @Override
// protected void doRefresh() {
// super.doRefresh();
// }
@Override
public void refresh() {
doRefresh();
}
@Override
protected Map<String, ZuulProperties.ZuulRoute> locateRoutes() {
LinkedHashMap<String, ZuulProperties.ZuulRoute> routesMap = new LinkedHashMap<>();
//从application.properties中加载路由信息
routesMap.putAll(super.locateRoutes());
//从db中加载路由信息
routesMap.putAll(locateRoutesFromDB());
//优化一下配置
LinkedHashMap<String, ZuulProperties.ZuulRoute> values = new LinkedHashMap<>();
for (Map.Entry<String, ZuulProperties.ZuulRoute> entry : routesMap.entrySet()) {
String path = entry.getKey();
// Prepend with slash if not already present.
if (!path.startsWith("/")) {
path = "/" + path;
}
if (StringUtils.hasText(this.properties.getPrefix())) {
path = this.properties.getPrefix() + path;
if (!path.startsWith("/")) {
path = "/" + path;
}
}
values.put(path, entry.getValue());
}
return values;
}
private Map<String, ZuulProperties.ZuulRoute> locateRoutesFromDB() {
Map<String, ZuulProperties.ZuulRoute> routes = new LinkedHashMap<>();
List<ZuulRouteVO> results = jdbcTemplate.query("select * from gateway_api_define where enabled = true ", new
BeanPropertyRowMapper<>(ZuulRouteVO.class));
for (ZuulRouteVO result : results) {
if (StringUtils.isEmpty(result.getPath()) ) {
continue;
}
if (StringUtils.isEmpty(result.getServiceId()) && StringUtils.isEmpty(result.getUrl())) {
continue;
}
ZuulProperties.ZuulRoute zuulRoute = new ZuulProperties.ZuulRoute();
try {
BeanUtils.copyProperties(result, zuulRoute);
} catch (Exception e) {
logger.error("=============load zuul route info from db with error==============", e);
}
routes.put(zuulRoute.getPath(), zuulRoute);
}
return routes;
}
public static class ZuulRouteVO {
/**
* The ID of the route (the same as its map key by default).
*/
private String id;
/**
* The path (pattern) for the route, e.g. /foo/**.
*/
private String path;
/**
* The service ID (if any) to map to this route. You can specify a physical URL or
* a service, but not both.
*/
private String serviceId;
/**
* A full physical URL to map to the route. An alternative is to use a service ID
* and service discovery to find the physical address.
*/
private String url;
/**
* Flag to determine whether the prefix for this route (the path, minus pattern
* patcher) should be stripped before forwarding.
*/
private boolean stripPrefix = true;
/**
* Flag to indicate that this route should be retryable (if supported). Generally
* retry requires a service ID and ribbon.
*/
private Boolean retryable;
private Boolean enabled;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getPath() {
return path;
}
public void setPath(String path) {
this.path = path;
}
public String getServiceId() {
return serviceId;
}
public void setServiceId(String serviceId) {
this.serviceId = serviceId;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public boolean isStripPrefix() {
return stripPrefix;
}
public void setStripPrefix(boolean stripPrefix) {
this.stripPrefix = stripPrefix;
}
public Boolean getRetryable() {
return retryable;
}
public void setRetryable(Boolean retryable) {
this.retryable = retryable;
}
public Boolean getEnabled() {
return enabled;
}
public void setEnabled(Boolean enabled) {
this.enabled = enabled;
}
}
}
package com.tianyalei.testzuul.config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.web.ServerProperties;
import org.springframework.cloud.netflix.zuul.filters.ZuulProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
@Configuration
public class CustomZuulConfig {
@Autowired
ZuulProperties zuulProperties;
@Autowired
ServerProperties server;
@Autowired
JdbcTemplate jdbcTemplate;
@Bean
public CustomRouteLocator routeLocator() {
CustomRouteLocator routeLocator = new CustomRouteLocator(this.server.getServletPrefix(), this.zuulProperties);
routeLocator.setJdbcTemplate(jdbcTemplate);
return routeLocator;
}
}
下面的config类功能就是使用自定义的RouteLocator类,上面的类就是这个自定义类。
里面主要是一个方法,locateRoutes方法,该方法就是zuul设置路由规则的地方,在方法里做了2件事,一是从application.yml读取配置的路由信息,二是从数据库里读取路由信息,所以数据库里需要一个各字段和ZuulProperties.ZuulRoute一样的表,存储路由信息,从数据库读取后添加到系统的Map<String, ZuulProperties.ZuulRoute>中。
在实际的路由中,zuul就是按照Map<String, ZuulProperties.ZuulRoute>里的信息进行路由转发的。
建表语句:
create table `gateway_api_define` (
`id` varchar(50) not null,
`path` varchar(255) not null,
`service_id` varchar(50) default null,
`url` varchar(255) default null,
`retryable` tinyint(1) default null,
`enabled` tinyint(1) not null,
`strip_prefix` int(11) default null,
`api_name` varchar(255) default null,
primary key (`id`)
) engine=innodb default charset=utf8
INSERT INTO gateway_api_define (id, path, service_id, retryable, strip_prefix, url, enabled) VALUES ('user', '/user/**', null,0,1, 'http://localhost:8081', 1);
INSERT INTO gateway_api_define (id, path, service_id, retryable, strip_prefix, url, enabled) VALUES ('club', '/club/**', null,0,1, 'http://localhost:8090', 1);
通过上面的两个类,再结合前面几篇讲过的zuul的使用,就可以自行测试一下在数据库里配置的信息能否在zuul中生效了。
数据库里的各字段分别对应原本在yml里配置的同名属性,如path,service_id,url等,等于把配置文件存到数据库里。
至于修改数据库值信息后(增删改),让zuul动态生效需要借助于下面的方法
package com.tianyalei.testzuul.config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.netflix.zuul.RoutesRefreshedEvent;
import org.springframework.cloud.netflix.zuul.filters.RouteLocator;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
@Service
public class RefreshRouteService {
@Autowired
ApplicationEventPublisher publisher;
@Autowired
RouteLocator routeLocator;
public void refreshRoute() {
RoutesRefreshedEvent routesRefreshedEvent = new RoutesRefreshedEvent(routeLocator);
publisher.publishEvent(routesRefreshedEvent);
}
}
可以定义一个Controller,在Controller里调用refreshRoute方法即可,zuul就会重新加载一遍路由信息,完成刷新功能。通过修改数据库,然后刷新,经测试是正常的。
@RestController
public class RefreshController {
@Autowired
RefreshRouteService refreshRouteService;
@Autowired
ZuulHandlerMapping zuulHandlerMapping;
@GetMapping("/refreshRoute")
public String refresh() {
refreshRouteService.refreshRoute();
return "refresh success";
}
@RequestMapping("/watchRoute")
public Object watchNowRoute() {
//可以用debug模式看里面具体是什么
Map<String, Object> handlerMap = zuulHandlerMapping.getHandlerMap();
return handlerMap;
}
}
参考http://blog.csdn.net/u013815546/article/details/68944039,作者从源码角度讲解了动态配置的使用。
————————————————
版权声明:本文为CSDN博主「天涯泪小武」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/tianyaleixiaowu/article/details/77933295
zuul动态配置路由规则,从DB读取相关推荐
- zuul默认的路由规则及禁用路由规则
- drools动态配置规则_微服务实战系列(八)-网关springcloud gateway自定义规则
1. 场景描述 先说明下项目中使用的网关是:springcloud gateway, 因需要给各个网关服务系统提供自定义配置路由规则,实时生效,不用重启网关(重启风险大),目前已实现:动态加载自定义路 ...
- SpringCloud - Spring Cloud Netflix 之 Zuul网关;路由(十一)
阅读本文前可先参考 SpringCloud - Spring Cloud根/父项目,开发准备(二)_MinggeQingchun的博客-CSDN博客 一.API网关 引自百度百科 API网关,软件术语 ...
- Dubbo 路由规则之条件路由
Dubbo 路由规则之条件路由 前言 大家好,今天开始给大家分享 - Dubbo 专题之 Dubbo 路由规则之条件路由.在前一个章节中我们介绍了 Dubbo 令牌验证和优雅停机,以及我们也例举了常见 ...
- 如何为服务器配置路由协议,服务器如何配置路由
服务器如何配置路由 内容精选 换一换 对等连接创建完成后,两个VPC还是不能互通.以下排查思路根据原因的出现概率进行排序,建议您从高频率原因往低频率原因排查,从而帮助您快速找到问题的原因.如果解决完某 ...
- Dubbo负载均衡和路由规则的区别
点击关注强哥,查看更多精彩文章呀 哈喽,大家好,我是强哥. 大家知道,强哥之前有一篇推文Dubbo也支持基于应用粒度的服务发现机制啦中说到,Dubbo2.x版本目前大都还是使用接口粒度的服务发现机制. ...
- SpringCloud系列——Zuul 动态路由
前言 Zuul 是在Spring Cloud Netflix平台上提供动态路由,监控,弹性,安全等边缘服务的框架,是Netflix基于jvm的路由器和服务器端负载均衡器,相当于是设备和 Netflix ...
- gateway配置mysql_使用Gateway配置路由以及动态路由
1. 新建module cloud-gateway-gateway9527 2. pom.xml cloud2020 com.atguigu.springcloud 1.0-SNAPSHOT 4.0. ...
- Zuul动态路由及动态Filter实现
一, Zuul动态路由实现 动态路由需要达到可持久化配置,动态刷新的效果.不仅要能满足从spring的配置文件properties加载路由信息,还需要从Redis加载我们的配置.另外一点是,路由信息在 ...
最新文章
- 查看Linux并发连接数
- SQL------Hint
- 接口自动化测试系列(一):HTTP状态码
- FAR,FRR,EER
- 很多人都不清楚HEX文件格式
- python 神经网络原理_神经网络理论基础及Python实现
- 用Supermemo背单词达到8000词条
- mysql用来干嘛的_CPU占用又爆了?MySQL到底在干什么
- cpu与简单模型机设计实验_180套经典夹具设计方案(附详解+模型),原来夹具设计这么简单!...
- MATLAB加入螺旋相位板调制,螺旋相位板的操作原理和使用手册_维尔克斯光电
- 3dmax2014 uv用法_3DSMAX演示一个硬表面模型UV展开的方法
- IE加载ocx时提示控件不安全的解决方法
- 水滴筹创始人:除中国以外不推行996;字节跳动2021年净亏损6041亿!
- try{}里面有一个return语句,那么紧跟在这个try后的finally{}里的code会不会被执行,什么时候被执行,在return前还是后?
- Jodd-Java的瑞士军刀 demo
- 如何搭建多功能会议室
- 漫画:有趣的扔鸡蛋问题
- VS2017安装Spy++工具
- 北斗GPS校时服务器(卫星授时)应用于机场网络系统集成
- 关于人脸识别,一篇很好的文章
热门文章
- 求助帖;RxtxFAX怎样通过调用传真服务器的串口COM1,COM2,通过电话线座机号发送传真?
- 日志门面框架Slf4j
- ios 获取当前准确时间
- nashorn_Nashorn简介
- idea如何全局替换
- SVN: File ‘xxxx‘ is locked in another working copy解决办法
- snownlp的准确度也太低了吧[伤心][伤心]是不是只能弄购物评论数据集啊
- 计算机无法读取盘,该图显示了如何修复计算机无法读取的USB闪存盘(SD卡)!...
- 用于时间序列数据的泊松回归模型
- 好用好看的Linux系统嵌入式操作系统