做一个简单的微服务架构如下图：
这个图表示的是一个网关代理Consul的两个服务，consul每个服务注册集群
安装 Consul的服务，这里安装单机版的，集群版配置最低要求（3个Consul server）的需要三台虚拟机，穷
这是下载地址 Consul 我这里部署的是CentOS7 ip是：192.168.31.140 记得关闭防火墙
yum instarll wget -yyum instarll unzip -ywget /consul/1.7.2/consul_1.7.2_linux_amd64.zipunzip consul_1.7.2_linux_amd64.zipmv consul /usr/local/bin/consul -v 查看图一代表安装成功了nohup consul agent -server -ui -bootstrap-expect=1 -data-dir=/tmp/consul -node=consul-1 -client=0.0.0.0 -datacenter=dc1 & 后台启动会生成一个nohup.out的日子文件curl http://127.0.0.1:8500/ui/dc1/services 访问 如下图二代表服务启动OKconsul可以通过配置文件注册服务，我这里用的是api代码注册配置文件注册vi /etc/consul/services_config.json创建配置文件重启即可
图一
图二
接下来写ServiceUser的服务，选择 core Api模板创建项目，安装Consul包
添加一个健康检查的API直接返回OK
再添加一个返回用户数据的API
在写一个服务注册的方法在Startup.cs里，ip和port及id我是从命令行获取的其他配置均写在配置文件里
private static void ServiceRegister(IConfiguration configuration){ConsulClient client = new ConsulClient(new Action<ConsulClientConfiguration>(t => {t.Address = new Uri(configuration["consul:servicesAddr"]);//这是Consul的服务地址192.168.31.140t.Datacenter = configuration["consul:datacenter"];//储存名}));//注册一个实例var result = client.Agent.ServiceRegister(new AgentServiceRegistration(){Address = configuration["ip"], //注册服务的IPID = $"{configuration["consul:serviceName"]}{configuration["id"]}",//服务id唯一的Name = configuration["consul:serviceName"],//服务名Port = Convert.ToInt32(configuration["port"]),//端口Tags = null,Check = new AgentServiceCheck(){HTTP = $"http://{configuration["ip"]}:{configuration["port"]}{configuration["consul:healthCheck"]}",//健康检查的API地址Interval = new TimeSpan(0, 0, 10),//间隔多少检查一次DeregisterCriticalServiceAfter = new TimeSpan(0, 1, 0) //多久注销不健康的服务}}).Result;}
获取命令行参数 写在main 方法里如下图
new ConfigurationBuilder().SetBasePath(Directory.GetCurrentDirectory()).AddCommandLine(args).Build();
编写配置文件
"consul": {"servicesAddr": "http://192.168.31.140:8500","datacenter": "dr1","serviceName": "ServiceCommodity","healthCheck": "/api/Health"}
ServiceCommodity和ServiceUser一样
接下来启动实例注册服务，我这里用端口区分不同的实例
dotnet ServiceCommodity.dll --urls http://*:5000 --environment Development --ip 192.168.31.137 --port 5000 --id 1dotnet ServiceCommodity.dll --urls http://*:5001 --environment Development --ip 192.168.31.137 --port 5001 --id 2dotnet ServiceCommodity.dll --urls http://*:5002 --environment Development --ip 192.168.31.137 --port 5002 --id 3dotnet ServiceUser.dll --urls http://*:6000 --environment Development --ip 192.168.31.137 --port 6000 --id 1dotnet ServiceUser.dll --urls http://*:6001 --environment Development --ip 192.168.31.137 --port 6001 --id 2dotnet ServiceUser.dll --urls http://*:6002 --environment Development --ip 192.168.31.137 --port 6002 --id 3
接下来注册Ocelot网关，微服务是离不开网关的，现在可能看不出网关的效果，Consul搭建成集群就能看出效果了
创建一个空的web项目安装如下两个包
在Startup.cs 里注册
创建ocelot.json配置文件
{"ReRoutes": [{"DownstreamPathTemplate": "/api/{controller}",//你的api路径"DownstreamScheme": "http","UpstreamPathTemplate": "/dust/{controller}",//你映射的路径"UpstreamHttpMethod": [ "get", "post" ],//请求方法"ServiceName": "ServiceCommodity",//你的服务名称"LoadBalancerOptions": {"Type": "LeastConnection"//ocelot提供了几种均衡方法，这里用的是最小连接}},{"DownstreamPathTemplate": "/api/{controller}","DownstreamScheme": "http","UpstreamPathTemplate": "/dust1/{controller}","UpstreamHttpMethod": [ "get", "post" ],"ServiceName": "ServiceUser","LoadBalancerOptions": {"Type": "LeastConnection"}}],"GlobalConfiguration": {"ServiceDiscoveryProvider": {"Host": "192.168.31.140",//你的Consul的ip地址"Port": 8500,//你的Consul的端口"ConfigurationKey": "Consul"//指定Consul，ocelot提供了几种，可以去官网看看}}}
加载配置文件
.ConfigureAppConfiguration((hostingContext, config) =>{config.SetBasePath(hostingContext.HostingEnvironment.ContentRootPath).AddJsonFile("appsettings.json", true, true).AddJsonFile($"appsettings.{hostingContext.HostingEnvironment.EnvironmentName}.json", true, true).AddJsonFile("ocelot.json").AddEnvironmentVariables();})
启动 dotnet GateWayOcelot.dll --urls http://*:7000
最后应用请求网关
string[] userAry = null;string[] commodityAry = null;using (HttpClient httpClient = new HttpClient()){HttpResponseMessage httpResponseMessage = httpClient.GetAsync("http://192.168.31.137:7000/dust1/user").Result;userAry = JsonConvert.DeserializeObject<string[]>(httpResponseMessage.Content.ReadAsStringAsync().Result);}using (HttpClient httpClient = new HttpClient()){HttpResponseMessage httpResponseMessage = httpClient.GetAsync("http://192.168.31.137:7000/dust/commodity").Result;commodityAry = JsonConvert.DeserializeObject<string[]>(httpResponseMessage.Content.ReadAsStringAsync().Result);}this.ViewBag.msgText = $"{userAry[0]}和{userAry[1]}讨论项目,去烧烤摊点了{commodityAry[0]},{commodityAry[1]},{commodityAry[2]},第二天凌晨5点两个人支起了早餐摊！";
到此一个简单的微服务OK了
Demo下载地址:/Xiao-Dust/MicroService
往期精彩回顾
.netcore consul实现服务注册与发现（一）单机部署
.netcore consul实现服务注册与发现（二）集群完整版
基于Docker的Consul服务发现集群搭建
Ocelot简易教程（五）之集成IdentityServer认证以及授权
点击【在看】+转发【朋友圈】对我最大的支持
