使用mysql数据库、nacos配置中心两种方式实现gateway动态路由_gateway动态路由数据库 nacos redis-程序员宅基地

1、MYSQL实现

表结构设计
在这里插入图片描述

代码设计

package com.example.config;

import com.alibaba.fastjson.JSON;
import com.example.domain.Filters;
import com.example.domain.Predicates;
import com.example.domain.Routes;
import com.example.service.IFiltersService;
import com.example.service.IPredicatesService;
import com.example.service.IRoutesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.filter.FilterDefinition;
import org.springframework.cloud.gateway.handler.predicate.PredicateDefinition;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionLocator;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import javax.annotation.PostConstruct;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.*;
import java.util.stream.Collectors;

@Component
@EnableScheduling
public class DynamicRouteServiceImplByMysql {
    

	@Autowired
	private DynamicRouteServiceImpl dynamicRouteService;
	@Autowired
	private RouteDefinitionLocator routeDefinitionLocator;

	@Autowired
	private IFiltersService iFiltersService;

	@Autowired
	private IRoutesService iRoutesService;

	@Autowired
	private IPredicatesService iPredicatesService;


	@PostConstruct
	public void init() {
    
		dynamicRouteByMysql();
	}

	/**
	 * 从数据库加载路由
	 *
	 */
	public void dynamicRouteByMysql() {
    
		try {
    
			List<Routes> routes = iRoutesService.selectRoutesAll();
			for (Routes route:routes){
    
				//获取filters
				List<FilterDefinition> filters=HandlerFilterList(route);
				//predicates
				List<PredicateDefinition> predicates =HandlerPredicateList(route);
				//给routeDefinition对象赋值
				RouteDefinition routeDefinition=new RouteDefinition();
				routeDefinition.setId(route.getId());
				URI url=new URI(route.getUri());
				routeDefinition.setUri(url);
				routeDefinition.setFilters(filters);
				routeDefinition.setPredicates(predicates);
				route.setStatus("Y");
				iRoutesService.updateRoutes(route);
				//RouteDefinition routeDefinition = (RouteDefinition)JSON.parse(routeJson);
				dynamicRouteService.add(routeDefinition);
			}
		} catch (Exception e) {
    
			e.printStackTrace();
		}
	}

	@Scheduled(fixedRate=1000*10)
	public void updateRoute() {
    
		try {
    
			List<Routes> routes = iRoutesService.selectRoutesAll();
			List<RouteDefinition> definitionList=new ArrayList<>();
			List<RouteDefinition> runningDefinitionList = Optional.ofNullable(routeDefinitionLocator.getRouteDefinitions()).map(Flux::collectList).map(Mono::block).orElse(Collections.emptyList());
			for (Routes route:routes){
    
				//获取filters
				List<FilterDefinition> filters=HandlerFilterList(route);
				//predicates
				List<PredicateDefinition> predicates =HandlerPredicateList(route);
				//给routeDefinition对象赋值
				RouteDefinition routeDefinition=new RouteDefinition();
				routeDefinition.setId(route.getId());
				URI url=new URI(route.getUri());
				routeDefinition.setUri(url);
				routeDefinition.setFilters(filters);
				routeDefinition.setPredicates(predicates);
				//RouteDefinition routeDefinition = (RouteDefinition)JSON.parse(routeJson);
				dynamicRouteService.update(routeDefinition);
				route.setStatus("Y");
				iRoutesService.updateRoutes(route);
				definitionList.add(routeDefinition);
			}
		/*List<RouteDefinition> definitionList = JSON.parseArray(configInfo, RouteDefinition.class);
		for (RouteDefinition definition : definitionList) {
			dynamicRouteService.update(definition);
		}*/
			List<String> newRunningDefinitionIds = definitionList.stream().map(RouteDefinition::getId).collect(Collectors.toList());
			runningDefinitionList.stream().map(RouteDefinition::getId)
					.filter(routeId -> !newRunningDefinitionIds.contains(routeId)).forEach(this::deleteRoute);
		}catch (Exception e){
    
			e.printStackTrace();
		}

	}
	private void deleteRoute(String routeId) {
    
		dynamicRouteService.delete(routeId);
	}

