Проблема с трубопроводом в 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 procsss. Ошибка, исключение, но она не возвращается из метода process.

Если я конвертирую поток с потоком в поток ByteArray, он отлично работает.

Правильно ли я использую поток трубопроводов?

Answer 1

Нет, потоки с потоками предназначены для передачи данных между двумя потоками. Между концами трубы имеется только небольшой буфер. Если вы напишете в поток потока с каналами, ваш поток будет заблокирован, если буфер заполнен до тех пор, пока другой поток не будет считываться из соответствующего потока входных каналов. Это не будет работать только с одним потоком.

Из Javadoc:

Как правило, данные считываются из объекта PipedInputStream одним нити и данные записываются в соответствующего PipedOutputStream по какой-либо другой нити.

Так что для небольших шаблонов просто использовать StringWriter, для больших, вы можете использовать FileWriter на временный файл, созданный File.createTempFile().

Answer 2

Как пишет Арне, количество буферного пространства в потоке с каналами довольно невелико. Если вы не можете использовать буфер, который может хранить все данные (будь то в памяти или на диске), то одна вещь, которую вы могли бы попробовать, - проверить, можно ли запустить обработку шаблона в другом потоке с потоком, переданным по каналам, отправляющим результаты обратно в основной поток, где вы это делаете.

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); 
     } 
    } 
);