Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单-阿里云开发者社区

开发者社区> 优惠码发放> 正文

Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单

简介: Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单一、说明网关的核心概念就是路由配置和路由规则,而作为所有请求流量的入口,在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启的,所以实现动态路由是非常有必要的;本文主要介绍实现的思路,并且以Nacos为数据源来讲解 二...
+关注继续查看

Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单
一、说明
网关的核心概念就是路由配置和路由规则,而作为所有请求流量的入口,在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启的,所以实现动态路由是非常有必要的;本文主要介绍实现的思路,并且以Nacos为数据源来讲解

二、实现要点
要实现动态路由只需关注下面4个点

网关启动时,动态路由的数据怎样加载进来
静态路由与动态路由以那个为准,ps:静态路由指的是配置文件里写死的路由配置
监听动态路由的数据源变化
数据有变化时怎样通知zuul刷新路由

三、具体实现
3.1. 实现动态路由的数据加载
重写SimpleRouteLocator类的locateRoutes方法,此方法是加载路由配置的,父类中是获取properties中的路由配置,可以通过扩展此方法,达到动态获取配置的目的
这里采用静态路由与动态路由共存,相同路由id以动态路由优先覆盖的实现方式
AbstractDynRouteLocator类可查看:AbstractDynRouteLocator.java

public abstract class AbstractDynRouteLocator extends SimpleRouteLocator implements RefreshableRouteLocator {

private ZuulProperties properties;

public AbstractDynRouteLocator(String servletPath, ZuulProperties properties) {
    super(servletPath, properties);
    this.properties = properties;
}

/**
 * 刷新路由
 */
@Override
public void refresh() {
    doRefresh();
}

@Override
protected Map<String, ZuulRoute> locateRoutes() {
    LinkedHashMap<String, ZuulRoute> routesMap = new LinkedHashMap<>();
    // 从application.properties中加载静态路由信息
    routesMap.putAll(super.locateRoutes());
    // 从数据源中加载动态路由信息
    routesMap.putAll(loadDynamicRoute());
    // 优化一下配置
    LinkedHashMap<String, ZuulRoute> values = new LinkedHashMap<>();
    for (Map.Entry<String, 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;
}

/**
 * 加载路由配置,由子类去实现
 */
public abstract Map<String, ZuulRoute> loadDynamicRoute();

}
由于动态路由的数据可以有很多种途径,如:Nacos、Redis、Zookeeper、DB等,所以这里定义一个抽象类,由具体的实现类去定义loadDynamicRoute方法

3.2. Nacos路由实现类
NacosDynRouteLocator类完整的代码实现可查看:NacosDynRouteLocator.java

3.2.1. 实现loadDynamicRoute方法获取动态数据

@Override
public Map<String, ZuulProperties.ZuulRoute> loadDynamicRoute() {
    Map<String, ZuulRoute> routes = new LinkedHashMap<>();
    if (zuulRouteEntities == null) {
        zuulRouteEntities = getNacosConfig();
    }
    for (ZuulRouteEntity result : zuulRouteEntities) {
        if (StrUtil.isBlank(result.getPath()) || !result.isEnabled()) {
            continue;
        }
        ZuulRoute zuulRoute = new ZuulRoute();
        BeanUtil.copyProperties(result, zuulRoute);
        routes.put(zuulRoute.getPath(), zuulRoute);
    }
    return routes;
}
    
private List<ZuulRouteEntity> getNacosConfig() {
    try {
        String content = nacosConfigProperties.configServiceInstance().getConfig(ZUUL_DATA_ID, ZUUL_GROUP_ID,5000);
        return getListByStr(content);
    } catch (NacosException e) {
        log.error("listenerNacos-error", e);
    }
    return new ArrayList<>(0);
}

3.2.2. 增加NacosListener监听路由数据变化

private void addListener() {
    try {
        nacosConfigProperties.configServiceInstance().addListener(ZUUL_DATA_ID, ZUUL_GROUP_ID, new Listener() {
            @Override
            public Executor getExecutor() {
                return null;
            }

            @Override
            public void receiveConfigInfo(String configInfo) {
                //赋值路由信息
                locator.setZuulRouteEntities(getListByStr(configInfo));
                RoutesRefreshedEvent routesRefreshedEvent = new RoutesRefreshedEvent(locator);
                publisher.publishEvent(routesRefreshedEvent);
            }
        });
    } catch (NacosException e) {
        log.error("nacos-addListener-error", e);
    }
}

注意路由数据变化后不需要自己手动刷新路由,只需要给zuul发送一个RoutesRefreshedEvent事件即可,zuul自己有个ZuulRefreshListener类会监听事件帮我们刷新路由

3.3. 配置类创建NacosDynRouteLocator的Bean
DynamicZuulRouteConfig可查看:NacosDynRouteLocator.java

@Configuration
@ConditionalOnProperty(prefix = "zlt.gateway.dynamicRoute", name = "enabled", havingValue = "true")
public class DynamicZuulRouteConfig {

@Autowired
private ZuulProperties zuulProperties;

@Autowired
private DispatcherServletPath dispatcherServletPath;

/**
 * Nacos实现方式
 */
@Configuration
@ConditionalOnProperty(prefix = "zlt.gateway.dynamicRoute", name = "dataType", havingValue = "nacos", matchIfMissing = true)
public class NacosZuulRoute {
    @Autowired
    private NacosConfigProperties nacosConfigProperties;

