Spring Cloud Netflix OSS 学习总结

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

正文:

Spring Cloud Netflix OSS

Spring Cloud Eureka

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

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

• 注册中心对比

• CAP
  • C 数据一致性 一致性是指数据的原子性，在经典的数据库中通过事务来保障，事务完成时，无论成功或回滚，数据都会处于一致的状态，在分布式环境下，一致性是指多个节点数据是否一致 raft
  • A 服务可用性 服务一直保持可用的状态，当用户发出一个请求，服务能在一定的时间内返回结果
  • P 网络分区故障的容错性 在分布式应用中，可能因为一些分布式的原因导致系统无法运转，好的分区容忍性，使应用虽然是一个分布式系统，但是好像一个可以正常运转的整体
• Consul
  • 服务发现
  • 健康检查
  • 键值存储
  • 多数据中心

  官网 Spring Cloud Consul 参考文档

• Eureka Server高可用配置 12345678910111213141516171819---spring: profiles: peer1eureka: instance: hostname: peer1 client: serviceUrl: defaultZone: http://peer2/eureka/---spring: profiles: peer2eureka: instance: hostname: peer2 client: serviceUrl: defaultZone: http://peer1/eureka/ 参考文档

Spring Cloud Ribbon

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

Netflix Ribbon

• 依赖 1234<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId></dependency>
• Ribbon 客户端 12345678910@SpringBootApplication@RibbonClients({ @RibbonClient(name = "service-provider")})public class Application { @Bean public RestTemplate restTemplate(){ return new RestTemplate(); }}
• 配置 application.properties 12service-provider.ribbon.listOfServers = \ http://${host}:${port}

Netflix Ribbon 整合 Eureka

• Ribbon 客户端 123456789101112@SpringBootApplication@RibbonClients({ @RibbonClient(name = "service-provider")})@EnableDiscoveryClientpublic 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
• 依赖 1234<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-feign</artifactId></dependency>
• feign 客户端 Application.java 123456789@SpringBootApplication@EnableFeignClientspublic class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); }} feignClient.java 12345@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