.Net Core with 微服务 - Consul 注册中心

上一次我们介绍了 ocelot 网关的基本用法。这次我们开始介绍服务注册发现组件 consul 的简单使用方法。

服务注册发现

首先先让我们回顾下服务注册发现的概念。
在实施微服务之后，我们的调用都变成了服务间的调用。服务间调用需要知道ip、端口等信息。再没有微服务之前，我们的调用信息一般都是写死在调用方的配置文件里（当然这话不绝对，有些公司会把这些信息写到数据库等公共的地方，以方便维护）。又由于业务的复杂，每个服务可能依赖n个其他服务，如果某个服务的ip，端口等信息发生变更，那么所有依赖该服务的服务的配置文件都要去修改，这样显然太麻烦了。有些服务为了负载是有个多个实例的，而且可能是随时会调整实例的数量。如果每次调整实例数量都要去修改其他服务的配置并重启那太麻烦了。
为了解决这个问题，业界就有了服务注册发现组件。
假设我们有服务a需要调用服务b，并且有服务注册发现组件r。整个大致流程将变成大噶3部：

1. 服务b启动向服务r注册自己的信息
2. 服务a从服务r拉取服务b的信息
3. 服务a调用服务b

有了服务注册发现组件之后，当修改a服务信息的时候再也不用去修改其他相关服务了。

consul

consul 是 hashicorp 公司推出的一套服务注册发现工具。它使用 golang 编写并且开源。由于使用 golang 的缘故所以它天生跨平台而且部署简单。它带有 web 管理后台方便用户查看维护 consul 集群。其实除了服务注册发现功能，consul 还支持 key/value 存储可以当一个简单的配置中心使用。

架构

上面是 consul 官网上画的架构图。从图上可以看到 consul 天生支持多数据中心部署。每个数据中心内部有多个 consul 节点。consul 的节点分为2种。

1. server
   server 模式的节点是真正意义上集群的节点。它通过raft算法实现cap里的ca。当leader server 挂掉的时候会自动选举出新的 leader 使集群继续正常工作。
2. client
   client 模式的节点虽然也叫节点，但是它并不会持久化数据，不维持状态，它仅仅是转发客户端的请求给后面的 server 节点，同时负责注册到该 client 节点的服务的健康检测。它非常轻量级，按照 consul 的说法最好是每个服务都配一个 client 。

为什么要有client模式的节点

我初看 consul 这套架构的时候觉得很奇怪，为什么要在 server 节点跟真正的服务之间插入一层 client 模式的节点。按照按照 consul 的说法还得每个服务配一个 client 节点。

经过思考说说我的一些看法。在这个模式下服务不在关心真正的集群在哪，集群的节点有哪些，只需要知道这个伴随的 client 节点的地址就行了。通过这个 client 节点去感知到真正可用的 server 节点，所有跟 server 节点的交互全部交给 client 节点代理去完成，这就简化了服务跟 consul 交互的难度。还有一个好处是服务的健康检测由 client 节点负责，在一定程度上减轻了 server 节点的压力。当然这也会带来一个问题，那就是如果 client 挂了，那么服务可能就连不上 consul 集群了，因为对于服务来说这个 client 节点相当于是单点的。

使用 docker 运行 consul

docker run -p 8500:8500 --name=consulserver consul agent -server -bootstrap -client=0.0.0.0 -ui -node=0

使用 docker 命令运行初始化一个 consul 的 server 模式的节点。

• -server 启动为server模式
• -bootstrap 设置为启动模式，这是第一个server节点，等待其它节点的加入
• -client 指定可以访问的客户端ip 。
• -ui 开启管理界面
• -node 节点的名字

docker run -d --name=consulserver1 consul agent -server -node=1 -join=172.17.0.2

有了第一个节点，我们可以开始创建更多的 server 节点来构造集群。consul 推荐至少3个 server 来组建集群。上面的 docker 命令表示启动第二个 server 然后加入第一个节点构造的集群。

• -join 加入某个集群，这里的 ip 为第一个启动的节点的内网 ip 。可以通过 docker exec xxx consul members 命令查看。后面会演示。

docker run --name=consulclient0 -e consul agent -client=0.0.0.0 -node=client0 -retry-join=172.17.0.2

