在分布式系统领域有个著名的 CAP定理
( C-数据一致性
; A-服务可用性
; P-服务对网络分区故障的容错性
,这三个特性在任何分布式系统中 不能同时满足,最多同时满足两个
); eureka是AP
, zookeeper是CP
。对于 服务发现
而言, 可用性
比 数据一致性
更加重要—— AP胜过CP
Consul | zookeeper | euerka | etcd | |
---|---|---|---|---|
服务健康检查 | 服务状态,内存,硬盘等 | (弱)长连接,keepalive | 可配支持 | 连接心跳 |
多数据中心 | 支持 | — | — | — |
kv存储服务 | 支持 | 支持 | — | 支持 |
一致性 | raft | paxos | — | raft |
CAP | ca | cp | ap | cp |
使用接口(多语言能力) | 支持http和dns | 客户端 | http(sidecar) | http/grpc |
watch支持(客户端观察到服务提供者变化) | 全量/支持long polling | 支持 | 支持long polling/大部分增量 | 支持long polling |
自身监控 | metrics | — | metrics | metrics |
安全 | acl /https | acl | — | https支持(弱) |
spring cloud集成 | 已支持 | 已支持 | 已支持 | 已支持 |
raft
:Raft强依赖 Leader 节点的可用性来确保集群数据的一致性。
paxos
: 第一次由提交者Leader向所有其他服务器发出prepare消息请求准备,所有服务器中大多数如果回复诺言承诺就表示准备好了,可以接受写入;第二次提交者向所有服务器发出正式建议propose,所有服务器中大多数如果回复已经接收就表示成功了。
long polling
:长轮询,客户端向服务器发送Ajax请求,服务器接到请求后hold住连接,直到有新消息才返回响应信息并关闭连接,客户端处理完响应信息后再向服务器发送新的请求。
metrics
:作为一款监控指标的度量类库,它提供了很多模块可以为第三方库或者应用提供辅助统计信息, 它还可以将度量数据发送给Ganglia和Graphite以提供图形化的监控
Eureka的自我保护模式
Eureka Server
在运行期间,会统计心跳失败的比例在15分钟之内是否 低于85%,如果出现低于的情况(实际在 生产环境上通常是由于网 络不稳定导致), Eureka Server
会将当前的实例注册信息保护起来,同时提 示警告。保护模式主要用于一组客户端和 Eureka Server
之间存在网络分 区场景下的保护。一旦进入保护模式, Eureka Server
将会尝试保护其服务注 册表中的信息,不再删除服务注册表中的数据(也就是不会注销任何微服务)。
所以 Eureka
的哲学是,同时保留 ”好数据“
与 ”坏数据“
总比丢掉任何”好数据“要更好,所以这种模式在实践中非常有效。,
ZooKeeper
是分布式协调服务,它的职责是保证数据(注:配置数据,状态数据)在其管辖下的所有服务之间保持同步、一致;(强一致性) ZooKeeper
使用单一主进程 Leader
用于处理客户端所有事务请求,采用 ZAB协议
将服务器数状态以事务形式广播到所有 Follower
上;如果三台服务挂了两台怎么选出 leader
; 1 不大于 (3/2)=1的
, ZooKeeper服务
就非常的困难 ZooKeeper
会将它们都从自己管理范围中剔除出去,外界就不能访问到这些节点了,本身这些节点是 “健康”
的,能提供服务的 包含不实的信息的结果也比什么都不返回要好
(因为暂时的网络故障而找不到可用的服务器) 因此, Eureka
可以很好的应对因网络故障导致部分节点失去联系的情况,而不会像 zookeeper
那样使整个注册服务瘫痪。
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> 复制代码
通过 @EnableEurekaServer
注解启动一个服务注册中心提供给其他应用进行对话,这个注解需要在 springboot工程
的启动 application类
上加
package io.ymq.example.eureka.server; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication @EnableEurekaServer public class EurekaServerApplication { public static void main(String[] args) { SpringApplication.run(EurekaServerApplication.class, args); } } 复制代码
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka-server</artifactId> </dependency> 复制代码
开启服务注册
在应用主类中通过加上@EnableEurekaClient
,但只有 Eureka
可用,你也可以使用 @EnableDiscoveryClient
。需要配置才能找到 Eureka注册中心服务器
discovery service
有许多种实现( eureka、consul、zookeeper
等)
@EnableDiscoveryClient
基于 spring-cloud-commons
,
@EnableEurekaClient
基于 spring-cloud-netflix
。
就是如果选用的注册中心是 eureka
,那么就推荐 @EnableEurekaClient
,
如果是其他的注册中心,那么推荐使用 @EnableDiscoveryClient
。
@SpringBootApplication @EnableEurekaClient @RestController public class EurekaProviderApplication { @RequestMapping("/") public String home() { return "Hello world"; } public static void main(String[] args) { SpringApplication.run(EurekaProviderApplication.class, args); } } 复制代码
添加配置 application.yml
添加配置找到Eureka服务器
eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ spring: application: name: eureka-provider server: port: 8081 复制代码
向 Eureka
注册服务,消费者使用 Ribbon
开启负载均衡
Ribbon
是 Netflix
发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将 Netflix
的中间层服务连接在一起。 Ribbon
客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出 Load Balancer(简称LB)
后面所有的机器, Ribbon
会自动的帮助你基于某种规则 (如简单轮询,随即连接等)
去连接这些机器。我们也很容易使用 Ribbon
实现自定义的负载均衡算法。
Ribbon
在工作时首选会通过 ServerList
来获取所有可用的服务列表,然后通过 ServerListFilter
过虑掉一部分地址,最后在剩下的地址中通过 IRule
选择出一台服务器作为最终结果。
ServerList
:用于获取地址列表。它既可以是静态的(提供一组固定的地址),也可以是动态的(从注册中心中定期查询地址列表)。 ServerListFilter
:仅当使用动态 ServerList
时使用,用于在原始的服务列表中使用一定策略过虑掉一部分地址。 IRule
:选择一个最终的服务地址作为 LB结果
。选择策略有 轮询、根据响应时间加权、断路器(当Hystrix可用时)
等。 简单轮询负载均衡(RoundRobin)
: 以轮询的方式依次将请求调度不同的服务器,即每次调度执行i = (i + 1) mod n,并选出第i台服务器。 随机负载均衡 (Random)
: 随机选择状态为UP的Server 加权响应时间负载均衡 (WeightedResponseTime)
: 根据相应时间分配一个weight,相应时间越长,weight越小,被选中的可能性越低。 区域感知轮询负载均衡(ZoneAvoidanceRule)
:复合判断server所在区域的性能和server的可用性选择server @SpringBootApplication @EnableEurekaClient @RestController public class EurekaProviderApplication { @Value("${server.port}") String port; @RequestMapping("/") public String home() { return "Hello world ,port:" + port; } public static void main(String[] args) { SpringApplication.run(EurekaProviderApplication.class, args); } } 复制代码
添加配置 application.yml
端口依次为8081,8082,8083
eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ spring: application: name: eureka-provider server: port: 8081 复制代码
<!-- 客户端负载均衡 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId> </dependency> <!-- eureka客户端 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> 复制代码
开启服务负载均衡
通过@EnableDiscoveryClient向服务注册中心注册;并且向程序的ioc注入一个bean: restTemplate并通过@LoadBalanced注解表明这个restRemplate开启负载均衡的功能
@EnableDiscoveryClient @SpringBootApplication public class RibbonConsumerApplication { @LoadBalanced @Bean RestTemplate restTemplate() { return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(RibbonConsumerApplication.class, args); } } 复制代码
/** * 描述:调用提供者的 `home` 方法 **/ @RestController public class ConsumerController { @Autowired private RestTemplate restTemplate; @GetMapping(value = "/hello") public String hello() { return restTemplate.getForEntity("http://eureka-provider/", String.class).getBody(); } } 复制代码
添加配置 application.yml
指定服务的注册中心地址,配置自己的服务端口,服务名称
eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ spring: application: name: ribbon-consumer server: port: 9000 复制代码
(Eureka服务,三台service provider和service Consumer)
,查看 ribbon
是否开启负载均衡 由于 Consul
自身提供了服务端,所以我们不需要像之前 实现Eureka
的时候创建服务注册中心,直接通过 下载consul的服务端程序 就可以使用。 Consul
内置了 服务注册
与 发现框架
(一站式)、具有以下性质(参考上面列表):
client
:客户端, 无状态, 将 HTTP 和 DNS 接口请求转发给局域网内的服务端集群,所有注册到当前节点的服务会被转发到server,本身是不持久化这些信息 server
:服务端, 保存配置信息, 高可用集群, 在局域网内与本地客户端通讯,功能和client都一样,唯一不同的是,它会把所有的信息持久化的本地,这样遇到故障,信息是可以被保留的。 通过广域网与其他数据中心通讯. 每个数据中心的 server 数量推荐为 3 个或是 5 个. server-leader
:表明这个server是它们的老大,它和其它server不一样的一点是,它需要负责同步注册的信息给其它的server,同时也要负责各个节点的健康监测。 raft
:server节点之间的数据一致性保证,一致性协议使用的是raft,而zookeeper用的paxos,etcd采用的也是taft。 服务发现协议
:consul采用http和dns协议,etcd只支持http 服务注册
:支持两种方式实现服务注册,consul官方建议使用第二种方式。 服务发现
:支持两种方式实现服务发现, 关于 consul
的环境搭建以及应用后续再补充吧~
在 github
上有关于 Spring Cloud
完整的部署。
最后, 给个 star 吧 ~
个人博客 ~
简书 ~