0

SOAP ベースの Web サービスを介して送信された大きなファイルを読み取るのに苦労しています。クライアント コードがメモリ不足の例外で失敗しています。私は MTOM を使用してバイナリ データを送信しています。これで大きなファイルの送信と読み取りを処理できることを期待しています。問題のファイル サイズは 750 MB です。私はApache cxfを使用しています。これが Web サービス エンドポイントの実装です。


@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)

ここで何が欠けているのかわかりません。ポインタは高く評価されます。

  • ありがとう
4

1 に答える 1