Eureka是Netflix开发的一款基于REST服务的服务发现工具,主要用于云计算系统中服务的自动注册与发现。其工作原理和内部实现可以概括如下:
一、架构组件
- Eureka Server: 服务注册中心,提供服务注册和发现的功能。服务提供者和消费者都会与Eureka Server进行交互。
- Eureka Client: 一个Java客户端,用于简化与Eureka Server的交互。客户端可以是服务提供者(向Eureka注册自己的服务)或服务消费者(从Eureka查询可用服务)。
二、工作流程
- 服务注册: 当服务提供者启动时,它向Eureka Server注册自己的服务信息,如IP地址、端口号等。
- 服务续约: 注册后,服务提供者会周期性地(默认30秒)向Eureka Server发送心跳,表明它是活跃的。
- 服务下线: 当服务提供者关闭时,它会向Eureka Server发送下线请求,Eureka Server随后将该服务从注册列表中移除。
- 服务发现: 服务消费者通过Eureka Client向Eureka Server查询可用服务,并获得服务提供者的信息。
- 服务同步: 在分布式部署中,多个Eureka Server实例之间会相互复制服务注册信息,保证数据一致性。
三、 服务端高可用设计
- 自我保护模式: 当Eureka Server检测到网络分区故障导致无法正常通信时,它会进入自我保护模式。在这种模式下,Eureka不会从注册表中删除服务,即使心跳超时,以避免因网络故障导致大量服务被错误地注销。
- 集群部署: 通过部署多个Eureka Server实例形成集群,提高服务发现的可用性和可靠性。
四、客户端负载均衡
Eureka Client通常与Ribbon(客户端负载均衡工具)结合使用,允许服务消费者在客户端进行负载均衡,而不是依赖于服务端的负载均衡。
五、Eureka缓存
为了减轻对Eureka Server的压力,Eureka Client会缓存服务信息,并周期性地刷新。这意味着服务信息可能存在延迟,不是实时的。
5.1 缓存分类
- Eureka Service有readOnlyCacheMap(只读缓存)、readWriteCacheMap(读写缓存) 、 注册表。
- 获取数据流向:只读缓存(3级缓存)-->读写缓存(2级缓存)-->注册表中直接获取数据(1级缓存)
5.2 缓存更新时机
- 主动过期:在有新的服务实例发生注册、下线、故障的时候,就回去刷新读写缓存的数据。
- 定时过期:给读写缓存加了一个定时器,然后每隔一段时间就给他清除掉里面的数据,默认是180秒清除一次。
- 被动过期:只读缓存里面也有一个定时器,每隔30秒的时候,去和读写缓存里面的数据进行对比,如果读写缓存的数据和只读缓存里面的数据不一致,就需要把读写缓存里面的数据同步到只读缓存里面。
Eureka通过这些机制和架构特点,在微服务架构中提供了一个可靠、灵活且轻量级的服务发现解决方案。