	/**
	 * 处理PredicateDefinition
	 * @return
	 */
	public List<PredicateDefinition> HandlerPredicateList(Routes route) {
    
		List<PredicateDefinition> predicates = new ArrayList<>();
		List<Predicates> predicateList = iPredicatesService.selectPredicatesListByRoutes_id(route.getId());
		for (Predicates predicate:predicateList){
    
			PredicateDefinition predicateDefinition = new PredicateDefinition();
			Map<String, String> args = predicate.getArgs();
			String[] strings = predicate.getValue().split(",");
			for (int i=0;i<strings.length;i++){
    
				String key = "_genkey_"+i;
				args.put(key,strings[i]);
			}
			predicateDefinition.setName(predicate.getName());
			predicateDefinition.setArgs(args);
			predicates.add(predicateDefinition);
		}
		return predicates;
	}
	/**
	 *处理FilterDefinition
	 * @return
	 */
	public List<FilterDefinition> HandlerFilterList(Routes route) {
    
		List<FilterDefinition> filters = new ArrayList<>();
		List<Filters> filterList = iFiltersService.selectFiltersListByRoutes_id(route.getId());
		for (Filters filter:filterList){
    
			FilterDefinition filterDefinition = new FilterDefinition();
			Map<String, String> args = filter.getArgs();
			String[] strings = filter.getValue().split(",");
			for (int i=0;i<strings.length;i++){
    
				String key = "_genkey_"+i;
				args.put(key,strings[i]);
			}
			filterDefinition.setName(filter.getName());
			filterDefinition.setArgs(args);
			filters.add(filterDefinition);
		}
		return filters;
	}

}
码片

package com.example.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;

@Service
public class DynamicRouteServiceImpl implements ApplicationEventPublisherAware {
    

    @Autowired
    private RouteDefinitionWriter routeDefinitionWriter;

    private ApplicationEventPublisher publisher;

    /**
     * ����·��
     *
     * @param definition
     * @return
     */
    public String add(RouteDefinition definition) {
    
        routeDefinitionWriter.save(Mono.just(definition)).subscribe();
        this.publisher.publishEvent(new RefreshRoutesEvent(this));
        return "success";
    }


    /**
     * ����·��
     *
     * @param definition
     * @return
     */
    public String update(RouteDefinition definition) {
    
        try {
    
            routeDefinitionWriter.save(Mono.just(definition)).subscribe();
            this.publisher.publishEvent(new RefreshRoutesEvent(this));
            return "success";
        } catch (Exception e) {
    
            return "update route  fail";
        }


    }

    /**
     * ɾ��·��
     *
     * @param id
     * @return
     */
    public String delete(String id) {
    
        try {
    
            this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();
            this.publisher.publishEvent(new RefreshRoutesEvent(this));
            return "delete success";
        } catch (Exception e) {
    
            e.printStackTrace();
            return "delete fail";
        }

    }

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
    
        this.publisher = applicationEventPublisher;
    }

}

说明：数据库这种方式是我们领导要求的，加了定时器轮询，误差和定时器轮询的间隔时间有关，这样做的好处是可以做成界面话展示，方便操作，界面大致如下：

在这里插入图片描述

2、nacos配置中心实现

代码设计

package com.example.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;

@Service
public class DynamicRouteServiceImpl implements ApplicationEventPublisherAware {
    

    @Autowired
    private RouteDefinitionWriter routeDefinitionWriter;

    private ApplicationEventPublisher publisher;

    /**
     * ����·��
     *
     * @param definition
     * @return
     */
    public String add(RouteDefinition definition) {
    
        routeDefinitionWriter.save(Mono.just(definition)).subscribe();
        this.publisher.publishEvent(new RefreshRoutesEvent(this));
        return "success";
    }


