AgileConfig/AgileConfig.ClientTest/Program.cs

using Agile.Config.Client;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using System;
using System.Threading.Tasks;

namespace AgileConfigClientTest
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");

            Task.Run(async () =>
            {
                var serviceCollection = new ServiceCollection();
                ConfigureServices(serviceCollection);
                var serviceProvider = serviceCollection.BuildServiceProvider();

                var lf = serviceProvider.GetService<ILoggerFactory>();

                var appId = "xxx";
                var seret = "app1";
                var host = "http://localhost:5000";

                try
                {
                    var client = new ConfigClient(appId, seret, host, lf.CreateLogger<ConfigClient>());
                    client.ConfigChanged += Client_ConfigChanged;
                    await client.ConnectAsync();
                    //var provider = new AgileConfigProvider(client);
                    //provider.Load();
                    await Task.Run(async () =>
                    {
                        while (true)
                        {
                            await Task.Delay(5000);
                            foreach (string key in client.Data.Keys)
                            {
                                var val = client[key];
                                //provider.TryGet(key, out string val);
                                Console.WriteLine("{0} : {1}", key, val);
                            }
                        }
                    });

                    Console.WriteLine("Test started .");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            });


            Console.ReadLine();
        }

        /// <summary>
        /// 此事件会在配置项目发生新增、修改、删除的时候触发
        /// </summary>
        /// <param name="obj"></param>
        private static void Client_ConfigChanged(ConfigChangedArg obj)
        {
            if (obj != null)
            {
                Console.WriteLine("Client_ConfigChanged, action {0} key {1}", obj.Action, obj.Key);
            }
        }

        private static void ConfigureServices(IServiceCollection services)
        {
            services.AddLogging(configure => configure.AddConsole());
            services.Configure<LoggerFilterOptions>(op =>
            {
                op.MinLevel = LogLevel.Trace;
            });
        }
    }
}