欢迎光临
我的个人博客网站

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

相关文章

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-Consul服务注册,服务发现

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

一、简介

 前一篇Consul中有个问题是,所有客户端都要和Consul进行连接,且直接拿到了所有的服务实例,这就直接把全部的服务实例暴露出来了,所以需要用网关来隔离客户端和服务实例,

所有api请求都从网关进入。

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 

 Ocelot作为一个网关应用,主要的功能有路由、请求聚合、服务发现、统一认证、统一鉴权、限流熔断、并内置了负载均衡器等的集成。而且这些功能都只需要简单的配置即可完成。

 

二、使用Ocelot

2.1应用配置

新建一个.NetCore项目作网关应用。

安装NuGet包 

Ocelot

Startup.cs中把ConfigureServices(),Configure()里面的代码都去掉,加上Ocelot接管代码。

  public void ConfigureServices(IServiceCollection services)         {             services.AddOcelot();         }          // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.         public void Configure(IApplicationBuilder app, IWebHostEnvironment env)         {             app.UseOcelot();         }

这些操作完,程序就再也不是asp.net core,也不是什么webApi的程序了,就是一个Ocelot网关应用。

2.2路由配置

网关最重要的功能就是路由,根据路由把功能转发到其它应用去,它本身的应用有ip地址,别人可能访问它,但它怎么知道哪个请求转到哪个应用去呢,这些全靠配置。

首先在 Program.cs里的CreateHostBuilder()加入配置文件信息

public static IHostBuilder CreateHostBuilder(string[] args) =>             Host.CreateDefaultBuilder(args)             .ConfigureAppConfiguration(c =>             {                 c.AddJsonFile("ocelot.json", optional: false, reloadOnChange: true);             })                 .ConfigureWebHostDefaults(webBuilder =>                 {                     webBuilder.UseStartup<Startup>();                 });

根目录下增加配置文件ocelot.json。

  {     "Routes": [       {         //转发到下游服务地址--url变量         "DownstreamPathTemplate": "/api/{url}",         //下游http协议         "DownstreamScheme": "http",         //负载方式,         "LoadBalancerOptions": {           "Type": "RoundRobin" // 轮询         },         "DownstreamHostAndPorts": [           {             "Host": "172.16.2.9",             "Port": 5201 //服务端口           }, //可以多个,自行负载均衡           {             "Host": "172.16.2.9",             "Port": 5202 //服务端口           },           {             "Host": "172.16.2.9",             "Port": 5203 //服务端口           }         ],         //上游地址         "UpstreamPathTemplate": "/T1/{url}", //网关地址--url变量   //冲突的还可以加权重Priority         "UpstreamHttpMethod": [ "GET", "POST", "DELETE", "PUT" ]       }     ]   }

 

这里的是路由配置,注释说明已经很清楚,假如网关程序启动后的地址为http://172.16.2.9:5200

当访问:http://172.16.2.9:5200/T1/Test/GetName  网关会把请求转发到http://172.16.2.9:5201/T1/Test/GetName,http://172.16.2.9:5202/T1/Test/GetName,http://172.16.2.9:5203/T1/Test/GetName,根据负载算法决定转发规则。

LoadBalancer是来决定负载的算法

  • LeastConnection:将请求发往最空闲的那个服务器

  • RoundRobin:轮流转发

  • NoLoadBalance:总是发往第一个请求或者是服务发现

Routes里面可以配多个路由转发。

2.3验证

在前面的Consul注册的程序中(5201,5202,5203端口程序)加入一个接口

    [Route("api/[controller]/[action]")]     public class TestController : Controller     {         private IConfiguration _configuration;         public TestController(IConfiguration configuration)         {             _configuration = configuration;         }         public IActionResult GetName()         {             string port = _configuration["port"];             return Json($"端口:{port},姓名:张三");         }     }

 

启动Ocelot的网关程序,端口为5200

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 访问地址:http://ip:5200/T1/Test/GetName

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 刷新一下

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

可以看到,已经成功转发到上面配置好的路由地址。

2.4Ocelot结合Consul进行服务发现

上面的示例是没有经过Consul的,是直接转发到相应地址,这显示又面临了服务地址管理的问题了,所以需要结束Consul自动发现服务的地址。

 把ocelot.json的文件加入consul配置信息

  {     "Routes": [       {         //转发到下游服务地址--url变量         "DownstreamPathTemplate": "/api/{url}",         //下游http协议         "DownstreamScheme": "http",         //负载方式,         "LoadBalancerOptions": {           "Type": "RoundRobin" // 轮询         },         //"DownstreamHostAndPorts": [         //  {         //    "Host": "172.16.2.9",         //    "Port": 5201 //服务端口         //  }, //可以多个,自行负载均衡         //  {         //    "Host": "172.16.2.9",         //    "Port": 5202 //服务端口         //  },         //  {         //    "Host": "172.16.2.9",         //    "Port": 5203 //服务端口         //  }         //],         //上游地址         "UpstreamPathTemplate": "/T1/{url}", //网关地址--url变量   //冲突的还可以加权重Priority         "UpstreamHttpMethod": [ "GET", "POST", "DELETE", "PUT" ],         "UseServiceDisConvery": true, //使用服务发现         "ServiceName": "api"//Consul服务名称       }     ],     "GlobalConfiguration": {       //Ocelot应用地址       "BaseUrl": "http://172.16.2.9:5200",       "ServiceDiscoveryProvider": {         //Consul地址         "Host": "172.16.2.84",         //Consul端口         "Port": 8500,         "Type": "Consul"//由Consul提供服务发现,每次请求Consul       }     }   }

可以看到,这里已经把写死的下游地址去掉了,加入了Consul的信息。

安装NuGet包 

Ocelot.Provider.Consul

Startup.cs中ConfigureServices(IServiceCollection services)加入.AddConsul();

 public void ConfigureServices(IServiceCollection services)         {             services.AddOcelot()                 .AddConsul();         }

配置完成,验证效果,启动项目。

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 再次访问http://ip:5200/T1/Test/GetName

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 刷新一下

 Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 控制台信息

Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul

 

 到这就已经成功完成 Ocelot+Consul的网关和服务发现功能了。

赞(0) 打赏
未经允许不得转载:张拓的天空 » Consul+Ocelot+Polly在.NetCore中使用(.NET5)-网关Ocelot+Consul
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

专业的IT技术经验分享 更专业 更方便

联系我们本站主机

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