SSE e Servlet 3.0

Eu registrei um SSE típico quando a página é carregada:

Cliente:

sseTest: function(){

var source = new EventSource('mySSE');
source.onopen = function(event){
console.log("eventsource opened!");
};

source.onmessage = function(event){
var data = event.data;
console.log(data);
document.getElementById('sse').innerHTML+=event.data + "<br />";
};
}

Meu Javascript-Debugger diz que "o recurso de eventos foi aberto!" foi com sucesso.

Meu código de servidor é um Servlet 3.0:

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Random;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(urlPatterns={"/mySSE"}, name = "hello-sse", asyncSupported=true)
public class MyServletSSE extends HttpServlet {

@Override
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

resp.setContentType("text/event-stream");
resp.setCharacterEncoding("UTF-8");

Random random = new Random();
PrintWriter out = resp.getWriter();

//AsyncContext aCtx = req.startAsync(req, resp);
//ServletRequest sReq = aCtx.getRequest();

String next = "data: " + String.valueOf(random.nextInt(100) + 1) + "\n\n";
//out.print("retry: 600000\n"); //set the timeout to 10 mins in milliseconds
out.write(next);
out.flush();
// do not close the stream as EventSource is listening
//out.close();
//super.doGet(req, resp);
}
}

O código funciona! O Código do Cliente aciona o método doGet () a cada 3 segundos e recupera os novos dados.

Questões: No entanto, eu me perguntocomo eu posso fazer este código melhor usando novos Servlet 3.0 Futures como Async-Support ou asyncContext.addListener (asyncListener) ou qualquer outra coisa que eu não conheço. Como eu nunca fecho o fluxo, eu me perguntocomo meu servidor será dimensionado?

Teoricamente, a melhor abordagem seria acionar o método doGet () via código do lado do servidor explicitamente quando novos dados estiverem lá, então o cliente não precisa acionar o "onmessage ()" do lado do cliente - Método e, portanto, o lado do servidor "doGet ()" - Método a cada 3 segundos para novos dados.

questionAnswers(2)

yourAnswerToTheQuestion