    /**
     * ����·��
     *
     * @param definition
     * @return
     */
    public String update(RouteDefinition definition) {
    
        try {
    
            routeDefinitionWriter.save(Mono.just(definition)).subscribe();
            this.publisher.publishEvent(new RefreshRoutesEvent(this));
            return "success";
        } catch (Exception e) {
    
            return "update route  fail";
        }


    }

    /**
     * ɾ��·��
     *
     * @param id
     * @return
     */
    public String delete(String id) {
    
        try {
    
            this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();
            this.publisher.publishEvent(new RefreshRoutesEvent(this));
            return "delete success";
        } catch (Exception e) {
    
            e.printStackTrace();
            return "delete fail";
        }

    }

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
    
        this.publisher = applicationEventPublisher;
    }

}

package com.example.config;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GatewayConfig {
    

    @Value("${spring.cloud.nacos.config.server-addr}")
    private String nacosServerAddr;
    @Value("${spring.cloud.nacos.config.namespace}")
    private String nacosNamespace;

    @Value("${nacos.gateway.route.config.data-id}")
    private String nacosRouteDataId;
    @Value("${nacos.gateway.route.config.group}")
    private String nacosRouteGroup;

    public String getNacosServerAddr() {
    
        return nacosServerAddr;
    }

    public void setNacosServerAddr(String nacosServerAddr) {
    
        this.nacosServerAddr = nacosServerAddr;
    }

    public String getNacosNamespace() {
    
        return nacosNamespace;
    }

    public void setNacosNamespace(String nacosNamespace) {
    
        this.nacosNamespace = nacosNamespace;
    }

    public String getNacosRouteDataId() {
    
        return nacosRouteDataId;
    }

    public void setNacosRouteDataId(String nacosRouteDataId) {
    
        this.nacosRouteDataId = nacosRouteDataId;
    }

    public String getNacosRouteGroup() {
    
        return nacosRouteGroup;
    }

    public void setNacosRouteGroup(String nacosRouteGroup) {
    
        this.nacosRouteGroup = nacosRouteGroup;
    }
}

package com.example.config;

import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionLocator;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import javax.annotation.PostConstruct;
import java.util.Collections;
import java.util.List;
import java.util.Optional;
import java.util.Properties;
import java.util.concurrent.Executor;
import java.util.stream.Collectors;

//@Component
public class DynamicRouteServiceImplByNacos {
    

	@Autowired
	private DynamicRouteServiceImpl dynamicRouteService;
	@Autowired
	private GatewayConfig gatewayConfig;
	@Autowired
	private RouteDefinitionLocator routeDefinitionLocator;

	@PostConstruct
	public void init() {
    
		dynamicRouteByNacosListener(gatewayConfig.getNacosRouteDataId(), gatewayConfig.getNacosRouteGroup());
	}

	/**
	 * ����Nacos Server�·��Ķ�̬·������
	 *
	 * @param dataId
	 * @param group
	 */
	public void dynamicRouteByNacosListener(String dataId, String group) {
    
		try {
    
			Properties properties = new Properties();
			properties.setProperty("serverAddr", gatewayConfig.getNacosServerAddr());
			properties.setProperty("namespace", gatewayConfig.getNacosNamespace());
			ConfigService configService = NacosFactory.createConfigService(properties);
			String configInfo = configService.getConfig(dataId, group, 5000);
			List<RouteDefinition> definitionList = JSON.parseArray(configInfo, RouteDefinition.class);
			for (RouteDefinition definition : definitionList) {
    
				dynamicRouteService.add(definition);
			}
			configService.addListener(dataId, group, new Listener() {
    
				@Override
				public void receiveConfigInfo(String configInfo) {
    
					List<RouteDefinition> runningDefinitionList = Optional.ofNullable(routeDefinitionLocator.getRouteDefinitions()).map(Flux::collectList).map(Mono::block).orElse(Collections.emptyList());
					List<RouteDefinition> definitionList = JSON.parseArray(configInfo, RouteDefinition.class);
					for (RouteDefinition definition : definitionList) {
    
						dynamicRouteService.update(definition);
					}
					List<String> newRunningDefinitionIds = definitionList.stream().map(RouteDefinition::getId).collect(Collectors.toList());
					runningDefinitionList.stream().map(RouteDefinition::getId)
							.filter(routeId -> !newRunningDefinitionIds.contains(routeId)).forEach(this::deleteRoute);
				}

				@Override
				public Executor getExecutor() {
    
					return null;
				}

				private void deleteRoute(String routeId) {
    
					dynamicRouteService.delete(routeId);
				}
			});
		} catch (NacosException e) {
    
		}
	}

}

