无法使用 SSE 发送消息（Java Servlet + ES6 JS）

Question

我试图在这个视频https://www.youtube.com/watch?v=rhCKCKD0KnA中做一个 SSE 的例子

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

    PrintWriter printWriter = null;

    while(true) {

        try {
            double rnd = Math.random() * 10000;

            printWriter = response.getWriter();
            printWriter.print("Rnd: " + rnd);

            response.flushBuffer();


            Thread.sleep(5000);

        }
        catch(IOException | InterruptedException e) {
            e.printStackTrace();

            printWriter.close();

            break;
        }


    }

和客户端

    window.onload = function () {

        startButton.onclick = () => {
            eventSource = new EventSource('http://localhost:8080/byteslounge-1/sse_test');

            eventSource.onopen = () => {
                displayTextArea.value += 'connected...' + '\n';
            };

            eventSource.onmessage = (message) => {
                displayTextArea.value += message.data + '\n\n';
            };

            eventSource.onerror = () => {
                displayTextArea.value += 'error occured...' + '\n';
            };

            startButton.disabled = true;
        };

        takeMsg.onclick = () => {
            eventSource.onmessage = (message) => {
                displayTextArea.value += message.data + '\n\n';
            };
        };

        stopButton.onclick = () => {
            eventSource.close();
            startButton.disabled = false;
        };

        clearText.onclick = () => {
            displayTextArea.value = '';
        }

    }

连接正常，但无法接收 onMessage 中的任何数据。服务器/客户端上没有错误/警告。我正在使用 FF 64 位最新版本/JDK 1.8/Payara。

Answer 1

我在您的代码中没有发现任何明显的问题。但是，在使用 Payara 5 时，我建议使用 JAX-RS SSE API 而不是自己在 servlet 中编写代码。

在此处查看示例和指南：http://ridingthecrest.com/blog/2017/02/22/jax-rs-2_1-new-feature-introduction.html

使用 JAX-RS SSE 替代您的服务器端点：

@Path("server-sent-events")
@Singleton
public class ServerSentEventsResource {

    @GET
    @Produces(MediaType.SERVER_SENT_EVENTS)
    public void getMessageQueue(@Context SseEventSink eventSink, @Context Sse sse) {

      while(true) {

        try {
            double rnd = Math.random() * 10000;

            eventSink.send(sse.newEvent("custom-message"));

            Thread.sleep(5000);

        }
        catch(IOException | InterruptedException e) {
            e.printStackTrace();

            printWriter.close();

            break;
        }
      }
    }
}

还可以使用通用 SSE 客户端测试服务器端点，例如curl 支持 SSE 并在传入事件发生时打印它们。如果可行，那么您的 javascript 客户端有错误。