Springboot 项目集成 Nacos 实现服务注册发现与配置管理

本文转载自微信公众号「Java极客技术」,作者鸭血粉丝。转载本文请联系Java极客技术公众号。

公司主营业务:成都网站建设、成都网站制作、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联推出新会免费做网站回馈大家。

Hello 大家好,我是阿粉,前面的文章给大家介绍了一下如何在本地搭建微服务环境下的服务注册中心和配置管理中心 Nacos,今天通过

我们通过使用 SpringBoot 项目集成 Nacos 来给大家演示一下是如何使用 Nacos 来实现服务发现和配置管理的。

启动 Nacos 服务

启动完本地搭建的 Nacos 服务后,我们可以看到,目前的服务管理下面的服务列表里面在三个命名空间下都没有服务,这是正常的,因为目前我们还没有服务接入Nacos。

Nacos 服务启动成功后,我们再创建两个 SpringBoot 项目,一个用于接入 Nacos 服务注册与发现和配置中心作为服务提供者 Producer,另一个只接入 Nacos的服务注册与发现,调用 Producer 获取配置中心的参数,我们叫做Consumer。

服务提供者 Producer

1.我们首先创建一个 SpringBoot 的项目,bootstrap.properties 文件内容如下:

 
 
 
 
  1. spring.application.name=producer 
  2.  
  3. #######################配置中心配置################################# 
  4. # 指定的命名空间,只会在对应的命名空间下查找对应的配置文件 
  5. spring.cloud.nacos.config.namespace=caeser-adsys-naming 
  6. spring.cloud.nacos.config.file-extension=properties 
  7. # 配置的分组名称 
  8. spring.cloud.nacos.config.group=TEST1 
  9. # 配置文件,数组形式,可以多个,依次递增 
  10. spring.cloud.nacos.config.ext-config[0].data-id=com.example.properties 
  11. spring.cloud.nacos.config.ext-config[0].group=TEST1 
  12. # 配置中心的地址 
  13. spring.cloud.nacos.config.server-addr=127.0.0.1:8848 
  14. #启用自动刷新对应的配置文件 
  15. spring.cloud.nacos.config.ext-config[0].refresh=true 
  16. ######################服务注册发现配置################################## 
  17.  
  18. # 服务集群名称 
  19. spring.cloud.nacos.discovery.cluster-name=TEST1_GROUP 
  20. # 服务注册中心的地址 
  21. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848 
  22. # 服务的命名空间 
  23. spring.cloud.nacos.discovery.namespace=caeser-adsys-naming 

2.application.properties 的文件内容如下,主要就是一个端口,其他配置根据情况自行添加或删除就好:

 
 
 
 
  1. # 服务启动的端口 
  2. server.port=8080 
  3. spring.main.allow-bean-definition-overriding=true 
  4. # tomcat 配置 
  5. server.tomcat.max-threads=500 
  6. spring.mvc.servlet.load-on-startup=1 
  7. spring.servlet.multipart.max-file-size=40MB 
  8. spring.servlet.multipart.max-request-size=100MB 
  9. # 日志配置 
  10. logging.level.root=info 
  11. logging.level.com.alibaba=error 
  12. logging.pattern.console=%clr{[%level]}{green} [%d{yyyy-MM-dd HH:mm:ss}] %clr{[${PID:-}]}{faint} %clr{[%thread]}{magenta} %clr{[%-40.40logger{80}:%line]}{cyan} %msg%n 

