<h2>基于Docker、Registrator、Zookeeper实现的服务自动注册</h2>    <p>本文所有服务均采用docker容器化方式部署</p>    <h2>当前环境</h2>    <ol>     <li>系统：Mac OS</li>     <li>docker 1.12.1</li>     <li>docker-compose 1.8.0</li>    </ol>    <h2>场景</h2>    <p>在微服务架构中，传统的大型单一应用会根据业务场景被拆分成众多功能单一且独立自治的微型服务。每个服务模块不仅能独立的对外暴露服务，而且根据业务需求，可以动态的进行扩容或缩减，充分利用了服务器资源。</p>    <p>但此架构引入了很多新的问题。其中一个是，随着服务的增多，以及服务的动态扩容，服务地址（IP、Port）硬编码的方式已经显得不太合适。我们需要寻求一种机制，让每个服务能动态的创建地址，同时调用方要能获取到这些信息、且感知地址的动态变化。</p>    <h2>注册中心</h2>    <p>为解决上述问题，业界给出的一种方案是使用注册中心，通过服务的发布-订阅模式，来解决上述场景，即所谓的 “服务的注册&发现”。</p>    <p>举例来讲，大家过去是否有翻查电话簿打电话的经历。有一天，你想给小明打个电话，可是不知道他的电话号码是多少。于是去翻查电话簿上对方的电话信息，这里电话簿就是所谓的注册中心，而翻查电话簿的动作就是属于服务的发现过程，那么小明给出自己的电话号码，由自己（或他人）记录在电话簿上的动作就属于服务的注册过程。</p>    <p>理解了小明的例子，再来看服务注册发现的流程，是不是一样呢？</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/b06cbbfafdb7f16576c2813620f9607e.png"></p>    <ol>     <li>服务注册：服务提供者将自身的服务信息注册进注册中心；</li>     <li>服务订阅：服务消费者从注册中心获取服务信息，并对其进行监听；</li>     <li>缓存服务信息：将获取到的服务信息缓存到本地，减少与注册中心的网络通信；</li>     <li>服务调用：查找本地缓存，找到对应的服务地址，发送服务请求；</li>     <li>变更通知：当服务节点有变动时（服务新增、删除等），注册中心将通知监听节点变化的消费者，使其更新服务信息。</li>    </ol>    <h2>服务注册</h2>    <p>回到小明的例子，小明有两种方式将自己的电话写入电话簿，一种是自己亲自登记，一种是找他人代为登记。即所谓的服务 “自注册” 与 “第三方注册”。</p>    <ul>     <li> <p>自注册：服务内部启动客户端，连接注册中心，写入服务信息。</p>      <ul>       <li>问题：        <ul>         <li>服务代码对注册中心进行了硬编码，若更换了注册中心，服务代码也必须跟着调整；</li>         <li>注册中心必须与每个服务都保持通信，来做心跳检测。如果服务很多时，对注册中心也是一种额外的开销；</li>        </ul> </li>      </ul> </li>     <li> <p>第三方注册（本文采用方式）：采用协同进程的方式，监听服务进程的变化，将服务信息写入注册中心。</p>      <ul>       <li>好处：做到了服务与注册中心的解耦，对服务而言，完成了服务的自动化注册；</li>       <li>问题：协同进程本身也要考虑高可用，否则将成为单点故障的风险点；</li>      </ul> </li>    </ul>    <p>考虑篇幅原因，服务消费者相关内容将在下篇进行讲述</p>    <h2>技术方案</h2>    <p>服务注册中心：作为整个架构中的核心，注册中心要做到的是支持分布式、支持持久化存储。可以把它想象成一个集中化管理的中心服务器。同时负责将服务注册信息的变动实时通知给服务消费者。</p>    <p>这里，技术上我们选用的 <a href="/misc/goto?guid=4958968912196595107" rel="nofollow,noindex">ZK (ZooKeeper)</a> 。大家可以把 ZK 想象成文件服务器，注册中心在 ZK 中的展现就是节点路径图，每个节点下存放者相应的服务信息，ZK路径图如下：</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/c7748591699ea05e910f261a05d7e2cb.png"></p>    <p>服务提供者：服务以 docker 容器化方式部署（实现服务端口的动态生成），并以 <a href="/misc/goto?guid=4958869857673473301" rel="nofollow,noindex">docker-compose</a> 的方式来管理，这里包含各种语言实现的服务（如JAVA、PHP等），通过 Registrator 完成服务的自动注册。</p>    <h2>技术说明</h2>    <p>Docker：是一个开源工具，能将一个WEB应用封装在一个轻量级，便携且独立的容器里，然后可以运行在几乎任何服务环境下。 Docker的一般使用在以下几点： 自动化打包和部署应用。</p>    <p>Docker-compose：是一个用来定义、启动和管理服务的工具，通过compose配置文件，将一个或多个 Docker 容器组合成一个服务。并通过简单的命令对服务进行管理，如启动、销毁、水平扩展等等。</p>    <p>Registrator：一个由Go语言编写的，针对docker使用的，通过检查容器在线或者停止运行状态自动注册和去注册服务的工具。</p>    <p>ZK：作为一个分布式服务框架，是 Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等等。</p>    <h2>示例</h2>    <p>代码地址： <a href="/misc/goto?guid=4959746411042371052" rel="nofollow,noindex">https://github.com/jasonGeng88/service_registry_discovery</a></p>    <p>示例主要从3个方面演示：</p>    <ol>     <li>框架搭建</li>     <li>服务准备</li>     <li>场景演示</li>    </ol>    <h3>框架搭建：</h3>    <p>ZK 部署</p>    <p>当前位置： 项目根目录</p>    <ul>     <li>zookeeper/docker-compose.yml （ <em>为演示方便，这里在单台机器上运行</em> ）：</li>    </ul>    <pre>  version: '2' #docker-compose版本  services:      zoo1:          image: zookeeper          restart: always          ports:              - 2181:2181          environment:              ZOO_MY_ID: 1              ZOO_SERVERS: server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888        zoo2:          image: zookeeper          restart: always          ports:              - 2182:2181          environment:              ZOO_MY_ID: 2              ZOO_SERVERS: server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888        zoo3:          image: zookeeper          restart: always          ports:              - 2183:2181          environment:              ZOO_MY_ID: 3              ZOO_SERVERS: server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888</pre>    <ul>     <li>启动命令（ <em>执行上述文件</em> ）</li>    </ul>    <pre>  cd zookeeper && docker-compose up -d</pre>    <ul>     <li>查看结果</li>    </ul>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/1205336920df6a9d2eae15461e80b30a.png"></p>    <p>Registrator 部署</p>    <p>当前位置： 项目根目录</p>    <ul>     <li>registrator/docker-compose.yml</li>    </ul>    <pre>  version: '2'  services:    registrator1:      image: gliderlabs/registrator      restart: always      network_mode: "host"      volumes:        - /var/run/docker.sock:/tmp/docker.sock      # -ip 设置服务写入注册中心的IP地址      # zookeeper:// 设置连接的 ZK 协议、地址、注册的根节点      command: "-ip 127.0.0.1 zookeeper://127.0.0.1:2181/services"      registrator2:      image: gliderlabs/registrator      restart: always      network_mode: "host"      volumes:        - /var/run/docker.sock:/tmp/docker.sock      command: "-ip 127.0.0.1 zookeeper://127.0.0.1:2182/services"      registrator3:      image: gliderlabs/registrator      restart: always      network_mode: "host"      volumes:        - /var/run/docker.sock:/tmp/docker.sock      command: "-ip 127.0.0.1 zookeeper://127.0.0.1:2183/services"</pre>    <ul>     <li>启动命令</li>    </ul>    <pre>  cd registrator/ && docker-compose up -d</pre>    <ul>     <li>查看结果</li>    </ul>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/cca16209972531a1e45f260d517ffac8.png"></p>    <p>目前框架已搭建完毕，我们来连接一台ZK，来观察节点情况：</p>    <pre>  # 进入 ZK 容器  docker exec -it zookeeper_zoo1_1 /bin/bash  # 连接 ZK  zkCli.sh -server 127.0.0.1:2181</pre>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/6eba5098bcea2cb935d8a5eee9b741d8.png"></p>    <h3>服务准备：</h3>    <p>项目中为演示准备了2个服务，分别是用JAVA、PHP实现的。</p>    <p>java_service_1（由springboot实现）:</p>    <p>当前位置： services/java_service_1</p>    <ul>     <li>启动文件</li>    </ul>    <pre>  package com.example;    import org.springframework.boot.SpringApplication;  import org.springframework.boot.autoconfigure.SpringBootApplication;    @RestController  @SpringBootApplication  public class DemoApplication {     @RequestMapping("/")      String home() {          return "This is Service 1.";      }     public static void main(String[] args) {    SpringApplication.run(DemoApplication.class, args);   }  }</pre>    <ul>     <li>生成 jar 文件</li>    </ul>    <p>这里使用 Spring Boot CLI 进行打包</p>    <pre>  spring jar ROOT.jar src/main/java/com/example/DemoApplication.java</pre>    <ul>     <li>构建镜像</li>    </ul>    <pre>  # java_service_1 为你要构建的镜像名，tag默认为latest  docker build -t java_service_1 .</pre>    <p>php_service_2:</p>    <p>当前位置： services/php_service_2</p>    <ul>     <li>index.php</li>    </ul>    <pre>  <?php    echo 'This is Service 2.';  </pre>    <ul>     <li>构建镜像</li>    </ul>    <pre>  # php_service_2 为你要构建的镜像名，tag默认为latest  docker build -t php_service_2 .</pre>    <p>现两个服务镜像以构建完毕，展示如下：</p>    <p><img src="https://simg.open-open.com/show/8acf5cae0e6e84a444b7ef59439a52da.png"></p>    <h3>场景演示：</h3>    <p>当前位置： services</p>    <ul>     <li><strong>场景 1：</strong> 启动 service_1（JAVA）服务</li>    </ul>    <pre>  docker-compose up -d service_1</pre>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/54cf81901873bac8b3f5adedc0f81f5e.png"></p>    <p>查看 ZK 节点情况</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/10eb7f58336ca0d6f30637c89a7e881e.png"></p>    <ul>     <li><strong>场景 2：</strong> 启动service_2（PHP）服务</li>    </ul>    <pre>  docker-compose up -d service_2</pre>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/aa912e9252562f85acf3bc2ab3aa79ac.png"></p>    <p>查看 ZK 节点情况</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/3ba5fc24758ba2e5c9972caf0677713c.png"></p>    <ul>     <li><strong>场景 3：</strong> 扩展service_2（PHP）服务，个数为2</li>    </ul>    <pre>  docker-compose up -d service_2</pre>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/244930ee7e45cb748707308688595bfd.png"></p>    <p>查看 ZK 节点情况</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/03c7c269a2652dbad72278e86a4f45cf.png"></p>    <ul>     <li><strong>场景 4：</strong> 注销service_1（JAVA）服务</li>    </ul>    <pre>  docker-compose up -d service_2</pre>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/200e4461ac2d0e9b1a97445e5019bdb3.png"></p>    <p>查看 ZK 节点情况</p>    <p style="text-align: center;"><img src="https://simg.open-open.com/show/97fd783d8b90ac68b69ee4269c74fab3.png"></p>    <h2>优化点</h2>    <ul>     <li> <p>在生产环境中，zk安全连接、节点访问控制都是需要注意的。简单做法，可以把连接地址改成内网IP，添加防火墙策略来限制连接客户端。</p> </li>     <li> <p>Registrator这里采用的是其多个进程分别连接不同的节点，来防止Registrator的单点故障。由于Registrator所用开销较小，在服务数量与ZK节点数量不大的情况下，不会产生问题。 较好的方式是：Registrator提供失效自动地址切换功能（ <em>目前官方文档好像没有提供此方案，有了解的同学可以留言告诉我</em> ）。</p> </li>    </ul>    <h2>总结</h2>    <p>本文从介绍何为 “服务注册&发现” 切入，以通俗易懂的语言介绍了其内在的本质，最后讲到了实现的所用的具体技术方案，以及以 Demo 的方式，演示了 Registrator 是如何做到服务的自动化注册的。</p>    <p>当然，这只是实现的一种形式。注册中心用 etcd、consul 也都是可行的，而且 Registrator 官方最好的支持是 consul。我们这里就不细究它们的差别了，找到适合自己、满足业务的就是最好的 :blush: 。</p>    <h2>后续</h2>    <ol>     <li>服务发现机制与实现</li>    </ol>    <p> </p>    <p>来自：https://github.com/jasonGeng88/blog/blob/master/201703/service_registry.md</p>    <p> </p>