【微服务No.4】 API网关组件Ocelot+Consul-低调大师

【微服务No.4】 API网关组件Ocelot+Consul

2018-06-25 526

介绍：

Ocelot是一个.NET API网关。该项目针对的是使用.NET运行微服务/面向服务架构的人员，他们需要一个统一的入口进入他们的系统。然而，它可以处理任何说HTTP并在ASP.NET Core支持的任何平台上运行的任何东西。

Ocelot是一组按特定顺序的中间件，Ocelot操纵HttpRequest对象进入由其配置指定的状态，直到它到达请求生成器中间件，在该中间件中创建HttpRequestMessage对象，该对象用于向下游服务发出请求。提出请求的中间件是Ocelot管道中的最后一件事。它不叫下一个中间件。来自下游服务的响应存储在每个请求作用域存储库中，并在请求返回到Ocelot管道时进行恢复。有一件中间件将HttpResponseMessage映射到HttpResponse对象上，并返回给客户端。这基本上是与其他一些功能。

Ocelot只能用于.NET Core，并且目前已经构建到netstandard2.0。所有下面我们使用.NET Core 2.1做演示。

创建一个基本示例：

首先我们创建一个.NET Core 2.1空项目。

当然我们还是要先引用的拉， Nuget 命令行： Install-Package Ocelot

配置：添加一个json文件实现最基本的配置：

{
    "ReRoutes": [],
    "GlobalConfiguration": {
        "BaseUrl": "urladdress"
    }
}

这里最重要的是BaseUrl。Ocelot需要知道它正在运行的URL，以便执行标题查找和替换以及某些管理配置。当设置这个URL时，它应该是客户端将看到的Ocelot运行的外部URL。

然后我们将刚才的配置文件加入到ASP.NET Core Configuration：Program.cs

 public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
                   .ConfigureAppConfiguration((hostingContext, builder) =>
                   {
                       builder
                       .SetBasePath(hostingContext.HostingEnvironment.ContentRootPath)
                       .AddJsonFile("ocelot.json");
                   })
                .UseStartup<Startup>();

View Code

最后在添加服务以及设置中间件：Startup.cs

 public void ConfigureServices(IServiceCollection services)
        {
            services.AddOcelot();//添加ocelot服务
        }

        // 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().Wait();//设置所有的Ocelot中间件
            app.Run(async (context) =>
            {
                await context.Response.WriteAsync("Hello World!");
            });
        }
    }

View Code

这些就是基本的所需编程代码。

配置文件的详细分析：

Ocelot的主要功能是收取HTTP请求并将它们转发到下游服务。目前以另一个http请求的形式出现。Ocelot描述了将一个请求作为ReRoute路由到另一个请求。为了在Ocelot中获得任何工作，您需要在配置中设置ReRoute。

说道这里我们补充一下刚才写的json文件的两个根节点：ReRoutes和GlobalConfiguration。

ReRoutes：是一个数组，其中的每一个元素代表了一个路由，我们可以针对每一个路由进行以上功能配置，告诉Ocelot如何处理上游请求的对象。

GlobalConfiguration：全局配置，可以适当的节约配置，比如baseurl节点，服务发现配置。

这样我们就实现了通过配置文件可以完成对Ocelot的功能配置：路由、服务聚合、服务发现、认证、鉴权、限流、熔断、缓存、Header头传递等。

配置一个示例：下面这个配置信息就是将用户的请求 /ProductService/1 转发到 localhost:8001/api/Test/1

{
  "ReRoutes": [
    {
      "DownstreamPathTemplate": "/api/Test/{postId}",
      "DownstreamScheme": "http",
      "DownstreamHostAndPorts": [
        {
          "Host": "127.0.0.1",
          "Port": 8001
        }
      ],
      "UpstreamPathTemplate": "/ProductService/{postId}",
      "UpstreamHttpMethod": [ "Get", "Delete" ]
    }
  ],
  "GlobalConfiguration": {
   // "BaseUrl": "http://127.0.0.1:8887/"
  }
}

View Code

DownstreamPathTemplate：下游方位url路径
DownstreamScheme：下游服务http schema
DownstreamHostAndPorts：下游服务的地址，如果使用LoadBalancer的话这里可以填多项
UpstreamPathTemplate: 上游也就是用户输入的请求Url模板
UpstreamHttpMethod: 上游请求http方法，可使用数组：Get ，Delete等

