AI 助理
文档备案控制台
开发者社区 云原生 微服务 文章 正文

.NET Core微服务之路：基于Consul最少集群实现服务的注册与发现（二）

2018-10-17 2283
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 重温Consul最少化集群的搭建   　　我们再复习一下上一篇的内容，先建立三台consul server节点，两个consul client节点，分别在每个节点上跑不同（名称不同而已）的实例。

重温Consul最少化集群的搭建

 
　　我们再复习一下上一篇的内容，先建立三台consul server节点，两个consul client节点，分别在每个节点上跑不同（名称不同而已）的实例。我们先通过vmware启动这五个节点，并且能成功访问这个两个client节点的实例。（具体配置可以见上一篇）
 
　　通过配置文件自动生成服务 
{
  "services": [
    {
      "id": "CLIENT_SERVICE_01",
      "name": "CAS Client Service",
      "tags": [
        "urlprefix-/ClientService01"
      ],
      "address": "192.168.153.132",
      "port": 5000,
      "checks": [
        {
          "name": "clientservice_check01",
          "http": "http://192.168.53.132:5000/api/health",
          "interval": "10s",
          "timeout": "5s"
        }
      ]
    },
    {
      "id": "CLIENT_SERVICE_02",
      "name": "CAS Client Service",
      "tags": [
        "urlprefix-/ClientService02"
      ],
      "address": "192.168.153.132",
      "port": 5001,
      "checks": [
        {
          "name": "clientservice_check02",
          "http": "http://192.168.153.132:5001/api/health",
          "interval": "10s",
          "timeout": "5s"
        }
      ]
    }
  ]
}

 

添加KEY/VALUE　　

curl -X PUT -d 'edisonchou' http://192.168.80.100:8500/v1/kv/web/vhallaccount
　　我们通过 http://192.168.153.129:8500/v1/kv/?recurse来查看这个值是否添加到Consul中
 　　再验证是否已经同步到其他Consul服务端，先看129，注意加粗字体 
[root@localhost ~]# ./consul kv get web/vhallaccount
stevelee
[root@localhost ~]# ip addr
1: lo: <LOOPBACK,UP,LOWER_UP> mtu 65536 qdisc noqueue state UNKNOWN group default qlen 1000
    link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
    inet 127.0.0.1/8 scope host lo
       valid_lft forever preferred_lft forever
    inet6 ::1/128 scope host
       valid_lft forever preferred_lft forever
2: ens32: <NO-CARRIER,BROADCAST,MULTICAST,UP> mtu 1500 qdisc pfifo_fast state DOWN group default qlen 1000
    link/ether 00:0c:29:a6:a1:1c brd ff:ff:ff:ff:ff:ff
3: ens34: <BROADCAST,MULTICAST,UP,LOWER_UP> mtu 1500 qdisc pfifo_fast state UP group default qlen 1000
    link/ether 00:0c:29:a6:a1:26 brd ff:ff:ff:ff:ff:ff
    inet 192.168.153.129/24 brd 192.168.153.255 scope global noprefixroute ens34
       valid_lft forever preferred_lft forever
    inet6 fe80::6d21:aa51:2262:b80f/64 scope link noprefixroute
       valid_lft forever preferred_lft forever

 　　再看130的Consul服务端

[root@localhost ~]# ./consul kv get web/vhallaccount
stevelee
[root@localhost ~]# ip addr
1: lo: <LOOPBACK,UP,LOWER_UP> mtu 65536 qdisc noqueue state UNKNOWN group default qlen 1000
    link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00
    inet 127.0.0.1/8 scope host lo
       valid_lft forever preferred_lft forever
    inet6 ::1/128 scope host
       valid_lft forever preferred_lft forever
2: ens32: <BROADCAST,MULTICAST,UP,LOWER_UP> mtu 1500 qdisc pfifo_fast state UP group default qlen 1000
    link/ether 00:0c:29:2c:c2:fc brd ff:ff:ff:ff:ff:ff
    inet 192.168.153.130/24 brd 192.168.153.255 scope global noprefixroute ens32
       valid_lft forever preferred_lft forever
    inet6 fe80::6114:ed9c:c49d:649b/64 scope link noprefixroute
       valid_lft forever preferred_lft forever