我们有了 server 集群，现在可以开始建立 consul 的 client 节点，然后加入集群。启动 consul client 的命令跟启动 consul server 的差不多。去掉了 -server 就代表这个 agent 为 client 模式。

使用 docker-compose 运行 consul

上面分步骤演示了如何使用 docker 命令来运行 consul 集群。一行行敲还是太麻烦，为了简化部署，这里整理成了 docker-compose 启动文件。

version: '3.9'
services:

  consulserver1:
    image: consul:1.9.4
    restart: always
    container_name: consulserver1
    hostname: consulserver1
    command: agent -server -bootstrap -client=0.0.0.0 -ui -node=consulserver1
    ports:
      - 8500:8500
  consulserver2:
    image: consul:1.9.4
    restart: always
    container_name: consulserver2
    hostname: consulserver2
    command: agent -server -join=consulserver1 -node=consulserver2
    depends_on:
      - consulserver1

  consulserver3:
    image: consul:1.9.4
    restart: always
    container_name: consulserver3
    hostname: consulserver3
    command: agent -server -join=consulserver1 -node=consulserver3
    depends_on:
      - consulserver1

  consulclient1:
    image: consul:1.9.4
    restart: always
    container_name: consulclient1
    hostname: consulclient1
    command: agent -client=0.0.0.0 -retry-join=consulserver1 -node=consulclient1
    depends_on:
      - consulserver2
      - consulserver3
    ports:
      - 8600:8500
  consulclient2:
    image: consul:1.9.4
    restart: always
    container_name: consulclient2
    hostname: consulclient2
    command: agent -client=0.0.0.0 -retry-join=consulserver1 -node=consulclient2
    depends_on:
      - consulserver2
      - consulserver3
    ports:
      - 8700:8500
  consulclient3:
    image: consul:1.9.4
    restart: always
    container_name: consulclient3
    hostname: consulclient3
    command: agent -client=0.0.0.0 -retry-join=consulserver1 -node=consulclient3
    depends_on:
      - consulserver2
      - consulserver3
    ports:
      - 8800:8500

这个 docker-compose 文件描述了启动3个 server 模式的实例，3个 client 模式的实例。其中 consulserver1 开启了ui，端口映射8500，consulclient1,、consulclient2、consulclient3 端口分别映射为 8600、8700、8800 ，记住这些端口，后面要用到。

[root@localhost myservices]# docker-compose up -d
[root@localhost myservices]# docker exec consulserver1 consul members


node           address          status  type    build  protocol  dc   segment
consulserver1  172.18.0.2:8301  alive   server  1.9.4  2         dc1  <all>
consulserver2  172.18.0.3:8301  alive   server  1.9.4  2         dc1  <all>
consulserver3  172.18.0.4:8301  alive   server  1.9.4  2         dc1  <all>
consulclient1  172.18.0.5:8301  alive   client  1.9.4  2         dc1  <default>
consulclient2  172.18.0.6:8301  alive   client  1.9.4  2         dc1  <default>
consulclient3  172.18.0.7:8301  alive   client  1.9.4  2         dc1  <default>

使用 docker-compose up -d 命令启动所有的容器。启动完成后使用 docker exec consulserver1 consul members 查看整个集群的状态。它列出了所有节点的类型，ip，是否存活等信息。

如果上面的操作一切正常，在浏览器里输入 http://宿主机ip：8500 访问 web 管理界面。界面上会显示6个绿色的节点。表示所有节点都正常运行中。

在 asp.net core 应用内使用 consul

好了现在我们已经有了 consul 集群，现在可以开始编写代码来注册跟拉取我们的服务了。我们需要完成4点操作。

1. 定义一个健康检测的接口
2. 在服务启动的时候自动注册该服务的基础信息
3. 在服务关闭的时候自动移除该服务
4. 拉取服务列表

健康检测

我们的服务注册到 consul 节点后，节点会定时去轮询我们的服务，所以需要提供一个 http 接口，如果返回 200 ok 就表示服务存活，否则代表服务故障。

    [apicontroller]
    [route("[controller]")]
    public class healthcontroller : controllerbase
    {
        [httpget]
        public string get()
        {
            return "ok";
        }
    }
}

