java B2B2C 仿淘宝电子商城系统-Eureka Client 源码分析

电子商务平台源码请加企鹅求求：一零三八七七四六二六。 在 SpringCloud 的众多组件中，Eureka 功能的重要性不言而喻，也许断路器能够不须要，配置中心也能够不须要，服务网关也能够不须要， 但 Eureka 不可或缺。因此，重点在于 Eureka。

本文的关注点

Client 功能：

能够注册到 EurekaServer

能够从 EurekaServer 获取列表

能够根据实例列表中负载均衡调用服务

1. 如何注册到 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 秒调用一次。

2. 如何从 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 秒（默认）更新一次。

3. 如何根据实例列表中负载均衡 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 进行请求并返回数据。

4. 总结

经过今天的代码分析，咱们知道了几点：

Client 如何注册，当启动的时候，会调用 DiscoveryClient 的register方法进行注册，同时，还有一个 30 秒间隔的定时任务也可能（小心跳返回 404）会调用这个方法，用于服务心跳。

Client 如何获取服务列表，Client 也是经过 DiscoveryClient 的getAndStoreFullRegistry方法对服务列表进行获取或者更新。

Client 如何负载均衡调用服务，Client 经过使用 JDK 的动态代理，使用 HystrixInvocationHandler 进行拦截。而其中的负载均衡策略实现不一样，默认是经过一个原子变量递增取余机器数，也就是轮询策略， 而这个类就是 ZoneAwareLoadBalancer。

固然，因为 SpringCloud 代码是在不少，本文也没有作到逐行剖析，可是，咱们已经了解了他的主要代码在什么地方以及设计，这对于咱们理解 SpringCloud 以及排查问题是有帮助的。

java B2B2C Springcloud仿淘宝电子商城系统