springcloud: A Java repository from shanehchao

Spring Cloud

Spring Cloud

简介

Spring Cloud是基于Spring Boot的一整套实现微服务的框架。提供了微服务开发所需的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理组件。
官网
dubbo和Spring Cloud对比

Eureka注册中心

创建项目，选择依赖
修改pom.xml（springboot和springcloud版本号）
修改核心配置文件
程序入口启动类添加注解
启动访问

Provider创建

创建Provider，添加依赖
修改pom.xml（springboot和springcloud版本号）
修改application.properties
在应用启动类中添加注解
启动provider，刷新注册中心页面，可查看注册的服务

Consumer创建-Ribbon方式

Spring cloud的服务消费者Consumer有两种服务调用方式，一种是ribbon+restTemplate，另一种是feign。 ribbon是一个负载均衡客户端。Feign默认集成了ribbon。

基于ribbon+restTemplate的服务调用架构示意图
创建项目、添加依赖
修改pom.xml（springboot和springcloud版本号）
配置文件application.properties
在springboot启动类中添加注解、创建restTemplate
创建service、controller 编写HelloService.java(在service实现类中完成服务调用)

Consumer创建-Feign方式

该方式是对RestTemplate方式的封装（无需创建该对象，并通过该对象调用服务），直接在Consumer的Service接口中通过Feign注解完成服务的调用。简而言之：

Feign 采用的是基于接口的注解
Feign 整合了ribbon

创建项目、添加依赖
修改pom.xml（springboot和springcloud版本号）
核心配置文件application.properties
在应用启动类中添加注解
编写service接口和controller代码
运行测试
与ribbon+rest对比
- 依赖不同
- 注解不同
- 加载对象
  1. ribbon需要加载RestTemplate
  2. feign无需手动加载

断路器-Hystrix

如果单个服务出现问题，由于服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成灾难性的严重后果，这就是服务故障的“雪崩”效应。为了解决这个问题，业界提出了断路器模型。当对特定的服务的调用的不可用达到一个阈值（Hystrix 是5秒20次）断路器将会被打开。断路打开后，可以避免连锁故障，fallback方法可以直接返回一个固定值。

ribbon+RestTemplate方式中使用断路器

创建项目、添加依赖
修改pom.xml（springboot和springcloud版本号）
编写核心配置文件，同ribbon项目
启动类添加注解
HelloService.java

feign中使用断路器

手动添加hystrix的依赖（在mvnRepository找即可）
核心配置文件，开启Feign自带的断路器
添加service实现、修改service接口
- 添加service实现
- 修改service接口

Hystrix Dashboard

断路器仪表盘:断路器状态监控界面

添加两个依赖
在启动类上添加注解
界面如下

路由Zuul

Zuul的主要功能是路由转发和过滤器。路由功能是微服务的一部分，比如／api/a转发到到a服务，/api/b转发到到b服务。zuul默认和Ribbon结合实现了负载均衡的功能。

路由转发

架构示意图
创建项目，添加依赖
添加注解
修改核心配置文件
测试启动注册中心、provider、consumer和zuul项目，访问http://localhost:8087/a/getinfo 或 http://localhost:8087/b/getinfo

Zuul过滤器

编写过滤器类继承ZuulFilter，并重写当中的方法。方法解释：
Debug启动Consumer项目并在controller方法上加断点，看是否请求相应的项目。访问路径：http://localhost:8087/a/getinfo 或 http://localhost:8087/b/getinfo

多注册中心

当成千上万个服务向注册中心注册的时候，它的负载是非常高的，这在生产环境上是不太合适的，如何将Eureka Server集群化？通过运行多个Eureka实例，使其更具有高可用性即可。

核心配置文件

application-peer1.properties

# 运行端口号
server.port=8088

# 指定注册中心实例名
eureka.instance.hostname=localhost

# 应用名称
spring.application.name=springcloud-reg1

#注册当前服务
eureka.client.service-url.defaultZone=http://localhost:8089/eureka

application-peer2.properties

# 运行端口号
server.port=8089

# 指定注册中心实例名
eureka.instance.hostname=localhost

# 应用名称
spring.application.name=springcloud-reg2

#注册当前服务
eureka.client.service-url.defaultZone=http://localhost:8088/eureka

application.properties

# 指定默认加载的配置文件
spring.profiles.active=peer1

指定注册中心

在服务提供者、消费者、代理方等项目指定多个注册中心即可 eureka.client.service-url.defaultZone=http://localhost:8088/eureka,http://localhost:8089/eureka

打包运行

打包命令mvn package

运行

java -jar xxxx.jar  --spring.profiles.active=peer1
java -jar xxxx.jar  --spring.profiles.active=peer2

配置管理中心config

在分布式系统中，由于服务数量巨多，为了方便服务配置文件统一管理，实时更新，所以需要分布式配置中心组件。在Spring Cloud中，有分布式配置中心组件spring cloud config ，它支持配置服务放在配置服务的内存中（即本地），也支持放在远程SVN或Git仓库中。在spring cloud config 组件中，分两个角色，一是config server，二是config client。

配置文件统一管理示意图

