深入了解 Eureka 架构原理及实现（六）

服务同步机制

服务同步机制是用来同步 Eureka Server 节点之间服务信息的。

它包括 Eureka Server 启动时的同步，和运行过程中的同步。

启动时同步

Eureka Server 启动后，遍历 eurekaClient.getApplications 获取服务信息，并将服务信息注册到自己的 registry 中。

注意这里是两层循环，第一层循环是为了保证已经拉取到服务信息，第二层循环是遍历拉取到的服务信息。

运行过程中同步

当 Eureka Server 节点有 register、renew、cancel 请求进来时，会将这个请求封装成 TaskHolder 放到 acceptorQueue 队列中，然后经过一系列的处理，放到 batchWorkQueue 中。

TaskExecutor.BatchWorkerRunnable是个线程池，不断的从 batchWorkQueue 队列中 poll 出 TaskHolder，然后向其他 Eureka Server 节点发送同步请求。

这里省略了两个部分：

• 一个是在 acceptorQueue 向 batchWorkQueue 转化时，省略了中间的 processingOrder 和 pendingTasks 过程。
  
  
• 另一个是当同步失败时，会将失败的 TaskHolder 保存到 reprocessQueue 中，重试处理。
  

对微服务解决方案 Dubbo 和 Spring Cloud 的对比非常多，这里对注册中心做个简单对比。

实现

1、pom依赖

2、配置文件

3、启动类

4、访问启动页

参考文章：

https://www.infoq.cn/article/jlDJQ*3wtN2PcqTDyokh

https://zhuanlan.zhihu.com/p/88385121