3: ens34: <BROADCAST,MULTICAST,UP,LOWER_UP> mtu 1500 qdisc pfifo_fast state UP group default qlen 1000
    link/ether 00:0c:29:2c:c2:06 brd ff:ff:ff:ff:ff:ff
    inet 192.168.153.170/24 brd 192.168.153.255 scope global noprefixroute dynamic ens34
       valid_lft 1216sec preferred_lft 1216sec
    inet6 fe80::a67c:7966:8767:27fb/64 scope link noprefixroute
       valid_lft forever preferred_lft forever

 

 　　我们也可以通过Consul WEB UI来编辑KV值。

 

 Consul服务的Watch机制

 　　熔断保护在Consul和Ocelot中都有实现，意思就是当一个服务不正常时（比如我们的一个服务实例挂了，Consul的健康检查机制检测到了），应该给系统维护人员给以告警。在Consul中，服务告警也是通过配置文件来实现的。

{
  "watches": [
    {
      "type": "checks",
      "handler_type": "http",
      "state": "critical",
      "http_handler_config": {
        "path": "http://192.168.153.132:9000/notice",
        "method": "POST",
        "timeout": "10s",
        "header": { "Authorization": [ "token" ] }
      }
    }
  ]
}

　　我们再新建一个项目，建立一个控制器，用默认的HomController控制器也可以，键入如下代码：

[Produces("application/json")]
public class HomeController : Controller
{
    [HttpPost]
    [Route("/notice")]
    public IActionResult Notice()
    {
        var stream = HttpContext.Request.Body;
        if (HttpContext.Request.ContentLength != null)
        {
            var buffer = new byte[HttpContext.Request.ContentLength.Value];
            stream.Read(buffer, 0, buffer.Length);
            var content = Encoding.UTF8.GetString(buffer);

            var path = $"{AppDomain.CurrentDomain.BaseDirectory}{DateTime.Now:hh_mm_ss_ffff}.log";
            if (!System.IO.File.Exists(path))
            {
                System.IO.File.Create(path).Close();
            }

            using (var sw = new StreamWriter(path))
            {
                sw.Write(content);
                sw.Flush();
                sw.Close();
            }

            return Ok();
        }

        throw new Exception("post is null");
    }
}
　　功能很简单，做一个接受消息的客户端，POST方法，代码不解释。
　　当我们把5000端口上的服务停掉，会出现什么样的情况呢？132Consul的客户端服务器就会出现:5000/api/health无法访问的问题。 
2018/10/17 04:03:10 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused
2018/10/17 04:03:10 [INFO] agent: Synced check "service:CLIENT_SERVICE_01"
2018/10/17 04:03:20 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused
2018/10/17 04:03:30 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused
2018/10/17 04:03:40 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused
2018/10/17 04:03:50 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused
2018/10/17 04:04:00 [WARN] agent: Check "service:CLIENT_SERVICE_01" HTTP request failed: Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused

　　Watch机制会每隔10s向http://192.168.153.132:9000/notice发送一组json格式的消息，内容如下

[{
    "Node": "LZZ.DEV.WebServer",
    "CheckID": "service:CLIENT_SERVICE_01",
    "Name": "clientservice_check01",
    "Status": "critical",
    "Notes": "",
    "Output": "Get http://192.168.153.132:5000/api/health: dial tcp 192.168.153.132:5000: connect: connection refused",
    "ServiceID": "CLIENT_SERVICE_01",
    "ServiceName": "CAS Client Service",
    "ServiceTags": ["urlprefix-/ClientService01"],
    "Definition": {
        "HTTP": "",
        "Header": null,
        "Method": "",
        "TLSSkipVerify": false,
        "TCP": "",
        "Interval": "0s",
        "Timeout": "0s",
        "DeregisterCriticalServiceAfter": "0s"
    }
}]
　　你也可以将上面的notice方法替换为其他消息通知的方法，比如邮件，比如短信，我更推荐用短信模式，这样能马上告诉运维人员，有节点挂了，该去加班了。
　　综合之前上一篇的介绍，目前看Consul的Web控制台，已经出现了10个微服务了（不包括系统）！

 

 

