2、实现该接口CallService.cs调用Goods、Order的api方法　　

public class CallService : ICallService
{
private readonly IConfiguration _configuration;
private readonly ConsulClient _consulClient;
private ConcurrentBag _serviceAUrls;
private ConcurrentBag _serviceBUrls;
private IHttpClientFactory _httpClient;
public CallService(IConfiguration configuration, IHttpClientFactory httpClient)
{
_cOnfiguration= configuration;
_cOnsulClient= new ConsulClient(optiOns=>
{
options.Address = new Uri(_configuration[“Consul:Address”]);
});
_httpClient = httpClient;
}
public async Task GetGoodsService()
{
if (_serviceAUrls == null)
return await Task.FromResult(“Goods Service Initializing…”);
using var httpClient = _httpClient.CreateClient();
//随机获取一个服务地址调用
var serviceUrl = _serviceAUrls.ElementAt(new Random().Next(_serviceAUrls.Count()));
Console.WriteLine(“Goods Service：” + serviceUrl);
var result = await httpClient.GetStringAsync($”{serviceUrl}/goods”);
return result;
}
public async Task GetOrderService()
{
if (_serviceBUrls == null)
return await Task.FromResult(“Order Service Initializing…”);
using var httpClient = _httpClient.CreateClient();
//随机获取一个服务地址调用
var serviceUrl = _serviceBUrls.ElementAt(new Random().Next(_serviceBUrls.Count()));
Console.WriteLine(“Order Service：” + serviceUrl);
var result = await httpClient.GetStringAsync($”{serviceUrl}/order”);
return result;
}
public void InitServiceList()
{
var serviceNames = new string[] { “czapigoods”, “czapiorder” };
foreach (var item in serviceNames)
{
Task.Run(async () =>
{
var queryOptiOns= new QueryOptions
{
WaitTime = TimeSpan.FromMinutes(5)
};
while (true)
{
await InitServicesAsync(queryOptions, item);
}
});
}
}
private async Task InitServicesAsync(QueryOptions queryOptions, string serviceName)
{
//获取心跳检查服务
var result = await _consulClient.Health.Service(serviceName, null, true, queryOptions);
if (queryOptions.WaitIndex != result.LastIndex)
{
queryOptions.WaitIndex = result.LastIndex;
var services = result.Response.Select(x => $”http://{x.Service.Address}:{x.Service.Port}”);
if (serviceName == “czapigoods”)
{
_serviceAUrls = new ConcurrentBag(services);
}
else if (serviceName == “czapiorder”)
{
_serviceBUrls = new ConcurrentBag(services);
}
}
}
}

public class CallService : ICallService
{
private readonly IConfiguration _configuration;
private readonly ConsulClient _consulClient;
private ConcurrentBag _serviceAUrls;
private ConcurrentBag _serviceBUrls;
private IHttpClientFactory _httpClient;
public CallService(IConfiguration configuration, IHttpClientFactory httpClient)
{
_cOnfiguration= configuration;
_cOnsulClient= new ConsulClient(optiOns=>
{
options.Address = new Uri(_configuration[“Consul:Address”]);
});
_httpClient = httpClient;
}
public async Task GetGoodsService()
{
if (_serviceAUrls == null)
return await Task.FromResult(“Goods Service Initializing…”);
using var httpClient = _httpClient.CreateClient();
//随机获取一个服务地址调用
var serviceUrl = _serviceAUrls.ElementAt(new Random().Next(_serviceAUrls.Count()));
Console.WriteLine(“Goods Service：” + serviceUrl);
var result = await httpClient.GetStringAsync($”{serviceUrl}/goods”);
return result;
}
public async Task GetOrderService()
{
if (_serviceBUrls == null)
return await Task.FromResult(“Order Service Initializing…”);
using var httpClient = _httpClient.CreateClient();
//随机获取一个服务地址调用
var serviceUrl = _serviceBUrls.ElementAt(new Random().Next(_serviceBUrls.Count()));
Console.WriteLine(“Order Service：” + serviceUrl);
var result = await httpClient.GetStringAsync($”{serviceUrl}/order”);
return result;
}
public void InitServiceList()
{
var serviceNames = new string[] { “czapigoods”, “czapiorder” };
foreach (var item in serviceNames)
{
Task.Run(async () =>
{
var queryOptiOns= new QueryOptions
{
WaitTime = TimeSpan.FromMinutes(5)
};
while (true)
{
await InitServicesAsync(queryOptions, item);
}
});
}
}
private async Task InitServicesAsync(QueryOptions queryOptions, string serviceName)
{
//获取心跳检查服务
var result = await _consulClient.Health.Service(serviceName, null, true, queryOptions);
if (queryOptions.WaitIndex != result.LastIndex)
{
queryOptions.WaitIndex = result.LastIndex;
var services = result.Response.Select(x => $”http://{x.Service.Address}:{x.Service.Port}”);
if (serviceName == “czapigoods”)
{
_serviceAUrls = new ConcurrentBag(services);
}
else if (serviceName == “czapiorder”)
{
_serviceBUrls = new ConcurrentBag(services);
}
}
}
}

　3、接下来添加接口依赖注入、以及服务初始化调用　　

public class Startup
{
public Startup(IConfiguration configuration)
{
COnfiguration= configuration;
}
public IConfiguration Configuration { get; }
// This method gets called by the runtime. Use this method to add services to the container.
public void ConfigureServices(IServiceCollection services)
{
services.AddControllers();
services.AddHttpClient();
　　　　　//依赖注入CallService
services.AddSingleton();
}
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ICallService service)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.UseRouting();
app.UseAuthorization();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
　　　　 //初始化服务列表调用
service.InitServiceList();
}
}　　

public class Startup
{
public Startup(IConfiguration configuration)
{
COnfiguration= configuration;
}
public IConfiguration Configuration { get; }
// This method gets called by the runtime. Use this method to add services to the container.
public void ConfigureServices(IServiceCollection services)
{
services.AddControllers();
services.AddHttpClient();
　　　　　//依赖注入CallService
services.AddSingleton();
}
// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ICallService service)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.UseRouting();
app.UseAuthorization();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
　　　　 //初始化服务列表调用
service.InitServiceList();
}
}　　

　4、使用Postman测试调用

KV操作

　除了提供服务发现和健康检查的集成.Consul提供了一个易用的键/值存储.这可以用来保持动态配置,协助服务协调,领袖选举,做开发者可以想到的任何事情.

　1、创建/修改

命令方式：consul kv put key val 如：consul kv put port 9000 –添加key为port值为9000

Http方式：

　2、查询　　

命令方式：consul kv get key 如：consul kv get port –查询key为port的KV

Http方式：value为baisc

　3、删除

命令方式：consul kv delete key 如：consul kv delete port –删除key为port的KV

Http方式：

 其他

　网上找了下：常用服务发现框架consul、zookeeper及etcd比较：

参考：

consul手册：https://blog.csdn.net/liuzhuchen/article/details/81913562 

https://www.consul.io/docs

https://www.consul.io/api/kv.html

github：

https://github.com/cwsheng/Consul.Demo.git