    @Autowired
    private ApplicationEventPublisher publisher;

    @Bean
    public NacosDynRouteLocator nacosDynRouteLocator() {
        return new NacosDynRouteLocator(nacosConfigProperties, publisher, dispatcherServletPath.getPrefix(), zuulProperties);
    }
}

}
这里通过自定义配置来控制是否开启动态路由功能

3.4. 添加Nacos路由配置
file
新增配置项:

Data Id:zuul-routes
Group:ZUUL_GATEWAY
配置内容:
[

{
    "enabled":true,
    "id":"csdn",
    "path":"/csdn/**",
    "retryable":false,
    "stripPrefix":true,
    "url":"https://www.csdn.net/"
}, {
    "enabled":true,
    "id":"github",
    "path":"/github/**",
    "retryable":false,
    "stripPrefix":true,
    "url":"http://github.com/"
}

]
添加两条路由数据

四、测试
启动网关通过/actuator/routes端点查看当前路由信息
file

可以看到静态路由和Nacos里配置的两条路由信息并存显示

修改Nacos配置,关闭csdn路由
file
刷新查看网关的路由信息
file

csdn的路由已经看不到了,实现了动态改变路由配置
原文地址https://www.cnblogs.com/zlt2000/p/11428272.html

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
DAO设计模式---实现一个简单的注册(下)
6、DAO工厂类: package com.song.DAOFactory; import com.song.DAO.RegisterDAO; import com.song.Impl.RegisterImpl; public class RegisterFactory{ publ...
785 0
Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单
Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单一、说明网关的核心概念就是路由配置和路由规则,而作为所有请求流量的入口,在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启的,所以实现动态路由是非常有必要的;本文主要介绍实现的思路,并且以Nacos为数据源来讲解 二...
1279 0
SpringBoot基于数据库实现简单的分布式锁
本文介绍SpringBoot基于数据库实现简单的分布式锁
1346 0
SpringBoot整合MongoDB(实现一个简单缓存)
SpringBoot整合MongoDB的一个小Demo,适合上手!
1222 0
一条简单的SQL的加锁实现分析
MySQL两条SQL语句锁的分析
3355 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
10192 0
Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单
网关的核心概念就是路由配置和路由规则,而作为所有请求流量的入口,在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启的,所以实现动态路由是非常有必要的;本文主要介绍实现的思路,并且以Nacos为数据源来讲解。
797 0
DAO设计模式---实现一个简单的注册(上)
DAO设计模式是属于Java Web中对数据层的具体操作,使用DAO设计模式可以简化大量代码的编写和增加程序的可移植性,可以很方便在日后对代码的修改。 如果在JSP中使用JDBC操作数据库,那样在JSP中就会嵌入大量的Java代码,显示和逻辑功能的代码混在一起,可读性差,难以维护。
1179 0
【最佳实践】OSS移动端断点下载简单实现
概要 技术点 最佳实践 改进 参考 概要 所谓断点下载,其实是客户端在从网络上下载资源时,由于某种原因中断下载。再次开启下载时可以从已经下载的部分开始继续下载未完成的部分,从而节省时间和流量。
2038 0
+关注
优惠码发放
阿里云优惠码阿里云推荐券bieryun.com
568
文章
4
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载