好了这样就实现了一个基本的Ocelot网关的转发示例。

下面让我们来看一下效果吧：

首先我们运行起来webapi项目发布在8001端口。然后访问地址是：http://127.0.0.1:8001/api/Test/5

我们看到的结果是：

然后我们启动我们的网关服务；发布在端口8888下，根据以上配置我们可以看到方位地址为：http://127.0.0.1:8888/ProductService/5

然后同样的请求结果是：

这样我们就实现使用统一网关来访问不同的地址，以便我们以后实现微服务的分发部署，虽然是不是多个接口，但是我们给上游访问还是提供一个接口，我们内部实现访问该访问那个接口。

至于具体怎发布也可参考这篇文章：http://www.cnblogs.com/yanbigfeg/p/9198345.html

路由小知识：

UpstreamHost=>"UpstreamHost": "baidu.com":上游主机

此功能允许您基于上游主机进行ReRoutes。这通过查看客户端使用的主机头来工作，然后将其用作我们用来识别ReRoute的信息的一部分。这样就是显示了只有在主机头值为baidu.com时才会匹配。

Priority=> "Priority": 0：优先级

此功能设置访问路由的优先级，假设在同一个路由下有多个路由，会根据优先级匹配优先级最高的，0是最低的。

Dynamic Routing：动态路由

这个主要是为了服务发现而实现的，在这种模式下，Ocelot将使用上游路径的第一个分段来查找服务发现提供商的下游服务。官网给出的大概配置效果：

{
    "ReRoutes": [],
    "Aggregates": [],
    "GlobalConfiguration": {
        "RequestIdKey": null,
        "ServiceDiscoveryProvider": {
            "Host": "localhost",
            "Port": 8510,
            "Type": null,
            "Token": null,
            "ConfigurationKey": null
        },
        "RateLimitOptions": {
            "ClientIdHeader": "ClientId",
            "QuotaExceededMessage": null,
            "RateLimitCounterPrefix": "ocelot",
            "DisableRateLimitHeaders": false,
            "HttpStatusCode": 429
        },
        "QoSOptions": {
            "ExceptionsAllowedBeforeBreaking": 0,
            "DurationOfBreak": 0,
            "TimeoutValue": 0
        },
        "BaseUrl": null,
            "LoadBalancerOptions": {
            "Type": "LeastConnection",
            "Key": null,
            "Expiry": 0
        },
        "DownstreamScheme": "http",
        "HttpHandlerOptions": {
            "AllowAutoRedirect": false,
            "UseCookieContainer": false,
            "UseTracing": false
        }
    }
}

View Code

Ocelot实现多个端口的轮询：

以上实现的这个有什么用啊，单独发布了接口，然后使用另外一个接口去复制他吗？别急，这只是其中的一个基本使用，现在我们有了基本步骤，我们改一改，实现webapi发布两个接口，8001,8002.然后还使用网关地址访问，可以循环的访问到8001端口和8002端口。

说起来简单，做起来也简单，我们只需要在我们上面的配置上修改一下即可：

{
  "ReRoutes": [
    {
      "DownstreamPathTemplate": "/api/Test/{postId}",
      "DownstreamScheme": "http",
      "DownstreamHostAndPorts": [
        {
          "Host": "127.0.0.1",
          "Port": 8001
        },
        {
          "Host": "127.0.0.1",
          "Port": 8002
        }
      ],
      "UpstreamPathTemplate": "/ProductService/{postId}",
      "UpstreamHttpMethod": [ "Get" ],
      "LoadBalancerOptions": {
        "Type": "RoundRobin"
      }
    }
  ],
  "GlobalConfiguration": {
    // "BaseUrl": "http://127.0.0.1:8887/"
  }
}

View Code

启动两个端口：

重复请求网关两次结果：

Ocelot+ Consul:

实现目标：启动服务发现然后模拟集群发布功能，实现发布端口8001,8002后，启动服务发现，然后配置Ocelot网关。实现访问统一接口可以轮询访问8001,8002,8001,8002，...这样。然后可以在添加8003，继续规则。

实现以上目标我们不需要该我们的示例代码，只需要修改配置json文件即可：

