Study.Microservices

一步一步，由浅入深，学习如何使用.net core搭建微服务框架。

第一步 使用dotnetty完成rpc

启动服务端

   var host = new HostBuilder()
                .AddRpcRuntime()
                .AddRpcServer()
                .UseDotNettyServer()
				.UseConsul()
                .ConfigureAppConfiguration((context, config) =>
                {
                    config.SetBasePath(Directory.GetCurrentDirectory());
                    config.AddJsonFile("appsettings.json", optional: true);
                    config.AddEnvironmentVariables();
                })
                 .ConfigureServices((context, services) =>
                 {
                     services.AddTransient<IUserService, UserService>();
                 })
                 .ConfigureLogging((context, logger) =>
                 {
                     logger.AddConfiguration(context.Configuration.GetSection("Logging"));
                     logger.AddConsole();
                 });

            host.RunConsoleAsync().Wait();

启动客户端

   var builder = new HostBuilder()
                .AddRpcRuntime()
                .AddRpcClient()
                .AddClientProxy()
                .UseDotNettyClient()
				.UseConsul()
                .ConfigureLogging((context, logger) =>
                {
                    logger.AddConfiguration(context.Configuration.GetSection("Logging"));
                    logger.AddConsole();
                });
                
            using (var host=builder.UseConsoleLifetime().Build())
            {
                host.Start();

                var provider = host.Services;
                var proxyGenerater = provider.GetService<IServiceProxyGenerater>();
                var remoteServices = proxyGenerater.GenerateProxys(new[] { typeof(IUserService) }).ToArray();
                var proxyFactory = provider.GetService<IServiceProxyFactory>();
                var userService = proxyFactory.CreateProxy<IUserService>(remoteServices.Single(typeof(IUserService).GetTypeInfo().IsAssignableFrom));

                Stopwatch sw = Stopwatch.StartNew();

                for (var i = 0; i < 10000; i++)
                {
                    var result = userService.GetUserNameAsync(i).Result;
                }
                sw.Stop();
                Console.WriteLine($"调用结束,耗时：{sw.ElapsedMilliseconds} 毫秒");

                host.WaitForShutdown();
            }