naocs配置中心配置

[{
    
    "id":"user-service",
    "order":0,
    "predicates":[{
    
        "args":{
    
            "_genkey_0":"/user-service/**"
    
        },
        "name":"Path"
        },
        {
    
        "args":{
    
            "_genkey_0":"2017-01-20T17:42:47.789-07:00[America/Denver]"
        },
        "name":"After"
        }],
    "uri":"lb://user-service",
    "filters":[{
    
         "args":{
    
            "_genkey_0":1
        },
        "name":"StripPrefix"
    }]
}]

在这里插入图片描述
说明：相对于数据库来说，使用nacos需要每次改动json配置，可能存在误操作的情况居多，但是可以实现实时生效。不像数据库，有一定的延迟。

本文链接：https://blog.csdn.net/weixin_42074606/article/details/114833317

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

python中文显示不出来_解决Python词云库wordcloud不显示中文的问题-程序员宅基地

文章浏览阅读2.6k次。解决Python词云库wordcloud不显示中文的问题2018-11-25背景：wordcloud是基于Python开发的词云生成库，功能强大使用简单。github地址：https://github.com/amueller/word_cloudwordcloud默认是不支持显示中文的，中文会被显示成方框。安装：安装命令：pip install wordcloud解决：经过测试发现不支持显示中文..._词云python代码无法输出文字

JVM在线分析-解决问题的工具一(jinfo,jmap,jstack)_jmap 在线分析-程序员宅基地

文章浏览阅读807次。扩展。_jmap 在线分析

台式计算机cpu允许温度,玩游戏cpu温度多少正常（台式电脑夏季CPU一般温度多少）...-程序员宅基地

文章浏览阅读1.1w次。随着炎热夏季的到来，当玩游戏正爽的时候，电脑突然死机了，自动关机了，是不是有想给主机一脚的冲动呢？这个很大的原因是因为CPU温度过高导致的。很多新手玩家可能都有一个疑虑，cpu温度多少以下正常？有些说是60，有些说是70，到底多高CPU温度不会死机呢？首先我们先看看如何查看CPU的温度。下载鲁大师并安装，运行鲁大师软件，即可进入软件界面，并点击温度管理，即可看到电脑各个硬件的温度。鲁大师一般情况下..._台式机玩游戏温度多少正常

小白自学Python日记 Day2-打印打印打印！_puthon打印任务收获-程序员宅基地

文章浏览阅读243次。Day2-打印打印打印！我终于更新了！（哭腔）一、最简单的打印最最简单的打印语句： print(“打印内容”)注意：python是全英的，符号记得是半角下面是我写的例子：然后进入power shell ，注意：你需要使用cd来进入你保存的例子的文件夹，保存时名字应该取为xxx.py我终于知道为什么文件夹取名都建议取英文了，因为进入的时候是真的很麻烦！如果你没有进入正确的文件夹..._puthon打印任务收获

Docker安装：Errors during downloading metadata for repository ‘appstream‘:_"cenerrors during download metadata for repository-程序员宅基地

文章浏览阅读1k次。centos8问题参考CentOS 8 EOL如何切换源？ - 云服务器 ECS - 阿里云_"cenerrors during download metadata for repository \"appstream"

尚硅谷_谷粒学苑-微服务+全栈在线教育实战项目之旅_基于微服务的在线教育平台尚硅谷-程序员宅基地

