gateway动态路由_无语!SpringCloud Gateway动态路由之Nacos,我已经讲得很清楚了

前言

当我们的网关Gateway程序开发完成之后,需要部署到生产环境,这个时候你的程序不能是单点运行的,肯定是多节点启动(独立部署或者docker等容器部署),防止单节点故障导致整个服务不能访问,网关是对客户端的入口与出口,在生产运行中极为重要,哪怕是简单的重启也会导致部分请求的丢失。

网关的路由配置这个时候就是一个大问题,是代码里面编写还是配置文件配置?他们都有一个致命的缺点,当有新的程序需要接入到网关进行路由或者有服务需要下线时候需要修改代码或者配置,然后重启整个网关程序,导致其他正常的服务路由受到了影响。

所以在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启网关,所以实现动态路由是非常有必要的;

本文主要介绍Spring Cloud Gateway 实现的思路,并且把路由信息存放在外部源中,这粒以Nacos为数据源来讲解。

实现要点

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

1、网关启动时,动态路由的数据怎样加载进来
2、静态路由与动态路由以那个为准
3、监听动态路由的数据源变化
4、数据有变化时怎样通知gateway刷新路由

ps:静态路由指的是配置文件里写死的路由配置

具体实现

Spring Cloud Gateway 中加载路由信息分别由以下几个类负责

1、PropertiesRouteDefinitionLocator:从配置文件中读取路由信息(如YML、Properties等)
2、RouteDefinitionRepository:从存储器中读取路由信息(如内存、配置中心、Redis、MySQL等)
3、DiscoveryClientRouteDefinitionLocator:从注册中心中读取路由信息(如Nacos、Eurka、Zookeeper等)

我们可以通过自定义RouteDefinitionRepository的实现类来实现动态路由的目的

fbb6f9906cde299a2d8b80e3293ce049.png

62c96556064d4ae5fd903a9521ddf007.png

97aa504ab8a928fb22965e3264c0d5a3.png

上面代码核心的是重写 getRouteDefinitions 方法实现路由信息的读取;这个方法中涉及到了ConfigService对象Api的方法。

管理Api方法,这个老顾这里不详细说了;小伙伴们可以理解为就是操作nacos config的对象

配置Nacos监听器,监听路由配置信息的变化,也是利用api方法,也就是addListener方法;此方法一看就知道,就是用来监听config信息变化的。

此addListener方法中路由变化只需要往 ApplicationEventPublisher 推送一个 RefreshRoutesEvent 事件,即刻gateway会自动监听该事件并调用 getRouteDefinitions 方法更新路由信息。

这样就达到了动态更新路由了。

配置类

为了更好的把此动态路由作为公共core,我们需要利用配置类,达到是否启用的方式;可以让开发者自行配置。

6e8df005791f4ccf793d2b1964010736.png

上面的配置类,有两个重要的@ConditionalOnProperty,这个就是用来控制是否启用动态路由,以及是否用nacos作为存储。

里面还有@Value注解定义我们存储路由信息的DataId和Group,application.yml如果不配置默认值为scg-routes和SCG_GATEWAY

添加Nacos路由配置

在同一个namespace中创建scg-routes和SCG_GATEWAY

0c595d859ce6a0cf12282fcb22044ad4.png

格式选择json,json体里面的格式其实就是RouteDefinition类的属性

1cec23f77768302595e225901f88dd2a.png
注意上面的配置的json是数组格式哦,也就是可以有很多路由哦

"id": "baidu", "order": 0, "predicates": [{ "args": { "pattern": "/baidu/**" }, "name": "Path" }], "uri": "https://www.baidu.com" },{ "id": "sina", "order": 2, "predicates": [{ "args": { "pattern": "/sina/**" }, "name": "Path" }], "uri": "http://www.sina.com.cn" }]

测试

在网关项目中的application.yml中配置

gateway: dynamicRoute: enabled: true

并且在application.yml中配置

endpoints: web: exposure: include: '*' endpoint: gateway: enabled: true health: show-details: always

这样我们就可以访问http://localhost:8081/actuator/gateway/routes,就可以看到路由信息

e398ecc6ad713fd1bed189a57c1e8e67.png

