IceRPC之调用管道Invocation pipeline与传出请求Outgoing request->快乐的RPC

技术分享 6个月前 (05-16) 0 999+

关注

作者引言 `.Net 8.0 下的新RPC`

很高兴啊，我们来到了IceRPC之调用管道 Invocation pipeline与传出请求 Outgoing request->快乐的RPC, 基础引导，让自已不在迷茫，快乐的畅游世界。

调用管道 `Invocation pipeline`

了解如何发送请求requests和接收响应responses。

定义

发送请求并接收相应响应的过程称为调用。

通常会通过客户端连接进行调用。然而,由于客户端和服务器连接具有相同的功能,因此也可以反过来调用,从连接的服务器端到此连接的客户端。

调用抽象

IceRPC总是通过调用调用器invoker来进行调用。调用器是一个简单的抽象,它接受传出的请求并返回传入的响应。

C# 中, 这个抽象是 IInvoker 接口:

namespace IceRpc;  public interface IInvoker {     Task<IncomingResponse> InvokeAsync(OutgoingRequest request, CancellationToken cancellationToken = default); }

ClientConnection 和 ConnectionCache 都实现此接口。这允许通过创建客户端连接或连接缓存,然后在生成的实例上调用 InvokeAsync 来进行调用:

await using var clientConnection = new ClientConnection(new Uri("icerpc://hello.zeroc.com")); using var request = new OutgoingRequest(...);  // Make an invocation by calling the IInvoker.InvokeAsync method implemented by ClientConnection. IncomingResponse response = await clientConnection.InvokeAsync(request);

处理调用

在将其提供给连接之前,通常会对调用执行附加处理。例如,可能需要压缩请求的有效负载、为每个请求添加遥测字段、添加截止时间或简单地添加日志记录等。

调用器实现可以调用另一个调用器,它本身调用另一个调用器,等等;用于进行调用的调用器可以是调用器链或树的头,称为"调用管道"invocation pipeline.

3种常见的调用者类型:

Leaf invoker
这是调用管道中的一片叶子。该调用器通常是连接。
Interceptor
拦截器拦截调用，并将其转发到"下一个"next拦截器。IceRPC提供了几个内置的拦截器,用于记录,压缩等。
Pipeline
管道在向调用器发出请求之前,通过在该管道中注册的拦截器来执行请求。

--- title: A typical invocation pipeline --- flowchart LR app([application code]) -- request --> i1["interceptor #1"] -- request --> i2["interceptor #2"] i2 -- request --> ti["ClientConnectionn or ConnectionCache"] -- request --> connection connection -- response --> ti -- response --> i2 -- response --> i1 -- response --> app

传出请求 `Outgoing request`

了解如何创建传出请求

创建传出请求 `Outgoing request`

为了创建 RPC,构造一个传出请求,然后将此请求作为参数传递给调用者invoke的调用方法。

传出请求携带调用者发送请求所需的所有信息:

目标服务的服务地址service address
调用此服务的操作名称
请求字段
请求的有效负载

传出请求还包含功能features。这些功能用于该管道内的本地通信；它们还用于管道中的调用者和应用程序代码之间的通信。

请求字段

请求字段表示由"传输连接"的请求承载的带外信息". 这些字段通常由拦截器和中间件读取和写入,以协调客户端和服务器中相同请求的处理。

字段是字节序列的字典 RequestFieldKey 中的条目,其中 RequestFieldKey 是 Slice 中定义的枚举:

unchecked enum RequestFieldKey : varuint62 {     Context = 0     TraceContext = 1     CompressionFormat = 2     Deadline = 3     Idempotent = 4 }

例如,当压缩拦截器压缩传出请求的有效负载时,它设置请求字段CompressionFormat。这告诉连接另一侧的压缩中间件"该有效负载是用 brotli 压缩的";然后压缩中间件可以解压缩该（传入）请求有效负载。

请求有效负载和继续有效负载`Payload`

请求的有效负载是表示操作参数的字节流。当连接发送请求时,它会读取这些字节并将其逻辑复制到网络连接,直到不再有字节需要读取。

另一方面,连接从网络读取这些字节,创建传入请求并将此请求提供给调度器 dispatcher。

传出请求的有效负载实际上分为两部分:连接在等待响应之前发送的第一部分,以及连接在等待、接收和返回响应时在后台发送的第二部分("继续")。

sequenceDiagram Local-)Remote: request header + payload par Remote--)Local: response header + payload and Local-)Remote: request payload continuation end

另一方面,调度器仅看到单个连续的传入请求有效负载。

请求功能

调用管道中的调用者在调用期间相互传输信息是很常见的。例如,重试拦截器需要与连接缓存通信,以确保连接缓存不会继续使用相同的服务器地址重试。C# 中,这些调用者获取并设置请求的 IFeatureCollection 以相互通信。

还可以使用这些功能与调用管道进行通信。例如,您可以设置功能 ICompressFeature 以要求压缩机拦截器（如果已安装）压缩请求的有效负载:

using var request = new OutgoingRequest(serviceAddress) {     Payload = largePayload,     Features = new FeatureCollection().With<ICompressFeature>(CompressFeature.Compress) };  // Hopefully invoker is an invocation pipeline with a compressor interceptor. IncomingResponse response = await invoker.InvokeAsync(request);

按照惯例,这些功能是使用接口类型进行管控的,例如上面示例中的 ICompressFeature。