{
  "ReRoutes": [
    {
      "DownstreamPathTemplate": "/api/Test/{postId}",
      "DownstreamScheme": "http",
      "UpstreamPathTemplate": "/Product123Service/{postId}",
      "UpstreamHttpMethod": [ "Get" ],
      "ServiceName": "ProductService",
      "LoadBalancerOptions": {
        "Type": "RoundRobin"
      },
      "UseServiceDiscovery": true
    }
  ],
  "GlobalConfiguration": {
    // "BaseUrl": "http://127.0.0.1:8887/"
    "ServiceDiscoveryProvider": {
      "Host": "localhost",
      "Port": 8500,
      "Type": "PollConsul",
      "PollingInterval": 100
    }
  }
}

View Code

这个就是我们的服务功能：

Ocelot允许您指定服务发现提供程序，并使用它来查找Ocelot正在将请求转发给下游服务的主机和端口。目前，这仅在GlobalConfiguration部分中受支持，这意味着将为所有的ReRoute使用相同的服务发现提供程序，以便在ReRoute级别指定ServiceName。

ServiceName:consul的服务名称
LoadBalancerOptions：使用的算法，目前有两种RoundRobin（轮询方式）和LeastConnection（最小连接）
UseServiceDiscovery：是否启用服务发现功能 true：为启动
ServiceDiscoveryProvider：配置服务发现的一些配置
Host：主机地址
Port：端口
PollingInterval：轮询的间隔时间，以毫秒为单位。并告诉Ocelot多久可以向Consul调用服务配置的更改

想要了解更多可以访问Ocelot官网：http://ocelot.readthedocs.io/en/latest/features/servicediscovery.html

系列目录：

微服务系列文章主要介绍微服务所使用到的一些技术和一些技术示例：

作者：YanBigFeg —— 颜秉锋

出处：http://www.cnblogs.com/yanbigfeg

本文版权归作者和博客园共有，欢迎转载，转载请标明出处。如果您觉得本篇博文对您有所收获，觉得小弟还算用心，请点击右下角的 [推荐]，谢谢！

微信关注我们

原文链接：https://yq.aliyun.com/articles/640543

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

扫盲人工智能的计算力基石--异构计算

人工智能有三要素：算法，计算力，数据。我们今天主要来讲讲计算力。计算力归根结底由底层芯片提供。按照计算芯片的组成方式，可以分成：同构计算：使用相同类型指令集和体系架构的计算单元组成系统的计算方式。异构计算：使用不同类型指令集和体系架构的计算单元组成系统的计算方式。常见的计算单元类别包括CPU、GPU、ASIC、FPGA等。我们从CPU开始，讲一个小故事来帮助你理解一切。异构厨房系统：有一个大厨（CPU），能做各种菜（兼容性好），但是某些大量重复的动作（例如切菜）明显减慢了他做菜的速度。原来客人都点炒青菜，拌黄瓜之类的，大厨自己还算能胜任，但是最近（大数据时代到来），客人要求高了很多，开始点各种大菜（大量数据复杂处理）。大厨力不从心，于是老板需要找个帮手（协处理器）来帮助他，比如在切菜方面，这个帮手可以同时处理很多菜品（并行处理），

2018-06-26

657

Spring Cloud Ribbon(服务消费者)

Spring Cloud Ribbon 是一个基于Http和TCP的客户端负载均衡工具,基于Netflix Ribbon实现的。它不像服务注册中心、配置中心、API网关那样独立部署，但是它几乎存在于每个微服务的基础设施中。 Ribbon架构图 1258b858-c697-32e3-8f9e-b2623f7c6862.png Ribbon负载均衡策略 6944619-0355d316f5df9b3f.png Ribbon默认的策略是轮询，我们可以自定义负载策略来覆盖默认的，当然也可以通过配置指定使用哪些策略。负载均衡概念负载均衡技术在现有网络结构之上提供了一种廉价、有效、透明的方法，来扩展网络设备和服务器的带宽、增加吞吐量、加强网络数据处理能力、提高网络的灵活性和可用性。它有两方面的含义：首先，大量的并发访问或数据流量分担到多台节点设备上分别处理，减少用户等待响应的时间；其次，单个重负载的运算分担到多台节点设备上做并行处理，每个节点设备处理结束后，将结果汇总，返回给用户，系统处理能力得到大幅度提高。负载均衡是对系统的高可用，网络压力的缓解和处理能力扩容的重要手段之一。硬件负载均衡...

2018-06-26

680

发表评论

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。