小伙伴们可以尝试修改一下nacos中的dataId为scg-routes,我们可以发现路由及时 得到了更改。

老万只修改了route_id的名称,路由就及时更新了

2a849ee0fe0d89c7fd37a3158bf587db.png

我们也看到了控制台日志也有相应的变化

3dce7a77a83c6e090744d308f43e51a7.png

总结

gateway的动态路由是非常实用的功能,在生产环境中是必备功能,小伙伴们一定要掌握哦,当然小伙伴们也可以用其他的数据源。谢谢!!!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/566967.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

json里面的list数据取不出来_sql盲注的困局:利用DNSlog快速导出数据

对于一个sql注入点来说最幸运的就是支持堆叠注入&#xff0c;最蛋疼的就是盲注&#xff0c;盲注里面难搞的就是基于时间的盲注。我们在本地利用这段代码进行演示<?php error_reporting(0); $link mysqli_connect(localhost,root,root); mysqli_set_charset($link,utf8); m…

python判断文件是否打开_python如何判断一个文件是否处于打开状态?

请问你的是linux吗&#xff1f;如果是linux可以借助/proc来获取。 import os class File(object): def __init__(self, file_path): if not os.path.exists(file_path): raise OSError({file_path} not exist.format(file_path file_path)) self.file_path os.path.abspath(f…

python怎么测试程序_python如何测试程序

测试函数是用于自动化测试&#xff0c;使用python模块中的unittest中的工具来测试 附上书中摘抄来的代码&#xff1a;#codingutf-8 import unittest from name_function import get_formatted_name class NamesTestCase(unittest.TestCase): def test_first_last_name(self): f…

判定覆盖白盒测试java_白盒测试系列(四)条件判定覆盖

条件判定覆盖一、定义&#xff1a;程序中每个判定至少有一次为真值&#xff0c;有一次为假值,使得程序中每个分支至少执行一次&#xff0c;且使得各判定中的每个条件获得各种可能的取值至少满足一次。二、特点&#xff1a;1、综合了条件覆盖和判定覆盖的特点2、满足条件判定覆盖…

discard python_Netty入门教程(一) 实现DISCARD服务

官方那个给出的介绍是&#xff1a;Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具&#xff0c;用以快速开发高性能、高可靠性的网络服务器和客户端程序。然后我们简单理解一下&#xff0c;这玩意就是个程序&#xff0c;干什么的&am…

python 每天执行一次_python 定时器每天就执行一次的实现代码

1.实现功能编写python脚本一直运行&#xff0c;判断当下是否是新的一天&#xff0c;如果是就执行一次任务代码2.具体实现代码#-*-coding:utf-8 -*-__author__ Administratorimport os,threading,timecurTimetime.strftime("%Y-%M-%D",time.localtime())#记录当前时间…

python 类的内置方法_【转】[python] 类常用的内置方法

原文&#xff1a;http://xukaizijian.blog.163.com/blog/static/170433119201111894228877/ 内置方法 说明 __init__(self,...) 初始化对象&#xff0c;在创建新对象时调用 __del__(self) 释放对象&#xff0c;在对象被删除之前调用 __new__(cls,*args,**kwd) 实例的生成操作 _…

java 文件与base64_java之文件与base64字符之间的相互转换

