Не должно быть слишком сложно отследить некоторые примеры. Я нашел один из IBM в WASdev / sample.javaee7.servlet.nonblocking . Для работы с javax.servlet API в Spring или Spring Boot достаточно просто попросить Spring ввести HttpServletRequest или HttpServletResponse. Итак, простой пример может быть:
@SpringBootApplication
@Controller
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@RequestMapping(path = "")
public void writeStream(HttpServletRequest request, HttpServletResponse response) throws IOException {
ServletOutputStream output = response.getOutputStream();
AsyncContext context = request.startAsync();
output.setWriteListener(new WriteListener() {
@Override
public void onWritePossible() throws IOException {
if ( output.isReady() ) {
output.println("WriteListener:onWritePossible() called to send response data on thread : " + Thread.currentThread().getName());
}
context.complete();
}
@Override
public void onError(Throwable t) {
context.complete();
}
});
}
}
Это просто создает WriteListener и присоединяет его к потоку вывода запроса, а затем возвращает. Ничего особенного.
EDITS: Дело в том, что контейнер сервлета, например, Tomcat, вызывает onWritePossible, когда данные могут быть записаны без блокировки. Подробнее об этом на Неблокирующие операции ввода-вывода с использованием Servlet 3.1: Масштабируемые приложения с использованием Java EE 7 (TOTD # 188). .
Слушатели (и пишущие) имеют методы обратного вызова, которые вызываются, когда контент доступен для чтения или может быть записан без блокировки.
Поэтому onWritePossible вызывается только тогда, когда out.println можно вызывать без блокировки.
Вызов методов setXXXListener указывает, что вместо традиционного ввода-вывода используется неблокирующий ввод-вывод.
Предположительно, что вы должны сделать, проверьте output.isReady, чтобы узнать, можете ли вы продолжать записывать байты. Похоже, что вам придется иметь какое-то неявное соглашение с отправителем / получателем о размерах блоков. Я никогда не использовал его, так что я не знаю, но вы попросили пример этого в среде Spring, и это то, что предоставляется.
Таким образом, onWritePossible вызывается только тогда, когда out.println может быть вызван без блокировки. Это звучит правильно, но как я могу понять, сколько байтов может быть записано? Как мне это контролировать?
РЕДАКТИРОВАТЬ 2: Это очень хороший вопрос, на который я не могу дать вам точный ответ. Я бы предположил, что onWritePossible вызывается, когда сервер выполняет код в отдельном (асинхронном) потоке от основного сервлета. Из примера вы проверяете input.isReady() или output.isReady(), и я предполагаю, что блокирует ваш поток, пока отправитель / получатель не будет готов к большему. Поскольку это делается асинхронно, сам сервер не блокируется и может обрабатывать другие запросы. Я никогда не использовал это, поэтому я не эксперт.
Когда я сказал, что будет какое-то неявное соглашение с отправителем / получателем о размерах блоков, это означает, что, если получатель способен принимать блоки по 1024 байта, вы запишете эту сумму, когда output.isReady истинно. Вы должны были бы знать об этом, читая документацию, ничего в API об этом. В противном случае вы можете написать отдельные байты, но в примере из оракула используются блоки по 1024 байта. 1024-байтовые блоки - это достаточно стандартный размер блока для потокового ввода-вывода. Приведенный выше пример должен быть расширен для записи байтов в цикле while, как показано в примере оракула. Это упражнение осталось для читателя.
Проектный реактор и Spring Webflux имеют концепцию backpressure, которая может решить эту проблему более тщательно. Это был бы отдельный вопрос, и я не изучал, как это объединяет отправителей и получателей (или наоборот).