服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - 关于springboot中nacos动态路由的配置

关于springboot中nacos动态路由的配置

2021-12-28 13:20Spring王不正 Java教程

这篇文章主要介绍了springboot中nacos动态路由的配置方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

nacos动态路由的配置

什么都不说了,springboot-nacos 不懂得的下面自行学习啦我直接贴下代码!

首先。。。

我自己有个服务器。在无聊之时写的代码,主要是通过网关来调用接口所以有了下面的代码。

1.作为一个动态路由维护管理的类

@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 {
          this.routeDefinitionWriter.delete(Mono.just(definition.getId()));
      } catch (Exception e) {
          return "update fail,not find route  routeId: "+definition.getId();
      }
      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));
          return "delete success";
      } catch (Exception e) {
          e.printStackTrace();
          return "delete fail";
      }
  }
  @Override
  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
      this.publisher = applicationEventPublisher;
  }

2.基于Nacos动态配置路由服务

@Component
public class DynamicRouteServiceImplByNacos implements CommandLineRunner {
  private static final Logger logger = LoggerFactory.getLogger(DynamicRouteServiceImplByNacos.class);
  @Autowired
  private DynamicRouteServiceImpl dynamicRouteService;
  @Value("${spring.cloud.nacos.discovery.server-addr}")
  private String address;
  @Value("${config.dataId}")
  private String dataId;
  @Value("${config.groupId}")
  private String groupId;
  @Value("${config.timeout}")
  private Long timeout;
 /* @Value("${config.ignore}")
  private String ignore;*/
  /**
   * 监听Nacos Server下发的动态路由配置
   */
  public void dynamicRouteByNacosListener() {
      try {
          ConfigService configService = NacosFactory.createConfigService(address);
          configService.addListener(dataId, groupId, new Listener() {
              @Override
              public void receiveConfigInfo(String configInfo) {
                  try {
                      logger.info("================Nacos 配置中心路由配置信息已修改================\n" + configInfo + "\n\n");
                      List<RouteDefinition> list = JSON.parseArray(configInfo, RouteDefinition.class);
                      list.forEach(definition -> {
                          dynamicRouteService.update(definition);
                      });
                  } catch (Exception e) {
                      e.printStackTrace();
                  }
              }
              @Override
              public Executor getExecutor() {
                  return null;
              }
          });
          /*configService.addListener(ignore, groupId, new Listener() {
              @Override
              public void receiveConfigInfo(String configInfo) {
                  try {
                      logger.info("================Nacos 配置中心忽略URL配置已修改================\n" + configInfo + "\n\n");
                      logger.info("\n" + configInfo + "\n\n");
                      List<String> ignoreList = JSON.parseArray(configInfo, String.class);
                      IgnoreRouteConfig.setIgnoreRouteArr(ignoreList);
                  } catch (Exception e) {
                      e.printStackTrace();
                  }
              }
              @Override
              public Executor getExecutor() {
                  return null;
              }
          });*/
      } catch (Exception e) {
          e.printStackTrace();
      }
  }
  @Override
  public void run(String... args) throws Exception {
      dynamicRouteByNacosListener();
  }
}

3.yml配置

关于springboot中nacos动态路由的配置

4. nacos网关配置

关于springboot中nacos动态路由的配置

5.最后:我建的是

父子工程两个服务发到服务器后 注意注意注意!!!:一定要开启防火墙,登上阿里云自己的服务增加端口,然后再linux中也要增加端口 linux防火墙相关命令

  • 删除 firewall-cmd --zone= public --remove-port=80/tcp --permanent
  • 开放 firewall-cmd --zone=public --add-port=1935/tcp --permanent
  • 查看状态 systemctl status firewalld
  • 启动 systemctl start firewalld
  • 查看已开启端口 firewall-cmd --list-ports
  • 重启 firewall-cmd --reload

关于springboot中nacos动态路由的配置

yml配置文件中 有一个这个端口 这个也要在阿里云上面还有服务器开启

这个就是接口访问时的网关端口号

关于springboot中nacos动态路由的配置

 

Springboot配置Nacos出现的问题

报错信息

java.lang.ClassNotFoundException:org.springframework.boot.context.properties.ConfigurationBeanFactoryMetadata

由于当前Nacos版本还不支持Springboot 2.4.+ 的版本,所以需要降一个版本 为2.3.+

具体如下

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'configurationPropertiesBeans' defined in class path resource [org/springframework/cloud/autoconfigure/ConfigurationPropertiesRebinderAutoConfiguration.class]: Post-processing of merged bean definition failed; nested exception is java.lang.IllegalStateException: Failed to introspect Class [org.springframework.cloud.context.properties.ConfigurationPropertiesBeans] from ClassLoader [jdk.internal.loader.ClassLoaders$AppClassLoader@1f89ab83]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:579) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:524) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:213) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.context.support.PostProcessorRegistrationDelegate.registerBeanPostProcessors(PostProcessorRegistrationDelegate.java:270) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.context.support.AbstractApplicationContext.registerBeanPostProcessors(AbstractApplicationContext.java:762) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:567) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:782) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:774) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:439) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:339) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:144) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.cloud.bootstrap.BootstrapApplicationListener.bootstrapServiceContext(BootstrapApplicationListener.java:212) ~[spring-cloud-context-2.2.5.RELEASE.jar:2.2.5.RELEASE]
	at org.springframework.cloud.bootstrap.BootstrapApplicationListener.onApplicationEvent(BootstrapApplicationListener.java:117) ~[spring-cloud-context-2.2.5.RELEASE.jar:2.2.5.RELEASE]
	at org.springframework.cloud.bootstrap.BootstrapApplicationListener.onApplicationEvent(BootstrapApplicationListener.java:74) ~[spring-cloud-context-2.2.5.RELEASE.jar:2.2.5.RELEASE]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:176) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:169) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:143) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:131) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.boot.context.event.EventPublishingRunListener.environmentPrepared(EventPublishingRunListener.java:82) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplicationRunListeners.lambda$environmentPrepared$2(SpringApplicationRunListeners.java:63) ~[spring-boot-2.4.5.jar:2.4.5]
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1540) ~[na:na]
	at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:117) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:111) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplicationRunListeners.environmentPrepared(SpringApplicationRunListeners.java:62) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.prepareEnvironment(SpringApplication.java:375) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:333) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1340) ~[spring-boot-2.4.5.jar:2.4.5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1329) ~[spring-boot-2.4.5.jar:2.4.5]
	at com.lenyuqin.product.ProductApplication.main(ProductApplication.java:14) ~[classes/:na]
