0
点赞
收藏
分享

微信扫一扫

C#-使用Consul

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

下载安装Consul,直接去官网(​​Consul by HashiCorp​​)下载即可。

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

#开发模式启动
consul agent -dev

C#-使用Consul_服务发现

将服务注册到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中了。

C#-使用Consul_配置文件_02

C#-使用Consul_服务发现_03

举报

相关推荐

C#-委托

C#-拓展方法

C#-获取CPUID

C#-宽带连接

学习C#-接口

0 条评论