创建服务端

创建项目，添加依赖

修改pom文件（核对版本号），手动添加svnkit依赖（mvnRepository查找）

<dependency>
    <groupId>org.tmatesoft.svnkit</groupId>
    <artifactId>svnkit</artifactId>
</dependency>

在启动类上添加注解

package com.cylib;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.config.server.EnableConfigServer;

@SpringBootApplication
@EnableDiscoveryClient
@EnableConfigServer
public class Springcloud10ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springcloud10ConfigServerApplication.class, args);
    }
}

修改核心配置文件application.properties

# 运行端口号
server.port=8090

# 应用名称
spring.application.name=config-server

# 注册中心路径
eureka.client.service-url.defaultZone=http://localhost:8080/eureka

# SVN配置信息
# 指定连接版本库类型
spring.profiles.active=subversion
# 指定SVN服务器路径
spring.cloud.config.server.svn.uri=svn://localhost/springcloud/
spring.cloud.config.server.svn.username=aelchao
spring.cloud.config.server.svn.password=aelchao
# 指定默认访问的分支名称
spring.cloud.config.server.svn.default-label=trunk

SVN服务器新建springcloud库，在trunk下新建config-server-dev.properties，添加star.username=zhangsan
测试config-server端是否可用
- 访问路径：http://localhost:8086/config-server/dev
- 访问路径中config-server是应用名称，dev是配置文件名的一部分，底层自动拼接成要访问的文件名。
- 返回信息如下，有配置文件中内容，则证明config-server端可用

创建客户端

创建项目，添加依赖（修改pom.xml）（由于测试使用到springmvc，需要添加web起步依赖）
1. ```
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
</dependency>
```
2. 其他依赖和服务端相同

重命名核心配置文件为bootstrap.properties

# 运行端口号
server.port=8091

# 应用名称
spring.application.name=config-client

# 注册中心路径
eureka.client.service-url.defaultZone=http://localhost:8080/eureka

# 服务端地址
spring.cloud.config.uri=http://localhost:8090

# 分支名称
spring.cloud.config.label=trunk

# 访问文件名称
spring.cloud.config.name=config-client
spring.cloud.config.profile=dev

在SVN，springcloud/trunk/新建config-config-dev.properties，添加star.username=lisi

启动类测试代码如下：

package com.cylib;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableDiscoveryClient
@RestController
public class Springcloud11ConfigClientApplication {

    @Value("${star.username}")
    private String username;

    @RequestMapping("getusername")
    public String getUsername() {
        return username;
    }

   public static void main(String[] args) {
      SpringApplication.run(Springcloud11ConfigClientApplication.class, args);
   }
}

浏览器访问，结果如下：
配置中心服务端和客户端都需要添加注册中心，否则客户端会有异常com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any
- pom.xml
```
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
```
- 配置文件application.properties和bootstrap.properties增加注册中心
```
# 注册中心路径
eureka.client.service-url.defaultZone=http://localhost:8080/eureka
```
- 启动类增加注解@EnableDiscoveryClient

服务追踪Zipkin

随着服务的越来越多，对调用链的分析会越来越复杂，如何解决这一问题呢？ Spring Cloud提供了服务追踪组件zipkin 本案例主要有三个工程组成：一个server-zipkin，它的主要作用使用ZipkinServer的功能，收集调用数据并展示，一个service-01和一个service-02，这两个service可以相互调用，并且只有调用了，server-zipkin才会收集数据，这就是为什么叫服务追踪了。

创建server-zipkin

创建项目，添加依赖（mvnrepository查找，不添加版本号可能会版本冲突）

<dependency>
    <groupId>io.zipkin.java</groupId>
    <artifactId>zipkin-server</artifactId>
    <version>2.4.5</version>
</dependency>

<dependency>
    <groupId>io.zipkin.java</groupId>
    <artifactId>zipkin-autoconfigure-ui</artifactId>
    <version>2.4.5</version>
</dependency>

启动类中添加注解 @EnableZipkinServer
修改核心配置文件
```
# 运行端口号
server.port=9411
```

创建service-01

创建项目，添加依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
    <version>1.3.1.RELEASE</version>
</dependency>

修改核心配置文件

# 运行端口号
server.port=8092

# 应用名称
spring.application.name=zipkin-service01

# zipkin server地址
spring.zipkin.base-url=http://localhost:9411

启动类

package com.cylib;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@RestController
public class Springcloud12Service01Application {

    @Autowired
    private RestTemplate restTemplate;

    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    // 构建采样器
    @Bean
    public AlwaysSampler getAlwaysSampler() {
        return new AlwaysSampler();
    }

    @RequestMapping("/getinfo")
    public String getInfo() {
        return "zipkin service 01";
    }

    @RequestMapping("/getservice")
    public String getService() {
        return restTemplate.getForObject("http://localhost:8093/getservice", String.class);
    }

    public static void main(String[] args) {
        SpringApplication.run(Springcloud12Service01Application.class, args);
    }
}

创建service-02

创建项目，添加依赖（不添加版本号可能会版本冲突）

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
    <version>1.3.1.RELEASE</version>
</dependency>