cd 對(duì)應(yīng)盤符文件夾\consul_1.17.1_windows_amd64
 //啟動(dòng)Consul
 consul agent -dev
 //設(shè)置ip地址訪問(wèn)-需要時(shí)配置
 consul agent -dev -client=0.0.0.0

dotnet add packages Consul

using Consul;
using Microsoft.Extensions.Configuration;
using System;
namespace MicroService.Framework;
public static class ConsulHelper
{
    /// <summary>
    /// Consul注冊(cè)
    /// </summary>
    /// <param name="configuration"></param>
    public static void ConsulRegist(this IConfiguration configuration)
    {
        //準(zhǔn)備鏈接Consul的Client
        ConsulClient client = new ConsulClient(c =>
        {
            c.Address = new Uri("http://localhost:8500/");
            c.Datacenter = "test1";
        });//找到consul
        string ip = string.IsNullOrWhiteSpace(configuration["ip"]) ? "127.0.0.1" : configuration["ip"];
        int port = string.IsNullOrWhiteSpace(configuration["port"]) ? 9001 : int.Parse(configuration["port"]);//命令行參數(shù)必須傳入
        //int weight = string.IsNullOrWhiteSpace(configuration["weight"]) ? 1 : int.Parse(configuration["weight"]);
        client.Agent.ServiceRegister(new AgentServiceRegistration()
        {
            ID = "service" + Guid.NewGuid(),//唯一id
            Name = "test_server",//Group--分組
            Address = ip,
            Port = port,
            //Tags = new string[] { weight.ToString() },//標(biāo)簽
            Check = new AgentServiceCheck()
            {
                Interval = TimeSpan.FromSeconds(10),//間隔10s一次
                HTTP = $"http://{ip}:{port}/Api/Health/Index",//健康檢測(cè)接口
                Timeout = TimeSpan.FromSeconds(3),//檢測(cè)等待時(shí)間
                DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(60)//失敗后多久移除
            }
        });
        //命令行參數(shù)獲取
        Console.WriteLine($"注冊(cè)成功：{ip}:{port}");
    }
}

public static class HealthExtention
{
    public static void Health(this WebApplication app)
    {
        app.MapWhen(context => context.Request.Path.Equals("/Api/Health/Index"),
         applicationBuilder => applicationBuilder.Run(async context =>
         {
             Console.WriteLine($"This is Health Check");
             context.Response.StatusCode = (int)HttpStatusCode.OK;
             await context.Response.WriteAsync("OK");
         }));
    }
}

dotnet run --urls=http://localhost:9001 --port=9001

  //consul獲取服務(wù)api/users/all也得知道
  string url = null;
  url = "http://test_server/api/users/all";//consul就像dns--只是負(fù)責(zé)解析ip：port--清單
  ConsulClient client = new ConsulClient(c =>
  {
      c.Address = new Uri("http://localhost:8500/");
      c.Datacenter = "test1";
  });
  var response = client.Agent.Services().Result.Response;//獲取服務(wù)清單
  Uri uri = new Uri(url);
  string groupName = uri.Host;
  //服務(wù)實(shí)例
  AgentService agentService = null;
  var dictionary = response.Where(s => s.Value.Service.Equals(groupName, StringComparison.OrdinalIgnoreCase)).ToArray();
  {
      //agentService = dictionary[0].Value;//寫死第一個(gè)
  }
  {
      輪詢策略 也是平均，但是太僵硬了
      agentService = dictionary[iIndex++ % dictionary.Length].Value;
  }
    //可自定義負(fù)載策略
  url = $"{uri.Scheme}://{agentService.Address}:{agentService.Port}{uri.PathAndQuery}";
  string content = InvokeApi(url);
  var res = JsonConvert.DeserializeObject<IEnumerable<User>>(content);