SpringGateway集成Nacos实现动态路由配置

　　通过SpringGateway集成Nacos实现配置管理，并且实现动态路由管理。
　　一、创建testgateway项目，POM文件如下：modelVersion4。0。0modelVersionparentgroupIdcom。golte。parentgroupIdgolteparentartifactIdversion1。0。0versionparentgroupIdcom。golte。gatewaygroupIdgoltegatewayartifactIdversion0。0。1SNAPSHOTversionnamegoltegatewaynamedescriptionGatewayprojectforSpringBootdescriptionpropertiesjava。version1。8java。versionspring。cloud。versionHoxton。SR8spring。cloud。version2。2。3。RELEASEalibaba。cloud。versionfastjson。version1。2。73fastjson。versionpropertiesdependenciesdependencygroupIdorg。springframework。cloudgroupIdspringcloudstartergatewayartifactIddependencydependencygroupIdcom。alibaba。cloudgroupIdspringcloudstarteralibabanacosconfigartifactIddependencydependencygroupIdcom。alibaba。cloudgroupIdspringcloudstarteralibabanacosdiscoveryartifactIddependency！sentinel提供的gataway适配器dependencygroupIdcom。alibaba。cloudgroupIdspringcloudalibabasentinelgatewayartifactIddependency！对外暴露SpringBoot监控指标dependencygroupIdorg。springframework。bootgroupIdspringbootstarteractuatorartifactIddependencydependencygroupIdorg。springframework。bootgroupIdspringbootstartertestartifactIdscopetestscopeexclusionsexclusiongroupIdorg。junit。vintagegroupIdjunitvintageengineartifactIdexclusionexclusionsdependencydependencygroupIdcom。alibabagroupIdfastjsonartifactIdversion｛fastjson。version｝versiondependencydependenciesdependencyManagementdependenciesdependencygroupIdorg。springframework。cloudgroupIdspringclouddependenciesartifactIdversion｛spring。cloud。version｝versiontypepomtypescopeimportscopedependencydependencygroupIdcom。alibaba。cloudgroupIdspringcloudalibabadependenciesartifactIdversion｛alibaba。cloud。version｝versiontypepomtypescopeimportscopedependencydependenciesdependencyManagementbuildfinalNametestgatewayfinalNamepluginsplugingroupIdorg。springframework。bootgroupIdspringbootmavenpluginartifactIdpluginpluginsbuildproject
　　二、创建项目配置文件bootstrap。ymlserver：port：80spring：profiles：active：devapplication：name：testgatewaycloud：nacos：config：namespace：｛spring。profiles。active｝serveraddr：http：127。0。0。1：8848extensionconfigs〔0〕：dataid：testgatewaycommons。ymlgroup：DEFAULTGROUPrefresh：trueNacos动态路由配置，json格式nacos：gateway：route：config：dataid：gatewaydynamicroutergroup：DEFAULTGROUP
　　a、testgatewaycommons。yml内容如下：sentinel相关配置spring：cloud：sentinel：transport：dashboard：http：127。0。0。1：8080port：8719scg：fallback：mode：responseresponsestatus：455responsebody：error！nacos：discovery：namespace：devserveraddr：127。0。0。1：8848management：endpoints：web：exposure：include：
　　三、创建网关配置类GatewayConfig。javaimportorg。springframework。beans。factory。annotation。Value；importorg。springframework。context。annotation。Configuration；ConfigurationpublicclassGatewayConfig｛publicstaticfinallongDEFAULTTIMEOUT30000；publicstaticStringNACOSSERVERADDR；publicstaticStringNACOSNAMESPACE；publicstaticStringNACOSROUTEDATAID；publicstaticStringNACOSROUTEGROUP；Value（｛spring。cloud。nacos。discovery。serveraddr｝）publicvoidsetNacosServerAddr（StringnacosServerAddr）｛NACOSSERVERADDRnacosServerAddr；｝Value（｛spring。cloud。nacos。discovery。namespace｝）publicvoidsetNacosNamespace（StringnacosNamespace）｛NACOSNAMESPACEnacosNamespace；｝Value（｛nacos。gateway。route。config。dataid｝）publicvoidsetNacosRouteDataId（StringnacosRouteDataId）｛NACOSROUTEDATAIDnacosRouteDataId；｝Value（｛nacos。gateway。route。config。group｝）publicvoidsetNacosRouteGroup（StringnacosRouteGroup）｛NACOSROUTEGROUPnacosRouteGroup；｝｝
　　四、创建动态路由服务DynamicRouteServiceImpl。javaimportorg。springframework。beans。factory。annotation。Autowired；importorg。springframework。cloud。gateway。event。RefreshRoutesEvent；importorg。springframework。cloud。gateway。route。RouteDefinition；importorg。springframework。cloud。gateway。route。RouteDefinitionWriter；importorg。springframework。context。ApplicationEventPublisher；importorg。springframework。context。ApplicationEventPublisherAware；importorg。springframework。stereotype。Service；importlombok。extern。slf4j。Slf4j；importreactor。core。publisher。Mono；动态更新路由网关service1）实现一个Spring提供的事宜推送接口ApplicationEventPublisherAware2）提供动态路由的基础方式，可通过获取bean操作该类的方式。该类提供新增路由、更新路由、删除路由，然后实现公布的功效。Slf4jServicepublicclassDynamicRouteServiceImplimplementsApplicationEventPublisherAware｛AutowiredprivateRouteDefinitionWriterrouteDefinitionWriter；公布事宜AutowiredprivateApplicationEventPublisherpublisher；OverridepublicvoidsetApplicationEventPublisher（ApplicationEventPublisherapplicationEventPublisher）｛this。publisherapplicationEventPublisher；｝删除路由paramidreturnpublicStringdelete（Stringid）｛try｛log。info（gatewaydeleterouteid｛｝，id）；this。routeDefinitionWriter。delete（Mono。just（id））；returndeletesuccess；｝catch（Exceptione）｛returndeletefail；｝｝更新路由paramdefinitionreturnpublicStringupdate（RouteDefinitiondefinition）｛try｛log。info（gatewayupdateroute｛｝，definition）；this。routeDefinitionWriter。delete（Mono。just（definition。getId（）））；｝catch（Exceptione）｛returnupdatefail，notfindrouterouteId：definition。getId（）；｝try｛routeDefinitionWriter。save（Mono。just（definition））。subscribe（）；this。publisher。publishEvent（newRefreshRoutesEvent（this））；returnsuccess；｝catch（Exceptione）｛returnupdateroutefail；｝｝增添路由paramdefinitionreturnpublicStringadd（RouteDefinitiondefinition）｛log。info（gatewayaddroute｛｝，definition）；routeDefinitionWriter。save（Mono。just（definition））。subscribe（）；this。publisher。publishEvent（newRefreshRoutesEvent（this））；returnsuccess；｝｝
　　五、创建通过Nacos读取动态路由配置服务DynamicRouteServiceImplByNacos。javaimportjava。util。List；importjava。util。Properties；importjava。util。concurrent。Executor；importjavax。annotation。PostConstruct；importorg。springframework。beans。factory。annotation。Autowired；importorg。springframework。cloud。gateway。route。RouteDefinition；importorg。springframework。context。annotation。DependsOn；importorg。springframework。stereotype。Component；importcom。alibaba。fastjson。JSON；importcom。alibaba。nacos。api。NacosFactory；importcom。alibaba。nacos。api。config。ConfigService；importcom。alibaba。nacos。api。config。listener。Listener；importcom。alibaba。nacos。api。exception。NacosException；importlombok。extern。slf4j。Slf4j；通过nacos下发动态路由设置，监听Nacos中gatewayroute设置ComponentSlf4jDependsOn（｛gatewayConfig｝）依赖于gatewayConfigbeanpublicclassDynamicRouteServiceImplByNacos｛AutowiredprivateDynamicRouteServiceImpldynamicRouteService；privateConfigServiceconfigService；PostConstructpublicvoidinit（）｛log。info（gatewayrouteinit。。。）；try｛configServiceinitConfigService（）；if（configServicenull）｛log。warn（initConfigServicefail）；return；｝StringconfigInfoconfigService。getConfig（GatewayConfig。NACOSROUTEDATAID，GatewayConfig。NACOSROUTEGROUP，GatewayConfig。DEFAULTTIMEOUT）；log。info（获取网关当前设置：r｛｝，configInfo）；ListRouteDefinitiondefinitionListJSON。parseArray（configInfo，RouteDefinition。class）；for（RouteDefinitiondefinition：definitionList）｛log。info（updateroute：｛｝，definition。toString（））；dynamicRouteService。add（definition）；｝｝catch（Exceptione）｛log。error（初始化网关路由时发生错误，e）；｝dynamicRouteByNacosListener（GatewayConfig。NACOSROUTEDATAID，GatewayConfig。NACOSROUTEGROUP）；｝监听Nacos下发的动态路由设置paramdataIdparamgrouppublicvoiddynamicRouteByNacosListener（StringdataId，Stringgroup）｛try｛configService。addListener（dataId，group，newListener（）｛OverridepublicvoidreceiveConfigInfo（StringconfigInfo）｛log。info（举行网关更新：r｛｝，configInfo）；ListRouteDefinitiondefinitionListJSON。parseArray（configInfo，RouteDefinition。class）；for（RouteDefinitiondefinition：definitionList）｛log。info（updateroute：｛｝，definition。toString（））；dynamicRouteService。update（definition）；｝｝OverridepublicExecutorgetExecutor（）｛log。info（getExecutorr）；returnnull；｝｝）；｝catch（NacosExceptione）｛log。error（从nacos吸收动态路由设置失足！！！，e）；｝｝初始化网关路由nacosconfigreturnprivateConfigServiceinitConfigService（）｛try｛PropertiespropertiesnewProperties（）；properties。setProperty（serverAddr，GatewayConfig。NACOSSERVERADDR）；properties。setProperty（namespace，GatewayConfig。NACOSNAMESPACE）；returnconfigServiceNacosFactory。createConfigService（properties）；｝catch（Exceptione）｛log。error（初始化网关路由时发生错误，e）；returnnull；｝｝｝
　　六、配置动态路由配置文件gatewaydynamicrouter，内容如下：〔｛id：useradminrouter，order：5，predicates：〔｛args：｛pattern：useradmin｝，name：Path｝〕，filters：〔｛name：StripPrefix，args：｛genkey0：1｝｝〕，uri：lb：testuseradmin｝，｛id：userapprouter，order：4，predicates：〔｛args：｛pattern：users｝，name：Path｝〕，filters：〔｛name：StripPrefix，args：｛genkey0：1｝｝〕，uri：lb：testuserapp｝〕
　　通过以上步骤就完成SpringGateway集成Nacos实现动态路由配置功能。以后只要通过修改Nacos的配置文件就可以时间服务的动态上下线了。不需要再重启网关了。