Исключение из-за нехватки памяти при получении большого файла с помощью веб-службы SOAP

Question

Я пытаюсь прочитать большой файл, передаваемый через веб-сервис на основе SOAP. Сбой клиентского кода с исключением "Недостаточно памяти". Я использую MTOM для отправки двоичных данных, надеясь, что смогу позаботиться о передаче и чтении большого файла. Размер файла составляет 750 МБ. Я использую Apache CXF. Вот реализация конечных точек веб-сервисов.

@MTOM
@WebService(endpointInterface = "com.test.contentservice.service.IContentService")
@BindingType(value=javax.xml.ws.soap.SOAPBinding.SOAP11HTTP_MTOM_BINDING)
public class ContentServiceImpl implements IContentService {

@Override
    public ContentResponse getFile(ContentRequest req) {
        ContentResponse res = new ContentResponse();
        try {
            File file = this.contentManager.getFile(req);
            DataSource source = new FileDataSource(file);
            DataHandler dataHandler = new DataHandler(source);
            res.setFileData(dataHandler);
            res.setFileName(file.getName());
        } catch (Exception ex) {
        }
        return res;
    }

Весенняя запись

<jaxws:endpoint id="contentService" implementor="#contentServiceImpl"
        address="/contentservice">
        <jaxws:dataBinding>
            <bean class="org.apache.cxf.jaxb.JAXBDataBinding">
                <property name="marshallerProperties">
                    <map>
                        <entry>
                            <key>
                                <value>jaxb.encoding</value>
                            </key>
                            <value>UTF-8</value>
                        </entry>
                    </map>
                </property>
            </bean>
        </jaxws:dataBinding>
        <jaxws:properties>
            <entry key="mtom-enabled" value="true" />
        </jaxws:properties>
    </jaxws:endpoint>

Как вы можете заметить, "mtom-enabled" включен.

Код клиента генерируется с помощью инструмента cxf wsdl2java. Вот пример кода клиента

ContentResponse res =  new ContentResponse();
        try{
            res = getRegisterPort().getFile(req);
            DataHandler dataHandler = res.getFileData();
            if(dataHandler!=null){
                    final InputStream in = dataHandler.getInputStream(); 
                    byte[] bytes = IOUtils.toByteArray(in);
            }
        }catch (Exception ex) {
            LOGGER.error("Error in invoking getContent service",ex);
        }

Вот объект ответа

@XmlAccessorType( XmlAccessType.FIELD )
public class ContentResponse extends ContentServiceResponseBase {

    private String content;
    private String source;
    private String fileName;
    @XmlMimeType("application/octet-stream")
    private DataHandler fileData;
// Getter / Setter ...
}

Я устанавливаю mtom на уровне кода клиента

final BindingProvider bpAdmin = (BindingProvider) port;
        bpAdmin.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, curlUrl);
        SOAPBinding binding = (SOAPBinding)bpAdmin.getBinding();
        binding.setMTOMEnabled(true);
JVM запись выглядит следующим образом:

java -Xms64m -Xmx6144m 
И исключение: 
Exception in thread "taskExecutor-12" java.lang.OutOfMemoryError: Java heap space
       at java.util.Arrays.copyOf(Arrays.java:2882)
       at java.lang.AbstractStringBuilder.expandCapacity(AbstractStringBuilder.java:100)
       at java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:515)
       at java.lang.StringBuilder.append(StringBuilder.java:189)
       at com.sun.xml.internal.bind.v2.runtime.unmarshaller.StAXStreamConnector.handleCharacters(StAXStreamConnector.java:312)
       at com.sun.xml.internal.bind.v2.runtime.unmarshaller.StAXStreamConnector.bridge(StAXStreamConnector.java:176)
       at com.sun.xml.internal.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal0(UnmarshallerImpl.java:349)
       at com.sun.xml.internal.bind.v2.runtime.BridgeImpl.unmarshal(BridgeImpl.java:109)
       at com.sun.xml.internal.bind.api.Bridge.unmarshal(Bridge.java:222)
       at com.sun.xml.internal.ws.client.sei.ResponseBuilder$DocLit.readResponse(ResponseBuilder.java:514)
       at com.sun.xml.internal.ws.client.sei.SyncMethodHandler.invoke(SyncMethodHandler.java:110)
       at com.sun.xml.internal.ws.client.sei.SyncMethodHandler.invoke(SyncMethodHandler.java:78)
       at com.sun.xml.internal.ws.client.sei.SEIStub.invoke(SEIStub.java:107)
       at $Proxy33.getFile(Unknown Source)
Не уверен, что мне здесь не хватает, любой указатель будет высоко оценен.
 Спасибо 
                                    
                                
                            

Answer 1

ОБНОВИТЬ

Не могли бы вы в этом случае попробовать StreamingDataHandler при отправке данных с вызовом readOnce на сервере?

Ссылка, которую вы можете адаптировать, только для части обработчика потоков: http://docs.oracle.com/cd/E14571_01/web.1111/e13734/mtom.htm

---

Проблема возникает в IOUtils.toByteArray?

Если нет, попытайтесь сузить операцию, в которой выдается исключение, и обновите свой вопрос.