添加一个healthcontroller里面就实现一个get方法简单的返回ok就可以了。

服务注册、移除

我们实现一个hostedservice来实现自动注册跟移除服务。hostedservice 有2个方法，start 跟 stop 。start 方法会在 app 启动的时候触发 ， stop 会在 app 关闭的时候触发。跟我们的需求完美符合。

install-package consul -version 1.6.10.1

使用 nuget 安装 consul .net client 类库。我们跟 consul 节点的通讯需要它来完成。

    public class serviceinfo
    {
        public string id { get; set; }
        public string name { get; set; }

        public string ip { get; set; }

        public int port { get; set; }

        public string healthcheckaddress { get; set; }
    }

定义一个类，存储服务的基本信息。

public class consulregisterservice : ihostedservice
    {
        iconsulclient _consulclient;
        serviceinfo _serviceinfo;
        public consulregisterservice(iconfiguration config, iconsulclient consulclient)
        {
            _serviceinfo = new serviceinfo();
            var sc = config.getsection("serviceinfo");

            _serviceinfo.id = sc["id"];
            _serviceinfo.name = sc["name"];
            _serviceinfo.ip = sc["ip"];
            _serviceinfo.healthcheckaddress = sc["healthcheckaddress"];
            _serviceinfo.port = int.parse(sc["port"]);

            _consulclient = consulclient;
        }

        public async task startasync(cancellationtoken cancellationtoken)
        {
            console.writeline($"start to register service {_serviceinfo.id} to consul client ...");
            await _consulclient.agent.servicederegister(_serviceinfo.id, cancellationtoken);
            await _consulclient.agent.serviceregister(new agentserviceregistration
            {
                id = _serviceinfo.id,
                name = _serviceinfo.name,// 服务名
                address = _serviceinfo.ip, // 服务绑定ip
                port = _serviceinfo.port, // 服务绑定端口
                check = new agentservicecheck()
                {
                    deregistercriticalserviceafter = timespan.fromseconds(0),//服务启动多久后注册
                    interval = timespan.fromseconds(5),//健康检查时间间隔
                    http = $"http://{_serviceinfo.ip}:{_serviceinfo.port}/" + _serviceinfo.healthcheckaddress,//健康检查地址
                    timeout = timespan.fromseconds(5)
                }
            });
            console.writeline("register service info to consul client successful ...");
        }

        public async task stopasync(cancellationtoken cancellationtoken)
        {
            await _consulclient.agent.servicederegister(_serviceinfo.id, cancellationtoken);
            console.writeline($"deregister service {_serviceinfo.id} from consul client successful ...");
        }
    }

定义一个 consulregisterservice 类，实现 ihostedservice 接口。在 start 方法内使用 consulclient 注册服务 。在 stop 方法内取消注册该服务。

        public void configureservices(iservicecollection services)
        {
            //注册consulclient对象
            services.addsingleton<iconsulclient>(new consulclient(x => {
                x.address = new uri(configuration["consul:clientaddress"]);
            }));
            //注册consulregisterservice 这个servcie在app启动的时候会自动注册服务信息
            services.addhostedservice<consulregisterservice>();
            services.addcontrollers();
        }

在 startup 的 configureservices 方法内先注入一个 iconsulclient 的实例。再注册我们的 consulregisterservice 服务。

  "serviceinfo": {
    "id": "hote_base_01", //服务id
    "name": "hote_base", //服务名
    "ip": "192.168.0.200", //服务部署的ip
    "port": 6002, //服务对应的端口
    "healthcheckaddress": "health" //健康检测的请求path
  },
  "consul": {
    "clientaddress": "http://192.168.0.117:8700" //consul client 的地址
  }

以我们的演示项目 hotel_base 为例，在 appsettings.json 文件内添加以上配置信息。其中 consul：clientaddress 为 consule client 节点的地址。

注意：这里的 ip 不要使用 localhost ，因为如果使用 docker 部署 ， localhost 会出现网络访问方面的问题。

好了，让我们运行一下我们的项目。等待项目启动完成后，打开 consul 的 web 管理界面。查看 consulclient1 节点，可以看到我们的 hotel_base_01 服务被注册上去了。

