无法使用 CXF/MTOM 接收所有文档

Question

我正在尝试做一件非常简单的事情:客户机通过其WSDL调用SOAP服务来加载PDF文档。

我使用Apache

CXF 2.7.5 和 MTOM

问题是文档似乎没有完全发送到客户端(文件大小与原始文件大小不相等)，因此，ADOBE无法打开它，因为它已损坏。

我的单元测试和SOAPUI调用都失败。

如果题目需要改进，欢迎修改

提前感谢。

<<p> 服务接口/strong>

@WebService
@DataBinding(value = JAXBDataBinding.class)
public interface DocumentService {
    @WebMethod(operationName = "getContent")
    DocumentContentVO getContent(@WebParam(name = "documentId") String documentId);
}

服务实现

@WebService(endpointInterface = "com.*.*.ws.sei.DocumentService", portName = "DocumentPort")
public class CXFDocumentService extends AbstractCommonService implements DocumentService {
@Override
public DocumentContentVO getContent(String documentId) {
    DocumentContentVO contentVO = new DocumentContentVO();
    contentVO.setDocumentId(documentId);
    DataSource ds = new PDFDataSource(nodeService,documentId);
    contentVO.setContent(new DataHandler(ds));
    return contentVO;
   }
}

PDFDataSource

@Component
public class PDFDataSource implements DataSource {
public static final String APPLICATION_PDF = "application/pdf";
private final String documentId;
private PCPNodeService nodeService;
public PDFDataSource(PCPNodeService nodeService, String documentId) {
    this.documentId = documentId;
    this.nodeService = nodeService;
}
@Override
public InputStream getInputStream() throws IOException {
    FileInputStream fis = new FileInputStream("c:/document.pdf");
    RemoteInputStream remoteInputStream = nodeService.getNodeInputStream(documentId);
    return fis;
}
@Override
public OutputStream getOutputStream() throws IOException {
    return null;
}
@Override
public String getContentType() {
    return APPLICATION_PDF;
}
@Override
public String getName() {
    return "INDICATE-DOCUMENT-NAME.pdf";
}
}

<<p> 值对象/strong>

@XmlRootElement(name = "DocumentContentVO")
@XmlAccessorType(XmlAccessType.FIELD)
@BindingType(value = javax.xml.ws.soap.SOAPBinding.SOAP11HTTP_MTOM_BINDING)
public class DocumentContentVO {
private String documentId;
@XmlMimeType("application/octet-stream")
private DataHandler content;

public DataHandler getContent() {
    return content;
}
public void setContent(DataHandler content) {
    this.content = content;
}
public String getDocumentId() {
    return documentId;
}
public void setDocumentId(String documentId) {
    this.documentId = documentId;
}
}

单元测试(让客户端调用)

public class DocumentWSClientTest {
@Test
public void soap_operation_getContent_should_return_pdf_document() throws Exception {
    final String documentId = "931c43c0-66a1-4ca3-bd86-5195a8f9e3de";
    final String wsdl = "http://localhost/pcp-soap/soap/v1/Documents?wsdl";
    final String operation = "getContent";
    final QName opName = new QName("http://sei.ws.*.*.com/", "getContent");
    //
    JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance();
    Client client = factory.createClient(wsdl);
    Object[] result = client.invoke(opName, documentId);
    DocumentContentVO documentContentVO = (DocumentContentVO) result[0];
    InputStream inputStream = documentContentVO.getContent().getInputStream();
    File file = new File("c:/job/test.pdf");
    if (file.exists() ) {
        file.delete();
    }
    file.createNewFile();
    FileOutputStream outputStream = new FileOutputStream(file);
    byte[] buffer = new byte[1024];
    while (inputStream.read(buffer) > -1) {
        outputStream.write(buffer);
    }
}
}

异常堆栈

org.apache.cxf.interceptor.Fault: Could not write attachments.
at org.apache.cxf.interceptor.AttachmentOutInterceptor$AttachmentOutEndingInterceptor.handleMessage(AttachmentOutInterceptor.java:105)
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271)
at org.apache.cxf.interceptor.OutgoingChainInterceptor.handleMessage(OutgoingChainInterceptor.java:77)
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271)
at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)
at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:239)
at org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:223)
at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:203)
at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:137)
at org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:158)
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:243)
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.doPost(AbstractHTTPServlet.java:163)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:755)
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:219)
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:684)
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:457)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:137)
at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:557)
at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:231)
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1075)
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:384)
at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193)
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1009)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)
at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:255)
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:154)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)
at org.eclipse.jetty.server.Server.handle(Server.java:370)
at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:489)
at org.eclipse.jetty.server.AbstractHttpConnection.content(AbstractHttpConnection.java:960)
at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.content(AbstractHttpConnection.java:1021)
at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:865)
at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:240)
at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)
at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668)
at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52)
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)
at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)
at java.lang.Thread.run(Thread.java:662)
    **Caused by: java.io.IOException: Closed**
at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:140)
at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:107)
at org.apache.cxf.io.AbstractWrappedOutputStream.write(AbstractWrappedOutputStream.java:51)
at org.apache.cxf.io.AbstractWrappedOutputStream.write(AbstractWrappedOutputStream.java:60)
at org.apache.cxf.attachment.AttachmentSerializer.writeAttachments(AttachmentSerializer.java:272)
at org.apache.cxf.interceptor.AttachmentOutInterceptor$AttachmentOutEndingInterceptor.handleMessage(AttachmentOutInterceptor.java:103)
... 38 more

SOAPUI httpLog链接到pastebinSOAP UI http日志

Answer 1

已解决，因为Apache http配置出错