Nacos实现服务注册与发现
什么是Nacos?
Nacos致力于帮助您发现、配置和管理微服务。Nacos提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。Nacos帮助您更敏捷和容易地构建、交付和管理微服务平台。
在接下来的教程里将使用Nacos作为微服务架构中的注册中心(替代:consul等)以及配置中心(spring cloud config)来使用。
安装Nacos
下载地址:https://github.com/alibaba/nacos/releases 本文版本:2.1.1
通过下载工具下载之后,解压。里面有不同脚本文件,根据不同平台,执行相应命令,启动单机版Nacos服务:
Linux/Unix/Mac:sh startup.sh -m standalone Windows:cmd startup.cmd -m standalone
相应startup.sh脚本在Nacos解压后的bin目录下。
启动完成之后,访问:http://localhost:8848/,可以进入Nacos的服务管理页面,具体如下;
应用接入Nacos注册中心
在完成了Nacos服务的安装和启动之后,下面我们编写两个应用(服务提供者与服务消费者)来验证服务的注册与发现了。
服务提供者
- 第一步:创建一个Spring Boot应用
- 第二步:修改pom文件
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.7.1</version> <relativePath/> <!-- lookup parent from repository --> </parent> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>2021.0.3</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-alibaba-dependencies</artifactId> <version>2021.1</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.22</version> <optional>true</optional> </dependency> </dependencies>
述内容主要三部分:
parent:定义spring boot的版本
dependencyManagement:spring cloud的版本以及spring cloud alibaba的版本,
dependencies:当前应用要使用的依赖内容。这里主要新加入了Nacos的服务注册与发现模块:spring-cloud-starter-alibaba-nacos-discovery。
第三步:创建应用主类,并实现一个HTTP接口
@EnableDiscoveryClient @SpringBootApplication public class ErosApplication { public static void main(String[] args) { SpringApplication.run(ErosApplication.class, args); } @Slf4j @RestController static class ErosController { @GetMapping("/hello") public String hello(@RequestParam String name) { return "hello " + name; } } }
- 第四步:配置服务名称和Nacos地址spring:
server: port: 8001 application: name: eros-gateway cloud: discovery: server-addr=127.0.0.1:8848
- 第五步:启动应用。
INFO 10475 --- [ main] o.s.c.a.n.registry.NacosServiceRegistry : nacos registry, eros-gateway 192.168.177.1:8801 register finished
在启动都没问题后可以访问Nacos的管理页面http://127.0.0.1:8848/nacos/来查看服务列表
服务消费者
接下来,实现一个应用来消费上面已经注册到Nacos的服务。
- 第一步:创建一个Spring Boot应用
- 第二步:编辑pom.xml中的依赖内容,与上面服务提供者的一样即可。
- 第三步:创建应用,实现一个HTTP接口,在该接口中调用服务提供方的接口。
@EnableDiscoveryClient @SpringBootApplication public class ErosApplication { public static void main(String[] args) { SpringApplication.run(ErosApplication.class, args); } @Slf4j @RestController static class TestController { @Autowired LoadBalancerClient loadBalancerClient; @GetMapping("/test") public String test() { ServiceInstance serviceInstance = loadBalancerClient.choose("eros-gateway"); String url = serviceInstance.getUri() + "/hello?name=" + "eros"; RestTemplate restTemplate = new RestTemplate(); String result = restTemplate.getForObject(url, String.class); return "Invoke : " + url + ", return : " + result; } } }
这里使用了Spring Cloud Common中的LoadBalancerClient接口来挑选服务实例信息。然后从挑选出的实例信息中获取可访问的URI,拼接上服务提供方的接口规则来发起调用。
-第四步:配置服务名称和Nacos地址,让服务消费者可以发现上面已经注册到Nacos的服务。
server: port: 8001 application: name: eros-gateway-client cloud: discovery: server-addr=127.0.0.1:8848
第五步:启动服务消费者,然后通过curl或者postman等工具发起访问,下面以curl为例:
$ curl localhost:9000/test Invoke : http://192.168.177.1:8801/hello?name=eros, return : hello eros $ curl localhost:9000/test Invoke : http://192.168.177.1:8802/hello?name=eros, return : hello eros
通过以上请求可以看到,两次不同请求的时候,真正实际调用的服务提供者实例是不同的,也就是说,通过LoadBalancerClient接口在获取服务实例的时候,已经实现了对服务提供方实例的负载均衡。
以上就是我们今天的教程,如果本文对你有所帮助,欢迎关注点赞,分享给您身边的朋友。您的鼓励就是对我的最大动力。