我想在 thrift 服务中使用流,例如,在服务方法中使用流或类似的东西作为方法的参数(例如,能够将 IDataReader 的结果序列化为流,然后反序列化对另一服务器端数据的引用)。
我不认为这是明确可能的,但我想知道是否有另一种方法可以实现类似的目标。
谢谢。
Apache thrift 不支持发送流。你能得到的最接近的是发送一个字节数组。
要使用 thrift 实现类似流的体验,您可以创建一个接口,以字节数组的形式返回流的下一部分。
在 C# 语法中,它看起来像
interface MyService
{
int OpenStream(string path);
byte[] ReadNextBlock(int openedStreamId, long maxBlockSize);
}
OpenStream 返回在每次调用时传递给 ReadNextBlock 的“流 id”。在您的服务器端,您可能拥有一个 Dictionary(key - openStreamID, value - Stream) ,它将用于保持源流打开并从中读取下一个块。
您还可以在客户端创建一个辅助类,它将是 Stream 的后代,并将使用 OpenStream 和 ReadNextBlock 来获取实际数据。