前言
- 前面的文章已经说了什么是Spring Cloud Alibaba,以及为什么选择使用SCA,这里我们就使用Spring Cloud Alibaba如何完成微服务的架构搭建展开讲解。
- 大家都知道作为微服务项目中一个必不可少的功能就是:服务的注册和发现,而市面上实现此功能的技术有很多,像Zookeeper,Eureka,consul等。
- 而作为阿里巴巴最新的开源项目之一,Nacos核心定位是“一个更易于帮助构建云原生应用的动态服务发现、配置和服务管理平台”,项目地址:https://nacos.io/zh-cn/
Naco提供了两个核心功能:服务注册与发现,动态管理配置
1. 服务注册与发现
Nacos提供基于DNS和基于RPC的服务发现,既能被用来支持https/http的服务注册与发现,也支持RPC如dubbo的服务注册与发现。
与Dubbo使用的zookeeper相比而言,两者差异还是比较大的,zookeeper是一种分布式的协调服务,它天生是作为分布式数据一致性场景下的解决方案,所以zookeeper是
CP(一致性和分区容错性)
,它牺牲了可用性
来保证一致性,在极端情况下(master选举期间)服务会对外停止服务,对于服务可用要求比较高的系统是难以接受的。Nacos是一种去中心话的架构,属于CAP理论里的AP(可用性和分区容器性)
架构,支持最终一致性,在分布式服务发现与注册场景下具有很不错的性能。目前dubbo官方也支持使用Nacos代替zookeeper。而相比Spring Cloud Eureka来说,Nacos更加强大。
Nacos=Spring Cloud Eureka + Spring Cloud Config
.
2. 动态配置服务
动态修改配置并实时生效对于服务端的同学来说并不陌生,这种服务能够让我们的服务拥有更多的灵活性,不需要重启服务即可做到配置实时生效,非常适合于“配置优先”的服务开发。
接下来我们将使用Nacos完成服务的注册和发现功能。
使用Nacos实现服务注册与发现
安装Nacos
下载地址:https://github.com/alibaba/nacos/releases
本文版本:1.0.0
下载完成之后,解压。根据不同平台,执行不同命令。
Linux/Unix/Mac
启动命令(standalone代表着单机模式运行,非集群模式):
sh startup.sh -m standalone
Windows
启动命令:
cmd startup.cmd
或者双击startup.cmd运行文件。
附:
startup.sh脚本位于Nacos解压后的bin目录下。
这里主要介绍Spring Cloud与Nacos的集成使用,对于Nacos的高级配置,后续再补充, 因为我们开发环境是window所以才使用第二种方式启动。
启动完成之后,访问:http://127.0.0.1:8848/nacos/,可以进入Nacos登陆页面:
如果使用Nacos 0.8.0以上版本,会出现登录页面,默认用户名密码为:nacos
登陆成功后会进入Nacos的服务管理页面,具体如下:
构建应用接入Nacos注册中心
在完成了Nacos服务的安装和启动之后,下面我们就可以编写两个应用(服务提供者和服务消费者)来验证服务的注册与发现了。
服务提供者
第一步:创建一个SpringBoot工程,命名为:alibaba-nacos-discovery-server
.
第二步:编辑pom.xml,加入必要的依赖配置,详细如下:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.SR1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>0.2.2.RELEASE</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>
<!-- spring-cloud-starter-{spring cloud子项目名称}-[{模板名称}] -->
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.2</version>
<optional>true</optional>
</dependency>
</dependencies>
上述配置主要分三部分:
- parent: 定义Spring Boot的版本
- dependencyManagement: Spring Cloud的版本以及Spring Cloud Alibaba的版本 ,由于Spring Cloud Alibaba还未纳入Spring Cloud主版本管理,所以需要单独引入
-
dependencies: 当前应用需要使用的依赖内容。这里新加入了Nacos的服务注册与发现版本模块:
spring-cloud-starter-alibaba-nacos-discovery
。 由于 dependencyManagement中已经引入了版本,所以这里就不用指定具体的版本号了。
第三步: 创建应用主类,编写对外提供服务的测试HTTP接口:
@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryServerApplication {
public static void main(String[] args) {
SpringApplication.run(NacosDiscoveryServerApplication.class, args);
}
}
@SpringBootApplication
定义是一个SpringBoot应用,@EnableDiscoveryClient
开启Spring Cloud的服务注册与发现,由于这里引入了spring-cloud-starter-alibaba-nacos-discovery
模块,所以Spring Cloud Common中定义了那些与服务治理相关接口将使用Nacos的实现。这点不论我们使用Eureka、Consule还是其他Spring Cloud整合的注册中心都是一样,这也是Spring Cloud做了封装后的好处所在。
@RestController
@Slf4j
public class TestController {
@GetMapping("/hello")
public String hello(@RequestParam String name) {
log.info("invoked name = {}", name);
return "hello " + name;
}
}
第四步:配置服务器名称和Nacos服务器地址, application.yml
server:
port: 9001 #服务端口
spring:
application:
# 服务名称尽量用 -,不用用 _,不用用特殊字符
name: alibaba-nacos-discovery-server
cloud:
nacos:
discovery:
# nacos server 地址
server-addr: localhost:8848
第五步:启动上面的应用。这里为了方便测试使用命令行方式启动在启动时添加 -Dserver.port=9002
的形式在本机的不同端口启动多个实例。
pom.xml添加maven打包插件:
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
打包:mvn clean package
运行:
java -jar -Dserver.port=9001 alibaba-nacos-discovery-server-1.0-SNAPSHOT.jar
java -jar -Dserver.port=9002 alibaba-nacos-discovery-server-1.0-SNAPSHOT.jar
启动完毕后看到下面日志,证明注册完毕:
2019-07-09 15:19:32.234 INFO 11988 --- [ main] o.s.c.a.n.registry.NacosServiceRegistry : nacos registry, alibaba-nacos-discovery-server 10.10.50.9:9002 register finished
实例全部启动完毕后,就可以在Nacos管理页面http://127.0.0.1:8848/nacos/ 来查看服务列表:
这里会显示当前注册的所有服务,以及每个服务集群数目、实例数、健康实例数。单击详情,我们还能看到每个服务具体的实例信息,如图所示:
服务消费者
接下来,实现一个应用来消费上已经注册到Nacos的服务。
第一步: 创建一个Spring Boot应用,命名为:alibaba-nacos-discovery-client
第二步: 编辑pom.xml文件中的依赖内容,同上面服务提供者一样即可。
第三步: 创建应用主类,编写一个消费者HTTP接口,在该接口中调用服务提供者提供的接口服务。
@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryClientApplication {
public static void main(String[] args) {
SpringApplication.run(NacosDiscoveryClientApplication.class, args);
}
}
@Slf4j
@RestController
public class TestController {
@Autowired
private LoadBalancerClient loadBalancerClient;
@GetMapping("/test")
public String test() {
// 通过spring cloud common中的负载均衡接口选取服务提供节点实现接口调用
ServiceInstance serviceInstance = loadBalancerClient.choose("alibaba-nacos-discovery-server");
String url = serviceInstance.getUri() + "/hello?name=" + "wolf";
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: 9003 #服务端口
spring:
application:
name: alibaba-nacos-discovery-client #服务实例名称
cloud:
nacos:
discovery:
server-addr: localhost:8848 #Nacos服务器地址
第五步: 启动消费者,通过curl或postman工具发起调用测试,下面以postman为例:
通过测试发现,两次不同的请求,真正调用的服务提供方实例是不同的,也就是说,通过 LoadBalancerClient
接口在获取服务实例的时候,已经实现了服务提供方实例的负载均衡。
但是这样的实现还是很繁琐,后面的文章我们会讲解其它更方便优雅的调用方式。