.NET Core API网关Ocelot(十七)【委托处理程序,Raft(实验功能不能用于生产环境)】

àì夳堔傛蜴生んèń 2021-07-05 01:42 157阅读 0赞

Ocelot允许用户将委托处理程序添加到`HttpClient`传输中。 这个功能在github \#208中提出，我确定它会以各种方式被使用。之后我们在GitHub＃264中进行了扩展。

## 用法 ##

为了将委托处理程序添加到`HttpClient`传输中，有两件重要的事情要做。

首先，为了创建一个可以用于委托处理程序的类，它必须如下所示。 我们将在asp.net core容器中注册这些处理程序，以便您可以将您已注册的其他服务注入到处理程序的构造函数中。

public class FakeHandler : DelegatingHandler
    { 
        protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
        { 
            //do stuff and optionally call the base handler..
            return await base.SendAsync(request, cancellationToken);
        }
    }

其次，您必须将处理程序添加到`Ocelot`的容器。

services.AddOcelot()
            .AddDelegatingHandler<FakeHandler>()
            .AddDelegatingHandler<FakeHandlerTwo>()

这两个`Add`方法都具有一个称为`global`的默认参数，该参数设置为`false`。 如果为`false`，则`DelegatingHandler`需要通过`ocelot.json`设置特定的`Routes`（稍后会详细介绍）。 如果将其设置为`true`，则它将成为全局处理程序并将应用于所有`Route`。

例如  
如下…

services.AddOcelot()
            .AddDelegatingHandler<FakeHandler>(true)

最后，如果你想要`Route`指定`DelegatingHandlers`为你的特定`DelegatingHandlers`，或全局（稍后会详细介绍）`DelegatingHandlers`，那么你必须将下面的`json`添加到`ocelot.json`中的特定`Route`中。 数组中的名称必须与您的`DelegatingHandlers`类名匹配，以便`Ocelot`将它们匹配在一起。

"DelegatingHandlers": [
        "FakeHandlerTwo",
        "FakeHandler"
    ]

你可以有多个`DelegatingHandlers`，他们的运行顺序如下：

1.  所有在服务中并且不在`ocelot.json`的`DelegatingHandlers`数组中的全局处理程序按加入的顺序排序。
2.  所有非全局的`DelegatingHandlers`以及来自`ocelot.json`的`DelegatingHandlers`数组中的所有全局变量都按照它们在`DelegatingHandlers`数组中的顺序排列。
3.  如果启用了跟踪，那么这一步是跟踪`DelegatingHandler`(看跟踪文档).
4.  如果启用了`QoS`，那么这一步是QoS `DelegatingHandler` (看服务质文档).
5.  `HttpClient`发生`HttpRequestMessage`.

希望其他人会洞悉这个功能是很有用的！

--------------------

# Raft #

Ocelot最近整合了`Rafty`，这是我在去年一直研究的`Raft`的一个实现。 这个项目实验性非常强，所以在我认为它没问题之前，请不要在生产环境中使用`Ocelot`的这个功能。

`Raft`是一种分布式一致性算法，它允许一组服务器（`Ocelots`）保持本地状态，而不需要一个集中式数据库（例如`SQL Server`）存储状态。

要获得Raft支持，您必须首先安装Ocelot Rafty软件包。

Install-Package Ocelot.Provider.Rafty

为了在`Ocelot`中启用`Rafty`，您必须对`Startup.cs / Program.cs`进行以下改动。

public virtual void ConfigureServices(IServiceCollection services)
    { 
         services
            .AddOcelot()
            .AddAdministration("/administration", "secret")
            .AddRafty();
    }

除此之外，您还必须在您的主项目中添加名为peers.json的文件，其内容看起来如下所示：

{ 
        "Peers": [{ 
                "HostAndPort": "http://localhost:5000"
            },
            { 
                "HostAndPort": "http://localhost:5002"
            },
            { 
                "HostAndPort": "http://localhost:5003"
            },
            { 
                "HostAndPort": "http://localhost:5004"
            },
            { 
                "HostAndPort": "http://localhost:5001"
            }
        ]
    }

`Ocelot`的每个实例必须在数组中有它的地址，以便它们可以使用`Rafty`进行通信。

完成这些配置更改后，您必须使用`peers.json`文件中的地址部署和启动`Ocelot`的每个实例。 然后服务器应该开始彼此通信！ 您可以通过发布配置更新来检测一切是否正常工作，并通过配置来检查它是否已复制到所有服务器。