html5-Spring SSEEmitter中途完成

我是服务器发送事件的新手,但不是Spring的新手.
已经制作了一个控制器,该控制器从启动SSEEmitter的UI上的按钮触发,并将其传递给另一个线程,该线程在每4秒后循环向UI发送消息.
到目前为止,我正在运行10个循环,每个循环睡眠4秒,但突然在第6或第7个循环的迭代附近,出现异常“线程“ Thread-4”中的异常java.lang.IllegalStateException：ResponseBodyEmitter已设置为完成”. .

因此,事件源再次重新建立连接,即再次调用控制器方法,这当然是我所不希望的.

我在这里尝试一件简单的事情.用户通过单击按钮进行订阅.
服务器无论何时都向浏览器发送响应10或20.就我而言,这就是上证所为之创造的.

代码如下：

@RequestMapping("/subscribe")
public SseEmitter subscribe() {
    SseEmitter sseEmitter = new SseEmitter();
    try {
        sseEmitter.send("Dapinder");
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    Runnable r = new AnotherThread(sseEmitter);
    new Thread(r).start();
    return sseEmitter;
}

公共类AnotherThread实现Runnable {

private SseEmitter sseEmitter;

public AnotherThread(SseEmitter sseEmitter) {
    super();
    this.sseEmitter = sseEmitter;
}

@Override
public void run() {
    SseEventBuilder builder = SseEmitter.event();
    builder.name("dapEvent");
    for (int i = 0; i < 10; i++) {
        builder.data("This is the data: " + i +" time.");
        try {
            //sseEmitter.send(builder);
            sseEmitter.send("Data: "+i);
            //sseEmitters.get(1L).send("Hello");
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            Thread.sleep(4000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    sseEmitter.complete();
}

public SseEmitter getSseEmitter() {
    return sseEmitter;
}

public void setSseEmitter(SseEmitter sseEmitter) {
    this.sseEmitter = sseEmitter;
}

}

function start() {
    var eventSource = new EventSource("http://localhost:8080/HTML5SSE/springSSE/subscribe"); //  /springSSE/connect
      eventSource.onmessage = function(event) {
        document.getElementById('foo').innerHTML = event.data;
    };

}


<button onclick="start()">Subscribe</button>

解决方法:

您的构建器未被使用；您创建并配置了构建器,但是随后直接使用“ sseEmitter.send”发送了一条简单消息.尝试这个：

sseEmitter.send(SseEmitter.event().name("dapEvent").data("This " + i +" time.");

还有一件事：为什么在subscribe方法中已经调用了send方法？此时,尚未返回SseEmitter.此消息是否传递给客户端？

这是一个excellent article,从JavaScript角度(不是Spring)说明了SSE.您将在此处看到可以通过调用流上的close从客户端取消事件流.将此与事件侦听器结合使用,您应该拥有所需的内容：

var source = new EventSource('...');
source.addEventListener('error', function(e) {
  if (e.currentTarget.readyState == EventSource.CLOSED) {
    // Connection was closed.
  } else {
    // Close it yourself
    source.close();
  }
});
source.addEventListener('message', function(e) {
  console.log(e.data);
});

注意：文章说e.readyState,但是我认为这是错误的.接收到的对象e是事件.您需要像这样从其中获取EventSource对象：e.currentTarget.

标签：server-sent-events,html5,spring,spring-mvc
来源： https://codeday.me/bug/20191118/2031475.html