SpringCloud入门之注册中心与熔断

Spring Cloud基本概念

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用Spring Boot的开发风格做到一键启动和部署。Spring并没有重复制造轮子，它只是将目前各家公司开发的比较成熟、经得起实际考验的服务框架组合起来，通过Spring Boot风格进行再封装屏蔽掉了复杂的配置和实现原理，最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包

Spring Cloud Config: 服务配置中心,将所有的服务的配置文件放到本地仓库或者远程仓库,配置中心负责读取仓库的配置文件，其他服务向配置中心读取配置。 Spring Cloud Config使得服务的配置统一管理，并可以在不人为重启服务的情况下进行配置文件的刷新。

Spring Cloud Netflix:
它是通过包装了 Netflix 公司的微服务组件实现的，也是 Spring Cloud 核心的核心组件，包括 Eureka、 Hystrix、 Zuul、 Archaius 等。 Eureka:服务注册和发现组件。

Hystrix:熔断器组件 。 Hystrix 通过控制服务的 API 接口的熔断来转移故障，防止微服务系统发生雪崩效应。另外， Hystrix 能够起到服务限流和服务降级的作用。使用 Hystrix Dashboard 组件监控单个服务的熔断器的状态，使用 Turbine 组件可以聚合多个服务的熔断器的状态。

Zuul: 智能路由网关组件 。 Netflix Zuul 能够起到智能路由和请求过滤的作用，是服务接口统一暴露的关键模块，也是安全验证、权限控制的一道门。

Feign: 声明式远程调度组件。

Ribbon: 负载均衡组件。

Archaius:配置管理 API 的组件，一个基于 Java的配置管理库，主要用于多配置的动态获取。

Spring Cloud Bus: 消息总线组件，常和 Spring Cloud Config 配合使用，用于动态刷新服务的配置。

SpringCloudSleuth:服务链路追踪组件，封装了Dapper、 Zipkin, Kibina等组件，可以实时监控服务的链路调用情况。

Spring Cloud Data Flow:大数据操作组件， Spring Cloud Data Flow 是SpringXD的替代品，也是一个混合计算的模型，可以通过命令行的方式操作数据流。

Spring Cloud Security: 安全模块组件，是对Spring Security的封装，通常配合0Auth2 使用来保护微服务系统的安全。

Spring Cloud Consul:该组件是 Spring Cloud对Consul 的封装，和 Eureka类似，它是另一个服务注册和发现组件。

Spring Cloud Zookeeper:该组件是 Spring Cloud对 Zookeeper 的封装，和 Eureka、Consul 类似，用于服务的注册和发现。

Spring Cloud Stream:数据流操作组件，可以封装 Redis、 RabbitMQ、 Kafka 等组件，实现发送和接收消息等。

Spring Cloud CLI:该组件是 Spring Cloud 对 Spring Boot CLI 的封装，可以让用户以命令行方式快速运行和搭建容器。

Spring Cloud Task: 该组件基于 Spring Task，提供了任务调度和任务管理的功能。

Spring Cloud Connectors: 用于 Paas 云平台连接到后端。

Maven Module开发

Talk is cheap. Show me the code.---Linux之父

Eureka 服务注册与发现

(1)注册中心

spring.application.name=eureka-server

server.port=8000
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

(2)定义服务

配置文件

spring.application.name=hi-server

server.port=8002

eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

依赖

 <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <version>2.1.2.RELEASE</version>
        </dependency>
</dependencies>

服务

@RestController
public class HiController {
    @RequestMapping("/hi")
    public String hi(@RequestParam String name){
        return "hi "+name + " welcome to spring cloud";
    }
}

(3)调用服务

服务接口

@FeignClient(name="hi-server")
public interface HiRemote {
    @RequestMapping(value = "/hi")
    public String hi(@RequestParam(value = "name") String name);
}

-调用服务

@RestController
public class ApiController {

    @Autowired
    HiRemote hiRemote;

    @RequestMapping("/hi/{name}")
    public String index(@PathVariable("name") String name) {
        return hiRemote.hi(name);
    }
}

熔断器

image

(1)配置

feign.hystrix.enabled=true

(2)回调

fallback

(3)隔离

在Hystrix中, 主要通过线程池来实现资源隔离. 通常在使用的时候我们会根据调用的远程服务划分出多个线程池. 例如调用产品服务的Command放入A线程池, 调用账户服务的Command放入B线程池. 这样做的主要优点是运行环境被隔离开了. 这样就算调用服务的代码存在bug或者由于其他原因导致自己所在线程池被耗尽时, 不会对系统的其他服务造成影响. 但是带来的代价就是维护多个线程池会对系统带来额外的性能开销. 如果是对性能有严格要求而且确信自己调用服务的客户端代码不会出问题的话, 可以使用Hystrix的信号模式(Semaphores)来隔离资源

(4)UI

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>2.1.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
            <version>2.1.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

2.0以上版本

 @Bean
    public ServletRegistrationBean getServlet(){
        HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
        ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
        registrationBean.setLoadOnStartup(1);
        registrationBean.addUrlMappings("/actuator/hystrix.stream");
        registrationBean.setName("HystrixMetricsStreamServlet");
        return registrationBean;
    }

SpringCloud入门之注册中心与熔断

Spring Cloud基本概念

Maven Module开发

Eureka 服务注册与发现

熔断器

推荐阅读更多精彩内容