Caused by: java.lang.IllegalStateException: Failed to introspect Class [org.springframework.cloud.context.properties.ConfigurationPropertiesBeans] from ClassLoader [jdk.internal.loader.ClassLoaders$AppClassLoader@1f89ab83]
	at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:481) ~[spring-core-5.3.6.jar:5.3.6]
	at org.springframework.util.ReflectionUtils.doWithLocalMethods(ReflectionUtils.java:321) ~[spring-core-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.buildLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:232) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.findLifecycleMetadata(InitDestroyAnnotationBeanPostProcessor.java:210) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(InitDestroyAnnotationBeanPostProcessor.java:149) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.context.annotation.CommonAnnotationBeanPostProcessor.postProcessMergedBeanDefinition(CommonAnnotationBeanPostProcessor.java:294) ~[spring-context-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyMergedBeanDefinitionPostProcessors(AbstractAutowireCapableBeanFactory.java:1098) ~[spring-beans-5.3.6.jar:5.3.6]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:576) ~[spring-beans-5.3.6.jar:5.3.6]
	... 31 common frames omitted
Caused by: java.lang.NoClassDefFoundError: org/springframework/boot/context/properties/ConfigurationBeanFactoryMetadata
	at java.base/java.lang.Class.getDeclaredMethods0(Native Method) ~[na:na]
	at java.base/java.lang.Class.privateGetDeclaredMethods(Class.java:3167) ~[na:na]
	at java.base/java.lang.Class.getDeclaredMethods(Class.java:2310) ~[na:na]
	at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:463) ~[spring-core-5.3.6.jar:5.3.6]
	... 38 common frames omitted
Caused by: java.lang.ClassNotFoundException: org.springframework.boot.context.properties.ConfigurationBeanFactoryMetadata
	at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:583) ~[na:na]
	at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178) ~[na:na]
	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:521) ~[na:na]
	... 42 common frames omitted

以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。

原文链接:https://blog.csdn.net/m0_46379371/article/details/113247647

延伸 · 阅读

精彩推荐
  • Java教程Java中线程的等待与唤醒_动力节点Java学院整理

    Java中线程的等待与唤醒_动力节点Java学院整理

    在Object.java中,定义了wait(), notify()和notifyAll()等接口。wait()的作用是让当前线程进入等待状态,同时,wait()也会让当前线程释放它所持有的锁。下面通过本...

    动力节点3092020-10-30
  • Java教程Java使用JavaMail发送邮件的方法

    Java使用JavaMail发送邮件的方法

    这篇文章主要介绍了Java使用JavaMail发送邮件的方法,结合实例形式分析了Java使用JavaMail实现邮件发送的具体步骤与相关实现代码,需要的朋友可以参考下 ...

    沧海小强4032020-04-15
  • Java教程Java扫描文件夹下所有文件名

    Java扫描文件夹下所有文件名

    这篇文章主要为大家详细介绍了Java扫描文件夹下所有文件名,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    qq_3837562010172021-04-02
  • Java教程Git和Maven的子模块简单实践

    Git和Maven的子模块简单实践

    今天小编就为大家分享一篇关于Git和Maven的子模块简单实践,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来...

    isea5336392021-06-24
  • Java教程java实现大数加法(BigDecimal)的实例代码

    java实现大数加法(BigDecimal)的实例代码

    之前写过用vector、string实现大数加法,现在用java的BigDecimal类,代码简单很多。但是在online-judge上,java的代码运行时间和内存大得多 ...

    java代码网3032019-10-16
  • Java教程Java创建多线程的8种方式集合

    Java创建多线程的8种方式集合

    这篇文章主要介绍了Java创建多线程的8种方式集合,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...

    itcats_cn10062021-12-02
  • Java教程老生常谈JVM的内存溢出说明及参数调整

    老生常谈JVM的内存溢出说明及参数调整

    下面小编就为大家带来一篇老生常谈JVM的内存溢出说明及参数调整。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧...

    Java之家5342020-08-30
  • Java教程Java集合框架源码分析之LinkedHashMap详解

    Java集合框架源码分析之LinkedHashMap详解

    这篇文章主要介绍了Java集合框架源码分析之LinkedHashMap详解,内容包括了linkedhashmap的简介和源码剖析以及关于LinkedHashMap的源码总结,内容丰富,需要的朋友...

    BridgeGeorge4782021-01-10