文章标签：
API
网络协议
微服务
关键词：
微服务集群注册
.NET consul
.NET服务注册
微服务consul注册
另一个老李
目录
相关文章
码农刚子
|
10月前
|
开发框架 .NET C#
ASP.NET Core Blazor 路由配置和导航
大家好，我是码农刚子。本文系统介绍Blazor单页应用的路由机制，涵盖基础配置、路由参数、编程式导航及高级功能。通过@page指令定义路由，支持参数约束、可选参数与通配符捕获，结合NavigationManager实现页面跳转与参数传递，并演示用户管理、产品展示等典型场景，全面掌握Blazor路由从入门到实战的完整方案。
码农刚子
707 6
Net分享
|
开发框架 .NET 开发者
简化 ASP.NET Core 依赖注入（DI）注册-Scrutor
Scrutor 是一个简化 ASP.NET Core 应用程序中依赖注入（DI）注册过程的开源库，支持自动扫描和注册服务。通过简单的配置，开发者可以轻松地从指定程序集中筛选、注册服务，并设置其生命周期，同时支持服务装饰等高级功能。适用于大型项目，提高代码的可维护性和简洁性。仓库地址：&lt;https://github.com/khellang/Scrutor&gt;
Net分享
814 5
shiningrise
|
开发框架 .NET C#
在 ASP.NET Core 中创建 gRPC 客户端和服务器
本文介绍了如何使用 gRPC 框架搭建一个简单的“Hello World”示例。首先创建了一个名为 GrpcDemo 的解决方案，其中包含一个 gRPC 服务端项目 GrpcServer 和一个客户端项目 GrpcClient。服务端通过定义 `greeter.proto` 文件中的服务和消息类型，实现了一个简单的问候服务 `GreeterService`。客户端则通过 gRPC 客户端库连接到服务端并调用其 `SayHello` 方法，展示了 gRPC 在 C# 中的基本使用方法。
shiningrise
552 5
在 ASP.NET Core 中创建 gRPC 客户端和服务器
Net分享
|
开发框架 算法 中间件
ASP.NET Core 中的速率限制中间件
在ASP.NET Core中，速率限制中间件用于控制客户端请求速率，防止服务器过载并提高安全性。通过`AddRateLimiter`注册服务，并配置不同策略如固定窗口、滑动窗口、令牌桶和并发限制。这些策略可在全局、控制器或动作级别应用，支持自定义响应处理。使用中间件`UseRateLimiter`启用限流功能，并可通过属性禁用特定控制器或动作的限流。这有助于有效保护API免受滥用和过载。 欢迎关注我的公众号：Net分享 （239字符）
Net分享
504 1
长梦
|
开发框架 缓存 .NET
GraphQL 与 ASP.NET Core 集成：从入门到精通
本文详细介绍了如何在ASP.NET Core中集成GraphQL，包括安装必要的NuGet包、创建GraphQL Schema、配置GraphQL服务等步骤。同时，文章还探讨了常见问题及其解决方法，如处理复杂查询、错误处理、性能优化和实现认证授权等，旨在帮助开发者构建灵活且高效的API。
长梦
549 3
众所周知
|
Java 网络安全 Nacos
Nacos作为流行的微服务注册与配置中心，其稳定性与易用性广受好评
Nacos作为流行的微服务注册与配置中心，其稳定性与易用性广受好评。然而，“客户端不发送心跳检测”是使用中常见的问题之一。本文详细探讨了该问题的原因及解决方法，包括检查客户端配置、网络连接、日志、版本兼容性、心跳检测策略、服务实例注册状态、重启应用及环境变量等步骤，旨在帮助开发者快速定位并解决问题，确保服务正常运行。
众所周知
350 5
众所周知
|
网络安全 Nacos 开发者
Nacos作为流行的微服务注册与配置中心，“节点提示暂时不可用”是常见的问题之一
Nacos作为流行的微服务注册与配置中心，其稳定性和易用性备受青睐。然而，“节点提示暂时不可用”是常见的问题之一。本文将探讨该问题的原因及解决方案，帮助开发者快速定位并解决问题，确保服务的正常运行。通过检查服务实例状态、网络连接、Nacos配置、调整健康检查策略等步骤，可以有效解决这一问题。
众所周知
469 4
众所周知
|
Java 网络安全 Nacos
Nacos作为流行的微服务注册与配置中心，其稳定性和易用性备受青睐。
Nacos作为流行的微服务注册与配置中心，其稳定性和易用性备受青睐。然而，实际使用中常遇到“客户端不发送心跳检测”的问题。本文深入探讨该问题的原因及解决方案，帮助开发者快速定位并解决问题，确保服务正常运行。通过检查客户端配置、网络连接、日志、版本兼容性、心跳策略、注册状态、重启应用和环境变量等步骤，系统地排查和解决这一问题。
众所周知
378 3
frank.
|
存储 安全 Go
Golang 语言微服务的服务注册与发现组件 Consul
Golang 语言微服务的服务注册与发现组件 Consul
frank.
336 0
薛伟同学
|
存储 网络协议 数据中心
服务注册中心Consul
服务注册中心Consul
薛伟同学
646 1
云原生