我们强制把启动的app关闭，可以看到 consul 管理界面显示 hotel_base 服务红色，代表故障。

注意：要演示故障这种情况，要先注释掉 consulregisterservice 的 stop 方法，不然关闭的时候会先取消注册，这样 consul 管理界面上就找不到对应的服务了。

我们按照 hotel_base 的套路，把其他几个服务都添加服务注册的代码。然后全部运行起来

拉取服务列表

下面我们演示下如何通过 consul client 读取服务列表。

   public interface iconsulservice
    {
        task<list<agentservice>> getservicesasync(string servicename);
    }
    public class consulservice : iconsulservice
    {
        public iconsulclient _consulclient;
        public consulservice(iconsulclient consulclient)
        {
            _consulclient = consulclient;
        }

        public async task<list<agentservice>> getservicesasync(string servicename)
        {
            var result = await _consulclient.health.service(servicename, "", true);
            return result.response.select(x => x.service).tolist();
        }
    }

定义一个consulservice类，里面有个getservicesasync方法。该方法通过服务名称从 consul 集群获取服务的列表。

        public void configureservices(iservicecollection services)
        {
            services.addsingleton<iconsulclient>(new consulclient(x => {
                x.address = new uri(configuration["consul:clientaddress"]);
            }));
            //注册consulservice里面封装了一些方法
            services.addsingleton<iconsulservice, consulservice>();
            services.addhostedservice<consulregisterservice>();
            services.addcontrollers();
        }

在 configureservices 方法内把 consulservice 注册到容器内。

 [apicontroller]
    [route("[controller]")]
    public class ordercontroller : controllerbase
    {
        private static readonly list<ordervm> _orders = new list<ordervm>() { 
            new ordervm { 
                id = "od001",
                startday = "2021-05-01",
                endday = "2021-05-02",
                roomno = "1001",
                memberid = "m001",
                hotelid = "h8001",
                createday = "2021-05-01"
            }
        };

        private iconsulservice _consulservice;
        public ordercontroller(ilogger<ordercontroller> logger, iconsulservice consulservice)
        {
            _consulservice = consulservice;
        }

        [httpget("{id}")]
        public async task<ordervm> get(string id)
        {
            var order = _orders.firstordefault(x=>x.id == id);
            if (!string.isnullorempty(order.memberid))
            {
                var memberserviceaddresses = await _consulservice.getservicesasync("member_center");
                var memberserviceaddress = memberserviceaddresses.firstordefault();
                using (var httpclient = new httpclient())
                {
                    httpclient.baseaddress = new uri($"http://{memberserviceaddress.address}:{memberserviceaddress.port}");
                    var memberresult = await httpclient.getasync("/member/" + order.memberid);
                    var json = await memberresult.content.readasstringasync();
                    var member = jsonconvert.deserializeobject<membervm>(json);
                    order.member = member;
                }
            }

            return order;
        }
    }

我们通过在 ordering 服务项目的一个获取订单详细信息的接口来演示下如何使用consulservice 。订单详细信息需要根据会员id获取会员的详细信息。我们通过 consulservice 获得 member_center 的服务列表后，取出一个配置信息，获取 ip 跟端口号。组装成服务的真正的请求地址，使用 httpclient 来请求这个接口，获取会员的基本信息。
当然这里我们有很多可以改进的地方，比如我们可以在本地缓存服务列表，这样不用每次都通过 consul client 拉取。比如我们可以写一个随机算法，每次从服务列表中随机取一个对象，从而达到负载均衡的目的，在这就不再演示了。

把所有项目都跑起来，使用 postman 去访问一下获取订单详情接口，可以看到订单详情的返回值包含了会员信息。

总结

通过以上，我们回顾了服务注册发现的概念。演示了如何通过 docker/docker-compose 环境来部署 consul 集群。还通过简单的 .net core 代码演示了如何注册服务信息到 consul 集群，如何通过代码获取服务列表并调用它。相信现在大家对服务注册发现、consul 组件有了一个比较直观的了解。
谢谢阅读。

项目地址

相关文章

net core with 微服务 - 什么是微服务
.net core with 微服务 - 架构图
.net core with 微服务 - ocelot 网关

关注我的公众号一起玩转技术