文章浏览阅读2.7k次，点赞3次，收藏11次。SpringBoot+Maven+MabatisPlusmaven在新建springboot项目引入RELEASE版本出错maven在新建springboot项目引入RELEASE版本出错maven详解maven就是通过pom.xml中的配置，就能够从仓库获取到想要的jar包。仓库分为：本地仓库、第三方仓库(私服)、中央仓库springframework.boot:spring-boot-starter-parent:2.2.1.RELEASE’ not found若出现jar包下载不了只有两_基于微服务的在线教育平台尚硅谷

随便推点

网络学习第六天（路由器、VLAN）_路由和vlan-程序员宅基地

文章浏览阅读316次。路由的概念路由器它称之为网关设备。路由器就是用于连接不同网络的设备路由器是位于OSI模型的第三层。路由器通过路由决定数据的转发。网关的背景：当时每家计算机厂商，用于交换数据的通信程序（协议）和数据描述格式各不相同。因此，就把用于相互转换这些协议和格式的计算机称为网关。路由器与三层交换器的对比路由协议对比路由器的作用：1.路由寻址2.实现不同网络之间相连的功能3.通过路由决定数据的转发，转发策略称为路由选择。VLAN相关技术什么是VLAN？中文名称叫：虚拟局域网。虚_路由和vlan

设置div背景颜色透明度，内部元素不透明_div设置透明度,里面的内容不透明-程序员宅基地

文章浏览阅读2.8w次，点赞6次，收藏22次。设置div背景颜色透明度，内部元素不透明：.demo{ 　background-color:rgba(255,255,255,0.15) } 错误方式：.demo{ background-color:#5CACEE;opacity:0.75;} 这样会导致div里面的元素内容和背景颜色一起变透明只针对谷歌浏览器的测试_div设置透明度,里面的内容不透明

Discuz!代码大全-程序员宅基地

文章浏览阅读563次。1.[ u]文字：在文字的位置可以任意加入您需要的字符，显示为下划线效果。2.[ align=center]文字：在文字的位置可以任意加入您需要的字符，center位置center表示居中，left表示居左，right表示居右。5.[ color=red]文字：输入您的颜色代码，在标签的中间插入文字可以实现文字颜色改变。6.[ SIZE=数字]文字：输入您的字体大小，在标签的中间插入文..._discuzcode 大全

iOS NSTimer定时器-程序员宅基地

文章浏览阅读2.6k次。iOS中定时器有三种，分别是NSTimer、CADisplayLink、dispatch_source，下面就分别对这三种计时器进行说明。一、NSTimerNSTimer这种定时器用的比较多，但是特别需要注意释放问题，如果处理不好很容易引起循环引用问题，造成内存泄漏。1.1 NSTimer的创建NSTimer有两种创建方法。方法一：这种方法虽然创建了NSTimer，但是定时器却没有起作用。这种方式创建的NSTimer，需要加入到NSRunLoop中，有NSRunLoop的驱动才会让定时器跑起来。_ios nstimer

Linux常用命令_ls-lmore-程序员宅基地

文章浏览阅读4.8k次，点赞17次，收藏51次。Linux的命令有几百个，对程序员来说，常用的并不多，考虑各位是初学者，先学习本章节前15个命令就可以了，其它的命令以后用到的时候再学习。1、开机物理机服务器，按下电源开关，就像windows开机一样。在VMware中点击“开启此虚拟机”。2、登录启动完成后，输入用户名和密码，一般情况下，不要用root用户..._ls-lmore

MySQL基础命令_mysql -u user-程序员宅基地

文章浏览阅读4.1k次。1.登录MYSQL系统命令打开DOS命令框shengfen，以管理员的身份运行命令1：mysql -u usernae -p password命令2：mysql -u username -p password -h 需要连接的mysql主机名(localhost本地主机名)或是mysql的ip地址（默认为：127.0.0.1）-P 端口号（默认：3306端口）使用其中任意一个就OK,输入命令后DOS命令框得到mysql>就说明已经进入了mysql系统2. 查看mysql当中的._mysql -u user