微服务和调用机制

短命女 2023-06-22 03:22 5阅读 0赞

按业务进行划分为独立的服务单元，解决单体系统的不足，同时也满足越来越复杂的业务需求

Spring cloud服务间调用的方式有两种：RestTemplate和FeignClient。  
都是通过Rest接口调用服务的http接口，参数和结果默认都是通过Jackson序列化和反序列化。  
Feign用的是Ribbon。  
Ribbon是一个客户端的负载均衡器，它提供对大量的HTTP和TCP客户端的访问控制。  
ribbon实现的关键点是为ribbon定制的RestTemplate，ribbon利用了RestTemplate的拦截器机制，在拦截器中实现ribbon的负载均衡。负载均衡的基本实现就是从服务注册中心获取可用的服务地址列表，然后通过一定算法负载，决定使用哪一个服务地址来进行http调用。

注册中心 Eureka 基于 REST 服务的服务注册与发现的组件  
主要包括两个组件：Eureka Server 和 Eureka Client  
Eureka Client：负责将这个服务的信息注册到Eureka Server中  
Eureka Server：提供服务注册和发现的能力，注册表保存各个服务所在的机器和端口号  
当各个服务启动时，Eureka Client都会将服务注册到Eureka Server，Eureka Server 会存储该服务的信息，  
也就是说，每个微服务的客户端和服务端，都会注册到 Eureka Server，这就衍生出了微服务相互识别的话题。

Feign 动态代理的http请求  
Feign会针对接口创建动态代理，本质就是调用 Feign创建的动态代理，Feign的动态代理会根据你在接口上的@RequestMapping等注解，来动态构造出你要请求的服务的地址，针对这个地址，发起请求、解析响应

(1)Eureka的健康检查只检测了服务的活性,无法确认服务调用是否成功;  
(2)只能重启来更新Ribbon负载策略;  
(1)在服务调用过程中,Eureka健康检查机制只验证了服务是否在线,而没有考虑是否调用成功,添加监控组件Actuator,监控服务调用后的状态。在服务心跳正常,却调用失败的情况下,将失败的状态更新到服务注册中心的实例列表中,消费者缓存实例时就可过滤失败过的服务实例,增强了后续调用的可行性和系统的可靠性。  
(2)在服务调用过程中,修改Ribbon负载均衡策略必须重启系统,设计实现动态更新机制:当收到新的请求时,重写Ribbon配置信息类,然后借助Spring的IOC机制注入新的配置资源,使得新的请求服务接收的是新的负载均衡策略,避免了整个系统的重启,增强了系统的可用性和可靠性。

注册中心概念  
服务提供者  
服务注册  
服务提供者在启动的时候通过发送REST请求的方式将自己注册到EurecaServer上，同时带上自身元数据信息。 Eureca Server接收到这个REST请求之后，将元数据的信息储存在一个双层结构的Map中，第一层map的key为服务名，第二层的key为具体服务的实例名。  
服务续约  
注册完服务之后，服务提供者会维持一个心跳，从而防止Eureca Server的“剔除任务”从服务列表中排除该实例。  
服务消费者  
获取服务  
服务消费者启动的时候会发送一个REST请求给注册中心，获取已注册的服务清单。 为了性能考虑，EurecaServer会维护一份只读的服务清单来返回给 客户端，同时该缓存清单会隔三十秒刷新一次。  
调用服务  
消费者获取清单之后，就可以获得服务者的实例名和元数据信息。 Ribbon默认使用轮询的方式调用，从而实现客户端负载均衡  
下线服务

服务实例进行正常的关闭操作时，会触发一个服务下线的REST请求给Eureca Server，注册中心将该服务状态设置为下线(DOWN)，并且把下线事件传播出去。

服务注册中心  
服务同步  
同一个服务的两个实例如果注册到不同的服务中心实例上，由于服务注册中心之间互相注册为服务，所以服务中心之间会互相转发注册请求服务给集群中的其他服务注册中心，从而实现服务注册中心之间的服务同步。  
失效剔除  
服务实例会因为内存溢出、网络故障等不正常下线了。但是服务注册中心并没有收到“服务下线”的请求。那么为了解决这个问题，Eureca Server 在启动的时候会创建一个定时任务，默认每隔六十秒将当前清单中超时（默认九十秒）没有续约的服务剔除出去。  
自我保护  
EurekaServer会统计心跳失败的比例在15分钟之内是否低于85%，如果出现低于的情况，EurekaServer会将这些实例保护起来，让其不过期，但是这样会让客户端拿到已经挂掉的服务实例，这就要求客户端必须要有容错机制（请求重试、断路器等）