我在页面加载时注册了一个典型的SSE:
客户端:
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 />";
};
}
我的 JavaScript 调试器显示 "eventsource opened!" 已成功。
我的服务器代码是一个 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);
}
}
代码可以工作!客户端代码每3秒触发doGet()方法并检索新数据。
问题:但是,我想知道如何通过使用新的Servlet 3.0 Futures(例如async-support或asyncContext.addListener(asyncListener)等)使这段代码更好?由于我从未关闭流,所以我想知道我的服务器将如何扩展?
理论上,最好的方法是在有新数据时通过服务器端代码显式地触发doGet()方法,这样客户端就不需要每3秒触发客户端端的"onmessage()"方法和服务器端的"doGet()"方法来获取新数据了。