1.服务注册

在上一篇的鉴权和登录服务中分别通过NuGet引用Consul这个包,同时新增AppBuilderExtensions类:

    public static class AppBuilderExtensions{public static IApplicationBuilder RegisterConsul(this IApplicationBuilder app,IApplicationLifetime lifetime,ServiceEntity serviceEntity){var consulClient = new ConsulClient(x => x.Address = new Uri($"http://{serviceEntity.ConsulIP}:{serviceEntity.ConsulPort}"));//请求注册的Consul地址var httpCheck = new AgentServiceCheck(){DeregisterCriticalServiceAfter=TimeSpan.FromSeconds(5),//服务启动多久后注册Interval=TimeSpan.FromSeconds(10),//健康检查时间间隔,或者成为心跳间隔HTTP=$"http://{serviceEntity.IP}:{serviceEntity.Port}/api/health",//健康检查地址Timeout=TimeSpan.FromSeconds(5)};//Register service with consulvar registration = new AgentServiceRegistration(){Checks = new[] {httpCheck},ID=Guid.NewGuid().ToString(),Name=serviceEntity.ServiceName,Address=serviceEntity.IP,Port=serviceEntity.Port,Tags = new[] { $"urlprefix-/{serviceEntity.ServiceName}"} //添加urlprefix-/servicename格式的tag标签,以便Fabio识别
            };consulClient.Agent.ServiceRegister(registration).Wait();//服务启动时注册,内部实现其实就是使用Consul API进行注册(HttpClient发起)lifetime.ApplicationStopping.Register(() =>{consulClient.Agent.ServiceDeregister(registration.ID).Wait();//服务停止时取消注册
            });return app;}}public class ServiceEntity{public string IP { get; set; }public int Port { get; set; }public string ServiceName { get; set; }public string ConsulIP { get; set; }public int ConsulPort { get; set; }}

通过这个类可以提供服务注册的基本参数。

修改Startup启动项中的Configure方法:

public void Configure(IApplicationBuilder app, IHostingEnvironment env, IApplicationLifetime lifetime){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}#region Consul 服务注册ServiceEntity serviceEntity = new ServiceEntity{IP = "127.0.0.1",   //服务运行地址Port = Convert.ToInt32(Configuration["Consul:ServicePort"]), //服务运行端口ServiceName = Configuration["Consul:Name"], //服务标识,Ocelot中会用到ConsulIP = Configuration["Consul:IP"], //Consul运行地址ConsulPort = Convert.ToInt32(Configuration["Consul:Port"])  //Consul运行端口(默认8500)
            };app.RegisterConsul(lifetime, serviceEntity);#endregionapp.UseIdentityServer();//app.UseAuthentication();
            app.UseStaticFiles();app.UseMvcWithDefaultRoute();}

看下配置文件需要新增的东西:

{"Service": {"Name": "MI.Service","Port": "7001","DocName": "Account Service","Version": "v1","Title": "Account Service API"},"Identity": {"IP": "localhost","Port": "7000","Scheme": "Bearer"},"ConnectionStrings": {"SqlConnection": "server=.;uid=sa;pwd=sa;database=MI"},"Consul": {"Name": "MI.Service.Account","ServiceProt": "7001","IP": "localhost","Port": "8500"}
}

蓝色标识的Consul部分是我们这里需要用到的,这里我把项目名称当作服务注册标识。

然后还需要为两个服务添加两个方法,一个是用来做健康检查的,一个是用来测试的:

    [Route("api/Health")]public class HealthController : Controller{[HttpGet]public IActionResult Get() => Ok("ok");}

public class MiUserController : Controller{public MIContext _context;public MiUserController(MIContext _context){this._context = _context;}public string Index(){return "Successful";}。。。。。。
}

通过“consul agent -dev”命令运行Consul,访问127.0.0.1:8500我们可以看到Consul的UI界面:

这里可以看到我们已经注册的两个服务。

2.服务发现

新建API项目MI.Ocelot,通过NuGet引用Ocelot和Ocelot.Provider.Consul两个包,并修改启动项注册Ocelot和Consul:

public void ConfigureServices(IServiceCollection services){//services.AddMvc();
            services.AddOcelot(Configuration).AddConsul();}// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.public void Configure(IApplicationBuilder app, IHostingEnvironment env){if (env.IsDevelopment()){app.UseDeveloperExceptionPage();}app.UseOcelot();//app.UseMvc();  }

然后添加配置文件consul.json:

{"ReRoutes": [{"UseServiceDiscovery": true, //启用服务发现"DownstreamPathTemplate": "/Account/{url}", //下游转发路由"DownstreamScheme": "http", //标识头"ServiceName": "MI.Service.Account", //服务注册标识"LoadBalancer": "RoundRobin", //服务均衡:轮询"UpstreamPathTemplate": "/Account/{url}", //上游请求路由"UpstreamHttpMethod": [ "Get", "Post" ], //请求的方法类型"ReRoutesCaseSensitive": false //不区分大小写
    },{"UseServiceDiscovery": true,"DownstreamPathTemplate": "/Identity/{url}","DownstreamScheme": "http","ServiceName": "MI.Service.IdentityServer","LoadBalancer": "RoundRobin","UpstreamPathTemplate": "/Identity/{url}","UpstreamHttpMethod": [ "Get", "Post" ],"ReRoutesCaseSensitive": false}],"GlobalConfiguration": {//"BaseUrl": "http://localhost:7003","ServiceDiscoveryProvider": {"Host": "127.0.0.1", // Consul Service IP"Port": 8500, // Consul Service Port"Type": "PollConsul","PollingInterval": 100 //健康检查时间端
    }}
}

在Program中启用这个配置文件:

        public static IWebHost BuildWebHost(string[] args) =>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().ConfigureAppConfiguration((hostingContext,builder)=> {builder.AddJsonFile("consul.json");}).Build();

到此,网关配置完毕。现在我将网关项目MI.Gateway部署在7003端口,登录服务MI.Service.Account部署在7001端口,鉴权服务部署在7000端口,我会通过访问网关服务来请求登录服务:

这里的流程是这样的,Ocelot通过“/Account/MiUser/Index”匹配到了“/Account/{url}”这个路由,进而拿到了“MI.Service.Account”这个服务注册标识,然后通过Consul拿到了对应的地址,并转发了请求,同时返回结果。

到此,具备服务注册和发现的简单网关服务就搭建完毕了,后面有时间会继续优化,添加限流、熔断,同时身份验证会在Ocelot中进行,而不是再去访问单独的鉴权服务。

转载于:https://www.cnblogs.com/weiBlog/p/9833807.html

