java B2B2C 仿淘宝电子商城系统-Eureka Client 源码分析
在 SpringCloud 的众多组件中,Eureka 功能的重要性不言而喻,也许断路器可以不需要,配置中心也可以不需要,服务网关也可以不需要, 但 Eureka 不可或缺。所以,重点在于 Eureka。
本文的关注点
Client 功能:
可以注册到 EurekaServer
可以从 EurekaServer 获取列表
可以根据实例列表中负载均衡调用服务
- 如何注册到 EurekaServer
我们在使用 Client 的时候,需要使用 @EnableDiscoveryClient 表示自己是一个 Client ,也就是说,这个注解一定有很大的作用,我们通过追踪该注解,会看到注解上的注释:
Annotation to enable a DiscoveryClient implementation.
可以知道,这个注解和 DiscoveryClient 绑定了。
进入这个类查看。该类果然有一个 register 方法。关键代码如下:
/** * Register with the eureka service by making the appropriate REST call. */ boolean register() throws Throwable { EurekaHttpResponse<Void> httpResponse = eurekaTransport.registrationClient.register(instanceInfo); return httpResponse.getStatusCode() == 204; }
注释说道:通过适当的REST调用来注册eureka服务。
这个 registrationClient 有很多实现,默认的实现是 SessionedEurekaHttpClient。当返回 204 的时候,表示注册成功。
同时,这个register方法也是维持心跳的方法。通过定时任务默认 30 秒调用一次。
- 如何从 EurekaServer 获取列表
同样,在 DiscoveryClient 类中,我们发现有一个 getApplications 方法,该方法代码如下:
@Override public Applications getApplications() { return localRegionApps.get(); }
而这个 localRegionApps 从哪里获取数据呢?我们使用 IDEA 发现该变量有几个地方可以 set 数据,其中关键方法 getAndStoreFullRegistry, 该方法被 2 个地方使用 :一个是更新,一个是从注册中心获取,该方法主要逻辑为:
private void getAndStoreFullRegistry() throws Throwable { Applications apps = null; EurekaHttpResponse<Applications> httpResponse = clientConfig.getRegistryRefreshSingleVipAddress() == null ? eurekaTransport.queryClient.getApplications(remoteRegionsRef.get()) : eurekaTransport.queryClient.getVip(clientConfig.getRegistryRefreshSingleVipAddress(), remoteRegionsRef.get()); if (httpResponse.getStatusCode() == Status.OK.getStatusCode()) { apps = httpResponse.getEntity(); } if (fetchRegistryGeneration.compareAndSet(currentUpdateGeneration, currentUpdateGeneration + 1)) { localRegionApps.set(this.filterAndShuffle(apps)); } }
使用 HTTP 请求从EurekaServer 获取数据,其中最重要的数据就是 Applications,然后,使用 CAS 更新版本,将数据进行打乱(防止使用相同的实例接受启动过程中的流量),最后放进 Applications 中。
同时,使用 CacheRefreshThread 每 30 秒(默认)更新一次。
- 如何根据实例列表中负载均衡 Call 提供者
当我们调用一个被 @FeignClient 注解标识的远程方法时,和普通的 RPC 一样,SpringCloud 也是使用的 JDK 的动态代理,这个动态代理的的拦截类则是 HystrixInvocationHandler, 核心方法 invoke 代码如下:
HystrixInvocationHandler.this.dispatch.get(method).invoke(args);
SpringCloud 通过 Future 的 get 方法阻塞等待结果。可以看到,SpringCloud 默认是有断路器的。是否开启根据 feign.hystrix.enable 属性决定是否开启。
这行代码最后调用的是 SynchronousMethodHandler 的 invoke 方法,代码如下:
public Object invoke(Object[] argv) throws Throwable { RequestTemplate template = buildTemplateFromArgs.create(argv); Retryer retryer = this.retryer.clone(); while (true) { try { return executeAndDecode(template); } catch (RetryableException e) { retryer.continueOrPropagate(e); if (logLevel != Logger.Level.NONE) { logger.logRetry(metadata.configKey(), logLevel); } continue; } } }
该方法会进行重试——如果重试失败的话。可以看得出来, executeAndDecode 方法就是真正的 RPC 调用。
那么,SpringCloud 是如何进行负载均衡选择对应的实例的呢?
在上面的executeAndDecode 方法中,会调用 LoadBalancerFeignClient 的 execute 方法。最终会调用 ZoneAwareLoadBalancer 负载均衡器的 chooseServer 方法, 该方法内部代理了一个 IRule 类型的的负载均衡策略。而默认的策略则是轮询,看看这个 choose 方法的实现:
/** * Get a server by calling {@link AbstractServerPredicate#chooseRandomlyAfterFiltering(java.util.List, Object)}. * The performance for this method is O(n) where n is number of servers to be filtered. */ @Override public Server choose(Object key) { ILoadBalancer lb = getLoadBalancer(); Optional<Server> server = getPredicate().chooseRoundRobinAfterFiltering(lb.getAllServers(), key); if (server.isPresent()) { return server.get(); } else { return null; } } /** * Choose a server in a round robin fashion after the predicate filters a given list of servers and load balancer key. */ public Optional<Server> chooseRoundRobinAfterFiltering(List<Server> servers, Object loadBalancerKey) { List<Server> eligible = getEligibleServers(servers, loadBalancerKey); if (eligible.size() == 0) { return Optional.absent(); } return Optional.of(eligible.get(nextIndex.getAndIncrement() % eligible.size())); }
上面的两个方法就是 SpringCloud 负载均衡的策略了,从代码中可以看到,他使用了一个 nextIndex 变量取余实例的数量,得到一个 Service。
在 AbstractLoadBalancerAwareClient 的 executeWithLoadBalancer 方法中得到轮询到的 Server 后,执行 FeignLoadBalancer的 executer 方法。
最后,使用 feign 包下的 Client接口的默认实现类 Default 执行 convertResponse方法,使用 Java BIO 进行请求并返回数据。
- 总结
通过今天的代码分析,我们知道了几点:
Client 如何注册,当启动的时候,会调用 DiscoveryClient 的register方法进行注册,同时,还有一个 30 秒间隔的定时任务也可能(当心跳返回 404)会调用这个方法,用于服务心跳。
Client 如何获取服务列表,Client 也是通过 DiscoveryClient 的getAndStoreFullRegistry方法对服务列表进行获取或者更新。
Client 如何负载均衡调用服务,Client 通过使用 JDK 的动态代理,使用 HystrixInvocationHandler 进行拦截。而其中的负载均衡策略实现不同,默认是通过一个原子变量递增取余机器数,也就是轮询策略, 而这个类就是 ZoneAwareLoadBalancer。
当然,由于 SpringCloud 代码是在很多,本文也没有做到逐行剖析,但是,我们已经了解了他的主要代码在什么地方以及设计,这对于我们理解 SpringCloud 以及排查问题是有帮助的。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
java B2B2C 多租户电子商城系统-Spring Cloud常见问题与总结(三)
一.Spring Cloud各组件重试 Spring Cloud各组件的重试配置。 早期,Spring Cloud的重试机制是比较混乱的-各个组件都有自己的重试机制,例如Ribbon、Feign、Zuul。官方也意识到了这个问题,并对重试相关逻辑进行了改造与简化。 在Spring Cloud Edgware中,配置重试是非常简单的。 重试步骤 1.重试依赖spring-retry,因此引入重试依赖 <dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> </dependency> 2.配置重试 <client> ribbon: # 同一实例最大重试次数,不包括首次调用 MaxAutoRetries: 1 # 重试其他实例的最大重试次数,不包括首次所选的server MaxAutoRetriesNextServer: 2 # 是否所有操作都进行重试 OkToRetryOn...
- 下一篇
Z语言实现基本原理
原文作者: @TKT2016 (知乎, github) 计算机编程发展已经有几十年了,编程的难度也越来越小,会编程的人也越来越多。但是现在的编程还是非常难,需要专门学习很长时间才能掌握。我的目标是创造出更简单更容易掌握的语言,所以我开发出了Z语言。 C#语言中实现用控制台打印”你好”的程序是 Console.Write(“你好”); 对一个没有接触编程的人来说,他至少需要懂Console是什么、Write是什么、‘.’号起什么作用、“你好”为什么需要括号括起来。 在Z语言中打印“你好”的程序是这样写的 控制台打印“你好” 相比来说,Z语言程序是主要用汉字写的,和中文自然语法比较接近,需要学习的知识点更少,一般人即使没有学过,也能一眼看出这句话是什么意思。 Z语言编译为了实现正确编译上条控制台打印“你好”程序,会进行以下步骤。 一、准备实际功能类 (控制台的源文件在’Z语言系统/控制台’) 1.新建类 新建一个叫‘控制台’的C#类,给这个类名添加特性[ZStatic]。(Zstatic在‘Z语言接口编写文档’解释) 2.实现’ public static void Write(objec...
相关文章
文章评论
共有0条评论来说两句吧...