使用管道流和jaxb

Question

我无法弄清楚我是否不正确地使用管道流，或者我的问题是否在以下问题的其他地方。

我有一个对象（称为“ADI”），我编组到一个文件中，如下所示：

final PipedInputStream pipedInputStream = new PipedInputStream(); 
    OutputStream pipedOutputStream = null; 
    pipedOutputStream = new PipedOutputStream(pipedInputStream); 
    log.info("marshalling away"); 
    final OutputStream outputStream = new FileOutputStream(new File(
      "target/test.xml")); 
    m.marshal(adi, outputStream); 
    outputStream.flush(); 
    outputStream.close(); 
    pipedOutputStream.write("test".getBytes()); 
    // m.marshal(adi, pipedOutputStream); 
    pipedOutputStream.flush(); 
    pipedOutputStream.close(); 
    log.info("marshalling done"); 
    return pipedInputStream; 

• 该代码生成与我期望内容的文件目标/的test.xml（编组对象），验证编组到outputStream中的工作是否正常。
• 该代码还会生成一个pipedInputStream。如果我遍历从该流中提取的字节并打印它们，它会显示“test”，验证我的输入/输出管道流已正确设置并正常工作的事实。

然而，当我取消

//m.marshal(adi, pipedOutputStream); 

代码挂起永远（永远显示“编组完成的”），而我希望的代码返回一个包含输入流“测试”，然后我的编组对象。

我错过了什么？

感谢

Answer 1

我想你想不正确的使用它...

从API（http://docs.oracle.com/javase/6/docs/api/java/io/PipedInputStream.html）：

通常情况下，数据是从的PipedInputStream对象读取由一个线程和数据被其他线程写入相应的PipedOutputStream。不建议尝试从单个线程使用这两个对象，因为它可能使线程死锁。

你想要做的是这样的：

log.info("marshalling away"); 
    final OutputStream fileOutputStream = new FileOutputStream(new File(
      "target/test.xml")); 
    m.marshal(adi, fileOutputStream); 
    fileOutputStream.flush(); 
    fileOutputStream.close(); 
    final ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); 
    outputStream.write("test".getBytes()); 
    m.marshal(adi, outputStream); 
    outputStream.flush(); 
    final InputStream inputStream = new ByteArrayInputStream(outputStream.toByteArray()); 
    outputStream.close(); 
    log.info("marshalling done"); 
    return inputStream; 

在这里看到的是如何把一个输出流进输入流更多的例子：http://ostermiller.org/convert_java_outputstream_inputstream.html

有使用临时线程的方式，你可以做类似于您的原始解决方案和管道流。