一、注册中心
1、注册中心演变过程
2、注册中心必备功能
① 服务的上线
② 服务的下线
③ 服务的剔除
④ 服务的查询
⑤ 注册中心HA
⑥ 注册中心节点数据同步
⑦ 服务信息的存储,比如mysql,redis,zookeeper,内存map等
3、RPC远程调用过程
① 负载均衡策略:随机,轮询,一致性Hash等;
② 容错机制:失败重试,失败自动切换等;
③ 透明代理: 调用远程方法跟调用本地的方法一样;
④ 协议: 双方约定好的协议,比如http协议,dubbo协议等;
⑤ 协议编解码:按照指定的协议进行编解码;
⑤ 序列化反序列化:网络传输的都是流,分字节流和字符流,所以需要对传输的数据做序列化,接收的流做反序列化;
⑥ 网络传输: 知道对方的ip+port就可以建立网络连接也就是socket连接,然后可以发起网络请求和接收对应的响应;
⑦ 线程池:io线程负责io连接,读取事件,等读取完成后交给线程池去处理相应的业务,类似netty的reactor模型;
二、Eureka详解
1、Eureka核心的Rest Api接口列表
请求名称 | 请求方式 | HTTP地址 | 请求描述 |
注册服务 | POST | /eureka/apps/{appID} | 传递JSON或者XML格式的参数内容,HTTP code为204表示成功 |
删除服务 | DELETE | /eureka/apps/{appID}/{instanceID} | HTTP code为200时表示成功 |
发起心跳 | PUT | /eureka/apps/{appID}/{instanceID} | HTTP code为200时表示成功 |
查询服务 | GET | /eureka/apps | HTTP code为200时表示成功,返回XML/JSON数据 |
查询指定appID的服务列表 | GET | /eureka/apps/{appID} | HTTP code为200时表示成功,返回XML/JSON数据 |
查询指定appID&instanceID的服务 | GET | /eureka/apps/{appID}/{instanceID} | 获取指定appID以及instanceID的服务信息,HTTP code为200时表示成功,返回XML/JSON数据 |
查询指定instanceID服务列表 | GET | /eureka/apps/instances/{instanceID} | 获取指定instanceID的服务信息,HTTP code为200时表示成功,返回XML/JSON数据 |
变更服务状态 | PUT | /eureka/apps/{appID}/{instanceID}/status?value=DOWN | 服务上线、服务下线等状态改变,HTTP code为200时表示成功 |
2、Eureka服务端和客户端
2.1 搭建Eureka服务端
第一步:加依赖
<!--netflix-eureka-server-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
第二步:加注解
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
第三步:编写配置文件
server:
#Eureka服务端应用的端口默认是8761
port: 8761
eureka:
client:
#表示是否将自己注册到EurekaServer,默认为true,由于当前应用就是EurekaServer,故而设为false
registerWithEureka: false
#表示是否从EurekaServer获取注册信息,默认为true,因为这是一个单点的EurekaServer,不需要同步其他的EurekaServer节点的数据
fetchRegistry: false
#注册地址
serviceUrl:
defaultZone: http://localhost:8761/eureka/
2.2 搭建Eureka客户端
第一步:加依赖
<!-- netflix-eureka-client -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
第二步:加注解
/**
* spring-cloud F版本可不写 @EnableDiscoveryClient
* @desc: 用户服务启动
* @author: toby
*/
@SpringBootApplication
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class, args);
}
}
第三步:编写配置文件
#eureka
eureka:
client:
#注册到Eureka服务端的地址
serviceUrl:
defaultZone: http://localhost:8761/eureka
instance:
#点击具体的微服务,右下角是否显示ip
prefer-ip-address: true
第四步:使用RestTemplate调用,需要加@LoadBalanced注解
/**
* 负载均衡加上@LoadBalanced
* @return
*/
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
当然实际项目中都是采用FeignClient来调用的。
启动Eureka服务端和客户端:
3、Eureka部署架构
3.1 架构图
3.2 Region
区域 | 编码 |
亚太(东京) | ap-northeast-1 |
亚太(新加坡) | ap-southeast-1 |
亚太(悉尼) | ap-southeast-2 |
欧洲(爱尔兰) | eu-west-1 |
南美(圣保罗) | sa-east-1 |
美东(北佛杰尼亚) | us-east-1 |
美西(北加利佛尼亚) | us-west-1 |
美西(俄勒冈) | us-west-2 |
3.3 核心功能
① 服务注册(Register):Eureka Client会通过发送REST请求向Eureka Server注册自己的服务,提供自身IP、端口、微服务名称等信息。Eureka Server接收到注册请求后,就会把这些信息存储在一个双层的Map中。
② 服务续约(Renew):在服务注册后,Eureka Client会维护一个心跳来持续通知Eureka Server,说明服务一直处于可用状态,防止被剔除。Eureka Client在默认的情况下会每隔30秒(eureka.instance.leaseRenewallIntervalInSeconds)发送一次心跳来进行服务续约。
③ 服务同步(Replicate):Eureka Server集群中多个Eureka Server之间会互相进行注册,不同Eureka Server之间会进行服务同步,用来保证Eureka Server集群内的所有实例中的数据一致性(从这个架构来看,Eureka Server所有实例所处的角色都是对等的,没有类似Zookeeper、选举过程,也不存在主从,所有的节点都是主节点。Eureka官方将Eureka Server集群中的所有实例称为"对等体(peer)")。
④ 获取服务(Get Registry):服务消费者(Eureka Client)在启动的时候,会发送一个REST请求给Eureka Server,获取上面注册的服务清单,并且缓存在Eureka Client本地,默认缓存30秒(eureka.client.registryFetchIntervalSeconds)。同时,为了性能考虑,Eureka Server也会维护一份只读的服务清单缓存,该缓存每隔30秒更新一次。
⑤ 服务调用(Make Remote Call):服务消费者在获取到服务清单后,就可以根据清单中的服务列表信息,查找到其他服务的地址,从而进行远程调用。
⑥ 服务下线(Cancel):当Eureka Client需要关闭或重启时,就不希望在这个时间段内再有请求进来,所以,就需要提前先发送REST请求给Eureka Server,告诉Eureka Server自己要下线了,Eureka Server在收到请求后,就会把该服务状态置为下线(DOWN),并把该下线事件传播出去。
⑦ 服务剔除(Evict):服务实例可能会因为网络故障等原因导致不能提供服务,而此时该实例也没有发送请求给Eureka Server来进行服务下线,所以,还需要有服务剔除的机制。Eureka Server在启动的时候会创建一个定时任务,每隔一段时间(默认60秒),从当前服务清单中把超时没有续约(默认90秒,eureka.instance.leaseExpirationDurationInSeconds )的服务剔除。
⑧ 自我保护:既然Eureka Server会定时剔除超时没有续约的服务,那就有可能出现一种场景,网络一段时间内发生了异常,所有的服务都没能够进行续约,Eureka Server就把所有的服务都剔除了,这样显然不太合理。所以,就有了自我保护机制,当短时间内,统计续约失败的比例,如果达到一定阈值,则会触发自我保护的机制,在该机制下,Eureka Server不会剔除任何的微服务,等到正常后,再退出自我保护机制。自我保护开关(eureka.server.enableself-preservation: false)
三、Eureka高可用
启动eureka-8761,eureka-8762 2个服务
1、eureka-8761配置文件如下:
spring:
application:
name: eureka-ha
server:
#Eureka服务端应用的端口默认是8761
port: 8761
eureka:
client:
#表示是否将自己注册到EurekaServer,表示8761的服务端需要向8762注册自己
registerWithEureka: true
#表示是否从EurekaServer获取注册信息,默认为true,需要从8762获取数据
fetchRegistry: true
#注册地址
serviceUrl:
defaultZone: http://localhost:8762/eureka/
2、eureka-8762配置文件如下:
spring:
application:
name: eureka-ha
server:
#Eureka服务端应用的端口默认是8761
port: 8762
eureka:
client:
#表示是否将自己注册到EurekaServer,表示8762的服务端需要向8761注册自己
registerWithEureka: true
#表示是否从EurekaServer获取注册信息,默认为true,需要从8761获取数据
fetchRegistry: true
#注册地址
serviceUrl:
defaultZone: http://localhost:8761/eureka/
3、eureka-client需要向2个注册中心注册服务(其实写一个就可以,因为eureka集群中的实例之前会同步数据)
#eureka
eureka:
client:
#注册到Eureka服务端的地址
serviceUrl:
defaultZone: http://localhost:8761/eureka,http://localhost:8762/eureka
启动后: