java - 尝试使用 akka 流编码(marshal) jaxb 对象时出现空文件

Question

我试图将 jaxb 对象编码为 xml 字符串，然后使用 akka Streams 将其写入文件，但执行后创建的文件为空。

我已经检查了编码(marshal)方法，但它在没有流的情况下工作正常。 请帮助我了解哪里有错误。

这是我的测试方法:

  @Test
    public void singlePojoTest() {
        ActorSystem actor = ActorSystem.create();
        Materializer materializer = ActorMaterializer.create(actor);
        //Creating and initializing of JAXB POJO
        AuditFile.Header header = new AuditFile.Header();
        initHeader(header,calendar);
        // useMarshaller - is converting object to xml String
        Flow<Object,String,NotUsed> flow = Flow.of(Object.class).map(o -> useMarshaller(o));
        Source<String,NotUsed> source = Source.single((Object)header).via(flow);
        CompletionStage<IOResult> result = source.map(string -> ByteString.fromString(string)).runWith(FileIO.toPath(Paths.get("test.txt")),materializer);
        actor.terminate();
    }

我期望在执行方法后 - 将创建带有编码 xml 的文件。

Answer 1

您正在调用actor.terminate();启动流后立即执行，无需等待流完成。

您必须“阻止”测试线程并允许异步流处理完成，然后才能终止 Actor 系统。

在关闭 Actor 系统之前应用以下内容。

result.toCompletableFuture().get();