.net core学习笔记，组件篇：服务的注册与发现（Consul）初篇

consul.exe agent -dev

// 创建Consul的客户端连接
            var consulClient = new ConsulClient(configuration =>
            {
                // Consul的连接地址
                configuration.Address = new Uri("http://127.0.0.1:8500");
            });
            // 创建Consul的服务注册信息
            var registration = new AgentServiceRegistration()
            {
                // 服务ID
                ID = Guid.NewGuid().ToString(),
                // 服务名称
                Name = "demoService",
                // 服务连接地址
                Address = "https://localhost",
                // 端口
                Port = 5001
                // AgentServiceRegistration对象还有一些其他属性，后面有机会再了解
            };
            // 注册服务
            consulClient.Agent.ServiceRegister(registration);

public interface IDemoService
    {
        Task<string> GetDemoService();
    }
    public class DemoService : IDemoService
    {
        private readonly IHttpClientFactory httpClientFactory;

        public DemoService(IHttpClientFactory httpClientFactory)
        {
            this.httpClientFactory = httpClientFactory;
        }

        public async Task<string> GetDemoService()
        {
            var res = "";
            // 创建consul连接对象
            var consulClient = new Consul.ConsulClient(configuare =>
            {
                // Consul的连接地址
                configuare.Address = new Uri("http://127.0.0.1:8500");
            });
            // 根据刚才注册的服务名称获取对应的服务
            var queryResult = await consulClient.Catalog.Service("demoService");
            // 服务连接地址
            var serviceUrls = new List<string>();
            // 遍历获取到的服务列表
            foreach (var service in queryResult.Response)
            {
                // 拼接连接地址
                serviceUrls.Add(service.ServiceAddress + ":" + service.ServicePort);
            }
            HttpClient httpClient = httpClientFactory.CreateClient();
            HttpResponseMessage response = await httpClient.GetAsync(serviceUrls[0] + "/api/Home/");
            if (response.StatusCode == HttpStatusCode.OK)
            {
                res = await response.Content.ReadAsStringAsync();
            }
            return res;
        }
    }

private readonly ILogger<HomeController> _logger;
        private readonly IDemoService _demoService;

        public HomeController(ILogger<HomeController> logger, IDemoService demoService)
        {
            _logger = logger;
            _demoService = demoService;
        }

        [HttpGet]
        public Task<string> Get()
        {
            return _demoService.GetDemoService();
        }

1 services.AddScoped<IDemoService, DemoService>();