Spring MVC + Oracle LOBs + Streaming - PullRequest
       10

Spring MVC + Oracle LOBs + Streaming

5 голосов
/ 14 января 2010

Мне нужно отправить двоичный поток блоба с помощью ServletOutputStream.

Я использую следующие технологии и программное обеспечение: Oracle 11, WebSphere 7, Springframework 2.5.5, Hibernate 3.3.SP1.

Есть две базы данных Oracle. Первый содержит таблицы для описания документов, которые я должен передать, а второй - содержание документов.

Я также настроил поддержку источников данных XA в WebSphere и JtaTransactionManager весной.

Я получаю ссылку на документ и сам контент в одной транзакции.

В спецификации JDBC говорится, что большие объекты являются транзакционными объектами, и переносимые приложения должны использовать такие объекты в транзакциях.

И у меня есть следующие вопросы:

  1. Законно ли получать входной поток BLOB внутри транзакционного метода и передавать его нетранзакционному методу верхнего уровня? Примерно так:

    @Transactional
    public InputStream getContent(Long docId) {
        Blob blob = getBlob(...);
        return blob.getBinaryStream();
    }


    public ModelAndView handleRequestInternal(HttpServletRequest req, HttpServletResponse resp) {
       Long docId = ServlerRequestUtils.getRequiredLongParameter(req);
       InputStream is = service.getContent(docId);
       copy(is, resp.getOutputStream());
       return null;
    }
  1. Если это недопустимо, как передать двоичный поток BLOB конечному пользователю, если содержимое BLOB достаточно велико и на сервере приложений предварительно настроено время ожидания транзакции? Нужно ли обрабатывать транзакции вручную и устанавливать время ожидания равным нулю (транзакция никогда не прекращается)?

  2. Каков наилучший способ передачи двоичного потока BLOB конечному пользователю в таком случае?

1 Ответ

5 голосов
/ 14 января 2010

Вы правы в том, что возврат потока BLOB из вашего метода tx не очень хорошая идея ... он может работать при определенных обстоятельствах, в зависимости от базы данных, но это рискованно.

Решение - вывернуть проблему наизнанку. Передайте сервлет OutputStream в ваш транзакционный метод. Это позволяет избежать проблемы транзакции и сохранить обработку вашего потока в одном месте:

@Transactional
public void getContent(Long docId, OutputStream outputStream) {
    Blob blob = getBlob(...);
    InputStream blobStream = blob.getBinaryStream();
    copy(blobStream, outputStream);
    blobStream.close(); // ignoring the usual stream closing try/catch stuff for brevity
}

public ModelAndView handleRequestInternal(HttpServletRequest req, HttpServletResponse resp) {
   Long docId = ServlerRequestUtils.getRequiredLongParameter(req);
   service.getContent(docId, resp.getOutputStream());
   return null;
}
...