.Net Core 商城微服务项目系列(二):使用Ocelot + Consul构建具备服务注册和发现功能的网关...相关推荐

  1. 实战某小型企业项目系列二:方案设计

    系列文章: 实战某小型企业项目系列一:需求描述 实战某小型企业项目系列二:方案设计 实战某小型企业项目系列三:项目实施规划_网络部分 实战某小型企业项目系列四:项目实施规划_系统部分 实战某小型企业项 ...

  2. .Net Core 商城微服务项目系列(十二):使用k8s部署商城服务

    一.简介 本篇我们将会把商城的服务部署到k8s中,同时变化的还有以下两个地方: 1.不再使用Consul做服务的注册和发现,转而使用k8s-dns来实现. 2.不再使用Ocelot作为业务网关,使用T ...

  3. .Net Core 商城微服务项目系列(十四):分布式部署携程Apollo构建配置中心

    一.开场白 在系统设计里我们有很多配置希望独立于系统之外,而又能够被系统实时读取.但是在传统的系统设计里,配置信息通常是耦合在系统内的,比如.net里通常会放在App.config或者web.conf ...

  4. .Net Core 商城微服务项目系列(八):购物车

    最近加班有点多,一周五天,四天加班到11点+,心很累.原因是我当前在的这个组比较特殊,相当于业务的架构组,要为其它的开发组提供服务和监控.所以最近更新的也少,不过这个元旦三天假应该会更新三篇. 这篇是 ...

  5. .Net Core 商城微服务项目系列(一):使用IdentityServer4构建基础登录验证

    这里第一次搭建,所以IdentityServer端比较简单,后期再进行完善. 1.新建API项目MI.Service.Identity,NuGet引用IdentityServer4,添加类InMemo ...

  6. 微服务架构系列二:密码强度评测的实现与实验

    本文是继<微服务架构系列一:关键技术与原理研究>的后续,系列一中论述了微服务研究的背景和意义,主要调研了传统架构的发展以及存在的问题和微服务架构的由来,然后针对微服务架构的设计原则.容器技 ...

  7. Springcloud HRM微服务项目(二)

    文章目录 课程类型数据查询 1.如何查询数据 2.如何封装数据 3.配置跨域 给课程分类做缓存 1.简介 2.搭建基础服务 3.集成redis 1.导包 2.工具类 3.测试工具类 4. redis服 ...

  8. 微服务项目占用内存过多机器扛不住怎么办?服务allinone设计

    前言: 现在越来越多的项目都使用微服务了,然后就发现原来的8G内存压根扛不住,按照本教程教的方法,在本地开发的时候做服务allinone,在部署的时候使用微服务部署,既保证了微服务的架构先进性又保证本 ...

  9. 采用Opserver来监控你的ASP.NET项目系列(二、监控SQL Server与Asp.Net项目)

    前言 之前有过2篇关于如何监控ASP.NET core项目的文章,有兴趣的也可以看看. ASP.NET Core之跨平台的实时性能监控 ASP.NET Core之跨平台的实时性能监控(2.健康检查) ...

最新文章

  1. uncompressing linux .................................................后没反应解决办法
  2. eventproxy
  3. Kettle使用_22 维度更新 缓慢变化维 拉链表
  4. double 格式化
  5. 自己动手写CPU(5)简单算术操作指令实现_1
  6. mfc 找到字符串中字符_[LeetCode] 467. 环绕字符串中唯一的子字符串
  7. js学习(利用websocket监控服务器)
  8. c语言复杂度为o(n)的排序算法,计数排序算法——时间复杂度O(n+k)
  9. Rust 1.34替代Cargo注册表 与crates.io共存
  10. 设计模式-第二篇之简单工厂模式
  11. 后台经验分享:如何做权限管理系统设计?
  12. 解决window10播放.avi格式视频黑屏,只有声音没有视频0xc00d5212错误
  13. Unity2D 简易2D地图 —— 地图的显示
  14. 怎么把HTM格式转化成WORD
  15. 云计算机具有什么特点,云计算具有哪些特点?
  16. windows7自带摄像头拍照摄像软件
  17. NCE4 L5 Youth
  18. python怎么实现打开摄像头_python开启摄像头以及深度学习实现目标检测方法
  19. 《C语言程序设计》课程总结报告
  20. LSM存储引擎基本原理

热门文章

  1. ubuntu上如何安装tomcat
  2. 如何解决ajax跨域问题(转)
  3. windows 2008 r2 系统默认80端口被系统占用的处理
  4. JS——实现短信验证码的倒计时功能(没有验证码,只有倒计时)
  5. 返回指定月份的周列表 包含 周序号、开始日期、结束日期(不包含周末)
  6. [程序设计语言] 堆和栈的全面总结
  7. Javascript中的翻转器
  8. 安全专家教你如何利用Uber系统漏洞无限制的免费乘坐?
  9. Machine Learning from Start to Finish with Scikit-Learn
  10. Andoid开发中生成二维码