我正在异步获取未知数量的ByteBuffer(它们通过网络发送).每个都包含一部分数据，它们以正确的顺序到达.我想重新组装它们，并将重新联合的数据传递给处理程序.但是，在最后一个到达之前，它们不能保存在内存中，因为它可以是许多兆字节.
因此，我的 idea 是，将InputStream传递给该数据的处理程序，处理程序可以从该处理程序中连续读取数据并进行动态处理，例如写入磁盘.由于InputStream不能写入，我可以使用PipedOutputStream，并将其连接到PipedInputStream.不过，这涉及到大量的复制(PipedInputStream有自己的缓冲区，然后通过复制到数组来再次读取)，所以我担心性能.
这是个好主意吗？我是否应该使用不同于流的技术，例如频道？
我会将ByteBuffer直接发送到接收器.接收方可以实现Flow.Subscriber<List<ByteBuffer>>，就像HttpResponse.BodySubscriber个实现一样.
这允许您的代码创建一个SubmissionPublisher(我所知道的唯一的Flow.Publisher的Java SE实现)，并将接收订户添加到其中:
SubmissionPublisher<List<ByteBuffer>> publisher =
new SubmissionPublisher<>();
// ...
Flow.Subscriber<List<ByteBuffer>> handler = /* ... */;
publisher.subscribe(handler);
// ...
while (dataAvailable) {
List<ByteBuffer> partialData = /* ... */;
publisher.submit(partialData);
}
SubmissionPublisher在如何创建提交线程以及如何处理接收方异常方面有许多选项.