Freemarker 中的管道流问题

Question

我需要在 freemarker 中加载和处理模板。我正在使用管道流来读回 freemarker 生成的结果。

示例代码：

PipedInputStream pi = new PipedInputStream();
PipedOutputStream po = new PipedOutputStream(pi);
Writer writer = new OutputStreamWriter(po);
configuration.getTemplate("xx").process(rootMap, writer);

问题是有时它会在 freemarker process 方法中冻结。 没有错误，没有异常，但它没有从 process 方法返回。

如果我将管道流转换为 ByteArray 流，它就可以正常工作。

我是否以正确的方式使用管道流？

Answer 1

不，管道流旨在在两个线程之间传递数据。管道两端之间只有一个小的缓冲区。如果写入管道输出流，则如果缓冲区已满，您的线程将被阻塞，直到另一个线程从相应的管道输入流中读取数据。这不适用于仅一个线程。

来自 Javadoc：

通常，数据是从
PipedInputStream 对象减一
线程和数据被写入
相应的 PipedOutputStream 通过
其他一些线程。

因此，对于小型模板，只需使用 StringWriter，对于大型模板，您可以在由 File.createTempFile() 创建的临时文件上使用 FileWriter。

Answer 2

正如 Arne 所写，管道流中的缓冲区空间量相当小。如果您无法使用可以容纳所有数据（无论是在内存中还是在磁盘上）的缓冲区，那么您可以尝试的一件事是看看是否可以在另一个线程中运行模板处理，并使用管道流将结果发送回到你正在执行此操作的主线程。

PipedInputStream pi = new PipedInputStream();
final Writer writer = new OutputStreamWriter(new PipedOutputStream(pi));
Thread worker = new Thread(new Runnable() {
    public void run() {
        configuration.getTemplate("xx").process(rootMap, writer);
    }
});
worker.start();

您可能需要将 final 关键字添加到其他变量中，以使其在实际代码中发挥作用。这取决于变量 configuration、getTemplate 的参数或 rootMap 变量是局部变量还是实例（或类）变量。

（当然，在指定线程的行为时，我可以对 Thread 进行子类化，但我更喜欢实例化一个接口 - 在本例中是 Runnable - 用于此类事情。）

Answer 3

这就是我让它发挥作用的方法。

final String uploadReportAsCsv = FreeMarkerTemplateUtils.processTemplateIntoString(
                        fileUploadReportTemplate, modelMap);

message.addAttachment("fileUploadProcessedReport.csv",
    new InputStreamSource() {
        //InputStreamResource from Spring is always returning an open stream,
        // thus we need to create this anonymous class.
        @Override
        public InputStream getInputStream() throws IOException {
            return new StringInputStream(uploadReportAsCsv);
        }
    }
);