C#-使用Consul

kdyonly

发布于 2023-03-03 18:55:34

3260

发布于 2023-03-03 18:55:34

文章被收录于专栏：个人编程笔记

浏览量 4

Consul是一个服务网格解决方案，提供了一个功能齐全的控制平面，具有服务发现、配置和分段功能。

下载安装Consul，直接去官网（Consul by HashiCorp）下载即可。

启动Consul，访问consul主页，默认为http://localhost:8500。

#开发模式启动
consul agent -dev

将服务注册到Consul，首先需要下载consul的nuget包，在包管理器中，搜索consul进行安装，使用扩展方法封装一个通用的注册方法：

//ConsulRegistryExtensions.cs
using Consul;
using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;

namespace ConsulHelper
{
    public static class ConsulRegistryExtensions
    {
        public static IApplicationBuilder UseConul(this IApplicationBuilder applicationBuilder, IConfiguration configuration, IHostApplicationLifetime lifetime) 
        {
            try
            {
                string ip = configuration["Consul:Ip"];
                int port = Convert.ToInt32(configuration["Consul:Port"]);
                string serviceName = configuration["Consul:ServiceName"];
                var serviceId = Guid.NewGuid().ToString();
                var consulHost = configuration["Consul:ConsulHost"];
                var consulDataCenter = configuration["Consul:ConsulDataCenter"];
                //创建consul的连接对象
                var consulClient = new ConsulClient(c =>
                {
                    c.Address = new Uri(consulHost);
                    c.Datacenter = consulDataCenter;
                });
                AgentServiceRegistration agentServiceRegistration = new AgentServiceRegistration()
                {
                    ID = serviceId,
                    Name = serviceName,
                    Address = ip,
                    Port = port,
                    Check = new AgentServiceCheck()
                    {
                        Interval = TimeSpan.FromSeconds(10),
                        HTTP = $"http://{ip}:{port}/Api/ApiHealth",
                        Timeout = TimeSpan.FromSeconds(10),
                        DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(20)
                    }
                };
                //将服务注册到consul上
                consulClient.Agent.ServiceRegister(agentServiceRegistration).Wait();
                //注销实例
                lifetime.ApplicationStopped.Register(async () =>
                {
                    await consulClient.Agent.ServiceDeregister(serviceId);
                });
            }
            catch(Exception ex)
            {
            }
            return applicationBuilder;
        }
    }
}

配置文件中的参数配置：

  "Consul": {
    "Ip": "127.0.0.1",
    "Port": "5272",
    "ServiceName": "ContentService",
    "ConsulHost": "http://127.0.0.1:8500",
    "ConsulDataCenter": "dc1"
  }

在WebApi项目的Controller文件夹中，创建心跳检测接口：

//ApiHealthController.cs
using Microsoft.AspNetCore.Mvc;

namespace ContentService.WebApi.Controllers
{
    [Route("Api/[controller]")]
    public class ApiHealthController:Controller
    {
        [HttpGet]
        public IActionResult Get()
        {
            return Ok("ok");
        }
    }
}

在Program.cs中调用刚才我们写的扩展方法：

//服务注册到consul中
IConfiguration configuration = app.Configuration;
IHostApplicationLifetime lifetime = app.Lifetime;
app.UseConul(configuration, lifetime);

启动服务，可以看到服务已经成功添加到Consul中了。