3.在启动类上面增加如下注解

 
 
 
 
  1. package com.ziyou.nacos.demo.producer; 
  2.  
  3. import org.springframework.boot.SpringApplication; 
  4. import org.springframework.boot.autoconfigure.SpringBootApplication; 
  5. import org.springframework.cache.annotation.EnableCaching; 
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient; 
  7.  
  8. @SpringBootApplication(scanBasePackages = "com.ziyou.nacos") 
  9. @EnableDiscoveryClient 
  10. @EnableCaching 
  11. public class ProducerApplication { 
  12.  
  13.     public static void main(String[] args) { 
  14.         SpringApplication.run(ProducerApplication.class, args); 
  15.     } 

4.pom.xml 文件内容如下:

 
 
 
 
  1.  
  2.  
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
  4.   4.0.0 
  5.  
  6.    
  7.     org.example 
  8.     nacos-demo 
  9.     1.0-SNAPSHOT 
  10.    
  11.  
  12.   producer 
  13.   1.0-SNAPSHOT 
  14.  
  15.   producer Maven Webapp 
  16.    
  17.   http://www.example.com 
  18.  
  19.    
  20.     UTF-8 
  21.     1.7 
  22.     1.7 
  23.     2.2.2.RELEASE 
  24.    
  25.  
  26.    
  27.      
  28.      
  29.       org.springframework.boot 
  30.       spring-boot-starter 
  31.        
  32.          
  33.           org.springframework.boot 
  34.           spring-boot-starter-logging 
  35.          
  36.        
  37.      
  38.      
  39.       org.springframework.boot 
  40.       spring-boot-starter-log4j2 
  41.      
  42.      
  43.       org.springframework.boot 
  44.       spring-boot-starter-web 
  45.      
  46.  
  47.      
  48.      
  49.       com.alibaba.cloud 
  50.       spring-cloud-starter-alibaba-nacos-config 
  51.      
  52.      
  53.      
  54.       com.alibaba.cloud 
  55.       spring-cloud-starter-alibaba-nacos-discovery 
  56.      
  57.    
  58.  
  59.    
  60.      
  61.      
  62.        
  63.        
  64.         src/main/resources 
  65.         true 
  66.          
  67.           **/** 
  68.          
  69.        
  70.      
  71.     producer 
  72.      
  73.        
  74.         org.springframework.boot 
  75.         spring-boot-maven-plugin 
  76.         ${spring.maven.plugin.version} 
  77.          
  78.            
  79.              
  80.               repackage 
  81.              
  82.            
  83.          
  84.        
  85.      
  86.    
  87.  

5.在 Producer 侧提供一个获取配置里面内容的接口,代码如下:

 
 
 
 
  1. package com.ziyou.nacos.demo.producer.controller; 
  2.  
  3. import com.ziyou.nacos.demo.producer.config.UserConfig; 
  4. import org.springframework.beans.factory.annotation.Autowired; 
  5. import org.springframework.web.bind.annotation.GetMapping; 
  6. import org.springframework.web.bind.annotation.RequestMapping; 
  7. import org.springframework.web.bind.annotation.RestController; 
  8.  
  9. /** 
  10.  * 
     
  11.  * Function:
     
  12.  * Author:@author ziyou
     
  13.  * Date:2021-04-11 19:59
     
  14.  * Desc:
     
  15.  */ 
  16. @RestController 
  17. @RequestMapping(value = "producer") 
  18. public class ProducerController { 
  19.  
  20.     private UserConfig userConfig; 
  21.  
  22.     @GetMapping("/getUsername") 
  23.     private String getUsername() { 
  24.         String result = userConfig.getUsername() + "-" + userConfig.getPassword(); 
  25.         System.out.println(result); 
  26.         return result; 
  27.     } 
  28.  
  29.     @Autowired 
  30.     public void setUserConfig(UserConfig userConfig) { 
  31.         this.userConfig = userConfig; 
  32.     } 
 
 
 
 
  1. package com.ziyou.nacos.demo.producer.config; 
  2.  
  3. import org.springframework.beans.factory.annotation.Value; 
  4. import org.springframework.cloud.context.config.annotation.RefreshScope; 
  5. import org.springframework.stereotype.Component; 
  6.  
  7. /** 
  8.  * 
     
  9.  * Function:
     
  10.  * Author:@author ziyou
     
  11.  * Date:2021-04-11 20:39
     
  12.  * Desc:
     
  13.  */ 
  14. @RefreshScope 
  15. @Component 
  16. public class UserConfig { 
  17.     @Value("${username}") 
  18.     private String username; 
  19.     @Value("${password}") 
  20.     private String password; 
  21.  
  22.     public String getUsername() { 
  23.         return username; 
  24.     } 
  25.  
  26.     public void setUsername(String username) { 
  27.         this.username = username; 
  28.     } 
  29.  
  30.     public String getPassword() { 
  31.         return password; 
  32.     } 
  33.  
  34.     public void setPassword(String password) { 
  35.         this.password = password; 
  36.     } 

6.启动 Producer,并且手动调用接口,启动 Producer 过后,我们在 Nacos 的服务注册列表可以看如下所示的内容,在 test1 的命名空间下,已经有了我们创建的 Producer 服务。

7.通过手动调用 Producer 的接口 http://127.0.0.1:8080/producer/getUsername 显示如下内容

并且我们看下此时 Nacos 的配置中心里面配置文件com.example.properties 里面的内容正是这个,这个时候我们手动把配置里面password 参数的值改成JavaGeek666,再次访问接口,我们会发现接口的输出也自动改变了。

修改配置内容如下:

再次访问结果如下:

服务调用者 Consumer

前面我们已经完成了Producer 的服务注册与配置动态生效的功能,这个时候基本已经可以使用了,不过我们还需要更进一步通过 Nacos 来实现服务发现,接下来我们创建 Consumer 的 SpringBoot 的项目,配置文件和pom.xml 文件基本一致,只要修改端口以及对应地方,下面贴一下不一样的地方

1.boostrap.properties 内容如下,因为这里我们只调用Producer 的接口,不需要接入 Nacos 的配置中心,所以这里只配置发服务注册与发现

 
 
 
 
  1. spring.application.name=consumer 
  2.  
  3. ######################服务注册发现配置################################## 
  4. spring.cloud.nacos.discovery.cluster-name=TEST1_GROUP 
  5. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848 
  6. spring.cloud.nacos.discovery.namespace=caeser-adsys-naming 

2.启动类,配置上 feignClient 需要扫描的包路径

 
 
 
 
  1. package com.ziyou.nacos.demo.consumer; 
  2.  
  3. import org.springframework.boot.SpringApplication; 
  4. import org.springframework.boot.autoconfigure.SpringBootApplication; 
  5. import org.springframework.cache.annotation.EnableCaching; 
  6. import org.springframework.cloud.openfeign.EnableFeignClients; 
  7.  
  8. /** 
  9.  * 
     
  10.  * Function:
     
  11.  * Author:@author ziyou
     
  12.  * Date:2021-04-11 17:07
     
  13.  * Desc:
     
  14.  */ 
  15. @SpringBootApplication(scanBasePackages = "com.ziyou.nacos") 
  16. @EnableFeignClients(basePackages = {"com.ziyou.nacos.demo.consumer.rpc"}) 
  17. @EnableCaching 
  18. public class ConsumerApplication { 
  19.     public static void main(String[] args) { 
  20.         SpringApplication.run(ConsumerApplication.class, args); 
  21.     } 

3.编写调用 Producer 的接口,FeignClient 里面的 value 就是 Producer 的应用名称

 
 
 
 
  1. package com.ziyou.nacos.demo.consumer.rpc; 
  2.  
  3. import org.springframework.cloud.openfeign.FeignClient; 
  4. import org.springframework.stereotype.Component; 
  5. import org.springframework.web.bind.annotation.GetMapping; 
  6.  
  7. /** 
  8.  * 
     
  9.  * Function:
     
  10.  * Author:@author ziyou
     
  11.  * Date:2021-04-11 20:01
     
  12.  * Desc:
     
  13.  */ 
  14. @FeignClient(value = "producer") 
  15. @Component 
  16. public interface IProducerFeign { 
  17.     /** 
  18.      * 获取生产者名称接口 
  19.      * 
  20.      * @return 
  21.      */ 
  22.     @GetMapping("/producer/getUsername") 
  23.     String getUsername(); 
  24.  
 
 
 
 
  1. package com.ziyou.nacos.demo.consumer.controller; 
  2.  
  3. import com.ziyou.nacos.demo.consumer.rpc.IProducerFeign; 
  4. import org.springframework.beans.factory.annotation.Autowired; 
  5. import org.springframework.web.bind.annotation.GetMapping; 
  6. import org.springframework.web.bind.annotation.RequestMapping; 
  7. import org.springframework.web.bind.annotation.RestController; 
  8.  
  9. /** 
  10.  * 
     
  11.  * Function:
     
  12.  * Author:@author ziyou
     
  13.  * Date:2021-04-11 19:59
     
  14.  * Desc:
     
  15.  */ 
  16. @RestController 
  17. @RequestMapping(value = "consumer") 
  18. public class TestNacosController { 
  19.  
  20.     private IProducerFeign iProducerFeign; 
  21.  
  22.     @GetMapping("/testNacos") 
  23.     private String testNacos() { 
  24.         return iProducerFeign.getUsername(); 
  25.     } 
  26.  
  27.     @Autowired 
  28.     public void setiProducerFeign(IProducerFeign iProducerFeign) { 
  29.         this.iProducerFeign = iProducerFeign; 
  30.     } 

4.启动Consumer,我们可以看到在 Nacos 如下图所示

5.调用 Consumer 的接口consumer/testNacos,结果如下图所示,同样的如果此时更改了 Nacos 配置文件中的内容,Consumer 这边也是可以实时更新的,感兴趣的小伙伴可以自己试试。

今天主要给大家介绍了一下如何通过 SpringBoot 项目来接入 Naocs 实现服务注册与发现,以及配置管理和动态刷新,相关的代码已经上传到 GitHub 了。

分享文章:Springboot 项目集成 Nacos 实现服务注册发现与配置管理
文章分享:http://www.shufengxianlan.com/qtweb/news3/93153.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联