Spring Cloud Netflix OSS 学习总结

微服务SpringCloud

摘要: 本篇博客是使用SpringCloud框架开发微服务时候的一篇技术分享

正文:

Spring Cloud Netflix OSS

提供了对Netflix开源项目的集成，使我们可以以Spring Boot编程风格使用Netflix旗下相关框架，只需要在程序里添加注解，就可以使用成熟的Netflix组件(Eureka、Hystrix、Zuul、Ribbon、Sidecar)

Spring Cloud Eureka

Eureka客户端

  • 向Eureka注册服务

  • 高可用(HA)

    • 多注册中心主机

      如果配置了多个Eureka注册服务器，那么默认情况只有一台可用的服务器，存在注册信息。如果Down掉了，则会选择下一台可用的Eureka服务器。

  • 配置

    • 应用间隔

      registry-fetch-interval-seconds: 30 去服务端获取注册信息的间隔时间

    • 同步间隔

      instance-info-replication-interval-seconds: 30 更新实例信息的变化到服务端的间隔时间

    参考链接

  • 注意

    • 端口不要使用0
    • Eureka缓存
      1. Eureka Server对注册列表进行缓存，默认时间为30s。
      2. Eureka Client对获取到的注册信息进行缓存，默认时间为30s。
      3. Ribbon会从上面提到的Eureka Client获取服务列表，将负载均衡后的结果缓存30s。

Eureka服务端

img

  • 注册中心对比
Feature Consul zookeeper etcd euerka
服务健康检查 服务状态，内存，硬盘等 (弱)长连接，keepalive 连接心跳 可配支持
多数据中心 支持 — — —
kv存储服务 支持 支持 支持 —
一致性 raft paxos raft —
cap ca cp cp ap
使用接口(多语言能力) 支持http和dns 客户端 http/grpc http（sidecar）
watch支持 全量/支持long polling 支持 支持 long polling 支持 long polling/大部分增量
自身监控 metrics — metrics metrics
安全 acl /https acl https支持（弱） —
spring cloud集成 已支持 已支持 已支持 已支持

  • CAP

    • C 数据一致性 一致性是指数据的原子性，在经典的数据库中通过事务来保障，事务完成时，无论成功或回滚，数据都会处于一致的状态，在分布式环境下，一致性是指多个节点数据是否一致

      raft

    • A 服务可用性 服务一直保持可用的状态，当用户发出一个请求，服务能在一定的时间内返回结果

    • P 网络分区故障的容错性 在分布式应用中，可能因为一些分布式的原因导致系统无法运转，好的分区容忍性，使应用虽然是一个分布式系统，但是好像一个可以正常运转的整体

  • Consul

    • 服务发现
    • 健康检查
    • 键值存储
    • 多数据中心

    官网

    Spring Cloud Consul 参考文档

  • Eureka Server高可用配置

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    ---
    spring:
      profiles: peer1
    eureka:
      instance:
        hostname: peer1
      client:
        serviceUrl:
          defaultZone: http://peer2/eureka/

    ---
    spring:
      profiles: peer2
    eureka:
      instance:
        hostname: peer2
      client:
        serviceUrl:
          defaultZone: http://peer1/eureka/

    参考文档

Spring Cloud Ribbon

主要功能是为REST客户端实现负载均衡

Netflix Ribbon

  • 依赖

    1
    2
    3
    4
    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-ribbon</artifactId>
    </dependency>

  • Ribbon 客户端

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    @SpringBootApplication
    @RibbonClients({
            @RibbonClient(name = "service-provider")
    })
    public class Application {
    	@Bean
    	public RestTemplate restTemplate(){
    		return new RestTemplate();
    	}
    }

  • 配置

    application.properties

    1
    2
    service-provider.ribbon.listOfServers = \
      http://${host}:${port}

Netflix Ribbon 整合 Eureka

  • Ribbon 客户端

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    @SpringBootApplication
    @RibbonClients({
            @RibbonClient(name = "service-provider")
    })
    @EnableDiscoveryClient
    public class Application {
    	@Bean
      	@LoadBalanced
    	public RestTemplate restTemplate(){
    		return new RestTemplate();
    	}
    }

  • 配置

Spring Cloud OpenFeign

  • 发展

    9.0.0版本之后groupId io.netflix.feign更改为io.github.openfeign

    对应依赖spring-cloud-starter-feign–>spring-cloud-starter-openfeign

  • 依赖

    1
    2
    3
    4
    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-feign</artifactId>
    </dependency>

  • feign 客户端

    Application.java

    1
    2
    3
    4
    5
    6
    7
    8
    9
    @SpringBootApplication
    @EnableFeignClients
    public class Application {

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

    }

    feignClient.java

    1
    2
    3
    4
    5
    6
    @FeignClient(value = "ms-business-task-engine-server")
    public interface ITaskEngineService {
        @RequestMapping(value = "/TaskQueue/addTaskToQueue",method = RequestMethod.POST)
        BaseResponse addTaskToQueue(@RequestBody List<SubTaskDTO> subTaskDTOList);
    }

  • 配置参考ribbon

Spring Cloud Hystrix

hystrix可帮助隔离每个服务，使单个服务的响应失败，避免微服务架构中因个别服务出现异常而引起级联故障蔓延。

特性

  • 断路器机制(断路–>半开–>恢复)
  • 资源隔离
  • 熔断降级

Hystrix Dashboard 监控

Spring Cloud Zuul

在没有网关的时候，随着系统不断庞大，运维维护越来越复杂，接口校验逻辑的冗余越来越多，校验逻辑升级更为复杂。

ZuulFilter

过滤器类型

  • pre 路由之前执行
  • route 路由请求时被调用
  • post 在route和error过滤器之后被过滤
  • error 处理请求发生错误时候被调用

过滤器执行顺序

  • order越小，优先级越高

过滤器是否被执行

  • shouldFilter = true(结合yaml控制开启)

过滤器具体逻辑

  • run()

Routes

路由规则与列表

Spring Cloud Sidecar

非JVM语言接入SpringCloud的两种方案

  • Sidecar
    • 必须去实现一个健康检查接口
    • 只有状态，服务治理只能从网关层控制流量
  • 自己实现注册中心API Http接口(推荐)

示例代码-github