He registrado un SSE típico cuando se carga la página:

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 />";
};
}

Mi Javascript-Debugger dice que "se abrió el código de eventos fue exitoso.

Mi código de servidor es un 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);
}
}

¡El código funciona! El Código de Cliente activa el método doGet () - cada 3 segundos y recupera los nuevos datos.

Preguntas: Sin embargo, me pregunto¿Cómo puedo hacer este código mejor? utilizando nuevos Servlet 3.0 Futures como Async-Support o asyncContext.addListener (asyncListener) o alguna otra cosa que no conozco. Como nunca cierro el arroyo, me pregunto.cómo se escalará mi servidor?

Teóricamente, el mejor enfoque sería activar el método doGet () a través del código del lado del servidor explícitamente cuando haya nuevos datos, por lo que el cliente no necesita activar el método "onmessage ()" del lado del cliente - y, por lo tanto, el lado del servidor "doGet ()" - Método cada 3 segundos para nuevos datos.