package cn.xuanyuan.util;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import sun.misc.BASE64Decoder;import sun.misc.BASE64Encoder;public class FileUitl {/*** 将文件转成base64 字符串* param path文件路径* return ** thro…

python向量化编程技巧_神经网络基础之Python与向量化

Vectorization 深度学习算法中&#xff0c;数据量很大&#xff0c;在程序中尽量减少使用loop循环语句&#xff0c;而可以使用向量运算来提高程序运行速度。 向量化(Vectorization)就是利用矩阵运算的思想&#xff0c;大大提高运算速度。例如下面所示在Python中使用向量化要比使…

java 父子线程 调用链_ZipKin原理学习--Zipkin多线程及线程池中追踪一致性问题解决...

在学习Zipkin分布式追踪系统中我们了解到Trace在整个调用链是一致的&#xff0c;在web服务中可以通过在header设置Trace值在不同的服务中进行传递&#xff0c;那样在一个服务内部不同的线程&#xff0c;甚至是线程池中Zipkin是如何处理的&#xff0c;接下来我们来了解学习一下。…

SQL server 数据库面试题及答案(实操2)

使用你的名字创建一个数据库 创建表&#xff1a; 数据库中有三张表&#xff0c;分别为student,course,SC&#xff08;即学生表&#xff0c;课程表&#xff0c;选课表&#xff09; 问题&#xff1a; --1.分别查询学生表和学生修课表中的全部数据。--2.查询成绩在70到80分之间…

python电子相册制作软件_电子相册怎么做

电子相册制作 本文来自#千兆网络有什么用#征稿活动&#xff0c;不断提速的网络给你的生活带来了什么变化&#xff1f;快来参与活动&#xff0c;聊聊你玩转互联网&#xff0c;高速网上冲浪的经历&#xff01;>点击这里查看活动详情< 现在手机的拍照功能日趋强大&#xff0…

java list 范围删除_JAVA中循环删除list中元素(移除list两时间范围外的元素)

印象中循环删除list中的元素使用for循环的方式是有问题的&#xff0c;但是可以使用增强的for循环&#xff0c;然后今天在使用时发现报错了&#xff0c;然后去科普了一下&#xff0c;再然后发现这是一个误区。下面就来讲一讲。。伸手党可直接跳至文末。看总结。。JAVA中循环遍历…

python标注审核_Python类型标注

机器学习越来越火&#xff0c;大量的机器学习包都支持Python&#xff0c;导致了Python近几年非常火爆&#xff0c;入手门槛低&#xff0c;编程简单&#xff0c;概念非常少。越来越多的新手小白加入到Python编程。 Python虽然简单&#xff0c;但也带来很多问题。尤其是弱类型一直…

php的在线问卷调查_基于php技术的问卷调查系统

本系统前台主要使用php作为开发语言&#xff0c;后台使用mysql作为数据库管理系统&#xff0c;开发环境是wamp&#xff0c;服务器采用apache。系统的主要功能包括&#xff1a;管理登陆、问卷调查题目及内容选项的添加、修改和查询&#xff0c;调查结果统计等。分为管理员用户、…

python reduce函数_Python reduce()函数的用法小结

reduce()函数也是Python内置的一个高阶函数。 reduce() 格式&#xff1a; reduce (func, seq[, init()]) reduce()函数即为化简函数&#xff0c;它的执行过程为&#xff1a;每一次迭代&#xff0c;都将上一次的迭代结果&#xff08;注&#xff1a;第一次为init元素&#xff0c;…

Php获取id并提交表单,提交表单后 PHP获取提交内容的实现方法

提交表单后 PHP获取提交内容的实现方法2020-06-14 15:35:24问题&#xff1a;网页上提交表单之后&#xff0c;PHP为什么不能获取提交的内容&#xff1f;然而在老版本的PHP上运行却正常。新版的PHP已经废弃了原来的表单内容处理方式&#xff0c;即不再把提交的表单的内容直接复制…

idea查看一个类的所有子类_java new一个对象的过程中发生了什么

java在new一个对象的时候&#xff0c;会先查看对象所属的类有没有被加载到内存&#xff0c;如果没有的话&#xff0c;就会先通过类的全限定名来加载。加载并初始化类完成后&#xff0c;再进行对象的创建工作。我们先假设是第一次使用该类&#xff0c;这样的话new一个对象就可以…

stringbuilder删除最后一个字符_Java类-StingBuffer,StringBuilder

Java提供了String,StringBuffr,StringBuilder类来封装字符串,并提供了一系列操作字符串对象的方法.他们的相同点都是封装字符串;都实现了CharSeqence接口.public final class StringBuffer extends AbstractStringBuilder implements java.io.Serializable,CharSequncepublic f…

php强大的函数,PHP中一些功能强大却很少使用的函数

本文主要介绍了PHP中功能强大却很少使用的函数&#xff0c;结合实例形式总结分析了php中非常实用的几个函数&#xff0c;包括函数的调用、注册、调用、判断等操作技巧。需要的朋友可以参考下&#xff0c;希望对大家有所帮助。具体如下&#xff1a;call_user_func_array — 让参…