Vertx在单个文件中合并多个文件的内容

Question

在vertx中将多个文件的内容附加到单个文件中的最佳方式是什么？我尝试过vertx文件系统和asyncFile，但它们都没有附加文件的选项，或者我不知道有任何附加文件。是否有其他方法可以在vertx中异步合并或附加文件。

我能找到的唯一解决方案是制作缓冲区列表并使用循环将内容写入每个先前缓冲区长度的末尾。

Answer 1

事实上，从Vert开始。x 3.4，在文件系统上没有辅助方法将文件附加到另一个文件。

您可以使用异步文件（AsyncFile）和泵（Pump），如下所示。

首先创建一个实用程序方法来打开文件：

Future<AsyncFile> openFile(FileSystem fileSystem, String path, OpenOptions openOptions) {
  Future<AsyncFile> future = Future.future();
  fileSystem.open(path, openOptions, future);
  return future;
}

然后使用另一个泵将文件附加到另一个文件：

Future<AsyncFile> append(AsyncFile source, AsyncFile destination) {
  Future<AsyncFile> future = Future.future();
  Pump pump = Pump.pump(source, destination);
  source.exceptionHandler(future::fail);
  destination.exceptionHandler(future::fail);
  source.endHandler(v -> future.complete(destination));
  pump.start();
  return future;
}

现在，您可以将它们与顺序合成结合起来：

void merge(FileSystem fileSystem, String output, List<String> sources) {
  openFile(fileSystem, output, new OpenOptions().setCreate(true).setTruncateExisting(true).setWrite(true)).compose(outFile -> {
    Future<AsyncFile> mergeFuture = null;
    for (String source : sources) {
      if (mergeFuture == null) {
        mergeFuture = openFile(fileSystem, source, new OpenOptions()).compose(sourceFile -> {
          return append(sourceFile, outFile);
        });
      } else {
        mergeFuture = mergeFuture.compose(v -> {
          return openFile(fileSystem, source, new OpenOptions()).compose(sourceFile -> {
            return append(sourceFile, outFile);
          });
        });
      }
    }
    return mergeFuture;
  }).setHandler(ar -> {
    System.out.println("Done");
  });
}