微服务

热门文章

最新文章

  • 1
    微服务架构的理论基础 - 康威定律
  • 2
    微服务（Microservice）那点事
  • 3
    微服务技术栈选型，看了这个别的可以不用看了
  • 4
    阿里巴巴微服务开源项目盘点（持续更新）
  • 5
    【直播预告】云栖社区特邀专家卢春梦：Spring Cloud 微服务核心组件集 mica 的设计思路
  • 6
    Java微服务开发指南 -- 使用Spring Boot构建微服务
  • 7
    (十) Spring Cloud构建分布式微服务架构 - SSO单点登录之OAuth2.0登录认证(1)
  • 8
    EDAS- ”性感“ 微服务剖析
  • 9
    王东：微服务下的APM全链路监控
  • 10
    使用Spring Boot构建微服务（文末福利）
  • 1
    阿里云微服务引擎 MSE 及 API 网关 2026 年 7 月产品动态
    134
  • 2
    阿里云微服务引擎 MSE 及 API 网关 2026 年 6 月产品动态
    239
  • 3
    阿里云微服务引擎 MSE 及 API 网关 2026 年 5 月产品动态
    481
  • 4
    技术复盘：基于 GoWind Admin 实现 Kratos 框架单体轻量化落地
    215
  • 5
    一条IM消息的分布式之旅：从发送到已读
    712
  • 6
    【Azure 应用服务】WEBSITE_DISABLE_CROSS_STAMP_SCALE 配置的作用说明
    165
  • 7
    阿里云微服务引擎 MSE 及 API 网关 2026 年 4 月产品动态
    208
  • 8
    阿里云微服务引擎 MSE 及 API 网关 2026 年 3 月产品动态
    486
  • 9
    阿里云微服务引擎 MSE 及 API 网关 2026 年 2 月产品动态
    341
  • 10
    阿里云微服务引擎 MSE 及 API 网关 2026 年 1 月产品动态
    526

    • 相关课程

    更多
  • 微服务实战-RocketMQ Binder
  • 微服务实战-服务注册中心 - Nacos
  • 微服务实战-Service Mesh与Istio
  • 微服务实战-分布式配置中心 - Config
  • 微服务实战-服务注册与发现 - Nacos Discovery
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 微服务x容器开源开发者 Meetup 上海站
  • 微服务治理技术白皮书
  • 微服务与Serverless
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！