Почему CXF/JAXB считывает весь InputStream в память перед сортировкой по SOAP-сообщению

Ответ 1

Вам не нужны никакие пользовательские маршаллеры или изменение поведения JAXB для достижения того, что вам нужно - DataHandler - ваш друг здесь.

Отвечая на ваш первый вопрос: JAXB должен хранить все данные в памяти, потому что он должен разрешать ссылки.

Я знаю, что вы не можете изменить ссылки WSDL и т.д. Но у вас есть ваш клиент WSDL в вашем проекте, чтобы генерировать классы клиентов, не так ли? Итак, что вы можете сделать (я не тестировал этот с сторонним WSDL, но, возможно, стоит попробовать) заключается в добавлении xmime:expectedContentTypes="application/octet-stream" в элемент XSD ответа, который возвращает данные, закодированные Base64. Например, например:

<xsd:element name="generateBigDataResponse">
    <xsd:complexType>
        <xsd:sequence>
            <xsd:element name="result"
                         type="xsd:base64Binary"
                         minOccurs="0"
                         maxOccurs="1"
                         xmime:expectedContentTypes="application/octet-stream"/>
        </xsd:sequence>
    </xsd:complexType>
</xsd:element>

Также не забудьте добавить пространство имен: xmlns:xmime="http://www.w3.org/2005/05/xmlmime" в элементе xsd:schema.

Что вы здесь делаете - это не изменение ссылок на WSDL, а просто указание JAXB вместо генерации byte[] для генерации DataHandler. Итак, что происходит, когда вы создаете свои клиентские классы следующим образом:

@Override
public DataHandler generateBigData() {
    try {
        final PipedOutputStream pipedOutputStream = new PipedOutputStream();
        PipedInputStream pipedInputStream = new PipedInputStream(pipedOutputStream);
        InputStreamDataSource dataSource = new InputStreamDataSource(pipedInputStream, "application/octet-stream");

        executor.execute(new Runnable() {

            @Override
            public void run() {
                //write your stuff here into pipedOutputStream
            }
        });

        return new DataHandler(dataSource);
    } catch (IOException e) {
        //handle exception if any
    }
}

Вы получаете DataHandler как тип ответа благодаря xmime. Я предлагаю вам использовать PipedOutputStream, но обязательно сделайте запись в другом потоке:

Канальный выходной поток может быть подключен к входному потоку с каналами создать канал связи. Потоковый поток - это отправка конец трубы. Как правило, данные записываются в PipedOutputStream объект одним потоком, и данные считываются из подключенного PipedInputStream через какой-то другой поток. Попытка использования обоих объектов из одного потока не рекомендуется, так как он может затормозить нить. Труба называется сломанной, если поток, который считывал байты данных из подключенного входного потока с каналами больше не будет.

Затем вы соединяете его с PipedInputStream, этот экземпляр входит в конструктор InputStreamDataSource, который затем передается в DataHandler и возвращает экземпляр DataHandler. Таким образом, ваш файл будет записан в виде кусков, и вы не получите этого исключения, больше - клиент никогда не получит таймаут.

Надеюсь, что это поможет.