java - JAX-WS MTOM 流式传输 : server reads entire stream before sending

Question

我有一个执行 MTOM 流式处理的 JAX-WS RI 服务器。从客户端来看，一切都很好。服务器收到一个 StreamingDataHandler，并且双方都没有使用太多内存发送 1 GB。然而，在检索文件时，服务器在发送文件之前读取了全部内容。客户端没问题。我在两端都使用 DataHandler，所以这方面的东西很好。我只是不希望服务器在开始发送之前从 InputStream 读取所有数据。我在 impl 上有以下注释:

@MTOM
@StreamingAttachment(parseEagerly = false, memoryThreshold = 1L)
@WebService(...)

我试过 parseEagerly true 和 false。我将内存阈值设置得很低，因为我不担心小文件的小性能影响。

这是 JAX-WS RI 的错误吗？

Answer 1

我就是这样做的。工作起来很有魅力。

界面(觉得很像你做的)

@WebService
@SOAPBinding(style = Style.RPC)
public interface ResultsServer {    
    @WebMethod
    @XmlMimeType("application/octet-stream")
    public DataHandler getResultDataAsXML(@WebParam Integer raceId) throws Exception;
}

实现

@MTOM
@WebService(endpointInterface = "ca.sportstats.wtc.ResultsServer")
@StreamingAttachment(parseEagerly=true, memoryThreshold=4000000L)
public class ResultsServerImpl implements ResultsServer {

    @Override
    public DataHandler getResultDataAsXML(@WebParam Integer raceId) throws Exception {
        File xmlFile = new File("c:/tmp/xml/response.xml");
        //... write my xml file using an XMLStreamWriter
        return new DataHandler(new FileDataSource(xmlFile));
    }
}

测试

public class Test {
    public static void main(String[] args) throws Exception {

       URL url = new URL("http://url/to/ipmlementation/ResultsServerImplService?wsdl");
       QName qname = new QName("http://test.test.com/", "ResultsServer");

       Service service = Service.create(url, qname);
       ResultsServerImpl resultServer = service.getPort(ResultsServerImpl.class);

       /************  test download  ***************/
       DataHandler handler = resultServer.getResultDataAsXML(4);
       StreamingDataHandler dh = (StreamingDataHandler) handler;
       File file = File.createTempFile("test-received.xml", "");
       dh.moveTo(file);
       dh.close();

    }
}

这对我来说很有效(从服务器)流式传输一个大的 XML 文件，而不用在内存中读取它。

另见

• https://metro.java.net/guide/ch06.html
• http://docs.oracle.com/cd/E15523_01/web.1111/e13734/mtom.htm#i279618
• http://www.mkyong.com/webservices/jax-ws/jax-ws-attachment-with-mtom/