在浏览器中刷新页面时 sseEmitter 完成

Question

我正在使用 sse 发射器实现通知系统， 1-客户端调用订阅 APi，服务器创建新的 ssEmtter 并将其返回给客户端

    SseEmitter sseEmitter = new SseEmitter(24 * 60 * 60 * 1000l);

    emitterService.addEmitter(sseEmitter);

    log.info("subscribed");
    return sseEmitter;
}

2-在发布服务器中使用此 sseEmiter 并发送消息

我的问题是当我在浏览器中刷新页面时，服务器尝试发送消息我得到了这个例外 即使我在浏览器中刷新页面，我怎样才能保持 sse 发射器的连接？ java.lang.IllegalStateException：ResponseBodyEmitter 已完成 在 org.springframework.util.Assert.state(Assert.java:76) 在 org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter.send(ResponseBodyEmitter.java:196) 在 org.springframework.web.servlet.mvc.method.annotation.SseEmitter.send(SseEmitter.java:126) 在 com.efinance.service.entity.service.EmitterServiceImpl.lambda$2(EmitterServiceImpl.java:102) 在 java.base/java.util.ArrayList.forEach(ArrayList.java:1541) 在 com.efinance.service.entity.service.EmitterServiceImpl.pushNotification（EmitterServiceImpl.java:95） 在 com.efinance.service.entity.service.EmitterServiceImpl$$FastClassBySpringCGLIB$$9e4e84c6.invoke(<生成>) 在 org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) 在 org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:687) 在 com.efinance.service.entity.service.EmitterServiceImpl$$EnhancerBySpringCGLIB$$c2c5d230.pushNotification(<生成>) 在 com.efinance.service.entity.service.EntityPansUnderThresholdJob.notifyEntityPansUnderThreshold（EntityPansUnderThresholdJob.java:57） 在 jdk.internal.reflect.GenerateMethodAccessor136.invoke（来源未知） 在java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43） 在 java.base/java.lang.reflect.Method.invoke(Method.java:566) 在org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection（AopUtils.java:344） 在 org.springframework.aop.framework.ReflectiveMethodInspiration.invokeJoinpoint(ReflectiveMethodInspiration.java:198) 在 org.springframework.aop.framework.CglibAopProxy$CglibMethodInspiration.invokeJoinpoint(CglibAopProxy.java:774) 在 org.springframework.aop.framework.ReflectiveMethodInspiration.proceed(ReflectiveMethodInitation.java:163) 在 org.springframework.aop.framework.CglibAopProxy$CglibMethodInitation.proceed(CglibAopProxy.java:749) 在org.springframework.aop.aspectj.MethodInitationProceedingJoinPoint.proceed（MethodInitationProceedingJoinPoint.java：88） 在 com.efinance.service.entity.tenant.TenantAspect.lambda$0(TenantAspect.java:36) 在 java.base/java.util.LinkedHashMap.forEach(LinkedHashMap.java:684) 在 com.efinance.service.entity.tenant.TenantAspect.handelTenantNames(TenantAspect.java:29) 在 jdk.internal.reflect.GenerateMethodAccessor138.invoke（来源未知） 在java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43） 在 java.base/java.lang.reflect.Method.invoke(Method.java:566) 在org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs（AbstractAspectJAdvice.java:644） 在org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod（AbstractAspectJAdvice.java:633） 在 org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70) 在 org.springframework.aop.framework.ReflectiveMethodInspiration.proceed(ReflectiveMethodInitation.java:175) 在 org.springframework.aop.framework.CglibAopProxy$CglibMethodInitation.proceed(CglibAopProxy.java:749) 在org.springframework.aop.interceptor.ExposeInitationInterceptor.invoke（ExposeInitationInterceptor.java:95） 在 org.springframework.aop.framework.ReflectiveMethodInspiration.proceed(ReflectiveMethodInitation.java:186) 在 org.springframework.aop.framework.CglibAopProxy$CglibMethodInitation.proceed(CglibAopProxy.java:749) 在 org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:691) 在 com.efinance.service.entity.service.EntityPansUnderThresholdJob$$EnhancerBySpringCGLIB$$e85299cc.notifyEntityPansUnderThreshold(<生成>) 在 jdk.internal.reflect.GenerateMethodAccessor136.invoke（来源未知） 在java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43） 在 java.base/java.lang.reflect.Method.invoke(Method.java:566) 在org.springframework.scheduling.support.ScheduledMethodRunnable.run（ScheduledMethodRunnable.java:84） 在 org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run（DelegatingErrorHandlingRunnable.java:54） 在 java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) 在 java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) 在 java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) 在java.base / java.util.concurrent.ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java：1128） 在 java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) 在 java.base/java.lang.Thread.run(Thread.java:834)

客户端，我正在使用 Angular，

console.log('call subscripe'); const eventSource = new EventSourcePolyfill(('http://localhost:8587/subscription'), { headers: { 'Authorization': 'Bearer ' + sessionStorage.getItem("token") }, heartbeatTimeout: 1000000 });
eventSource.onopen = (e) => console.log("open");
eventSource.onmessage = (e) => { console.log(e)}
eventSource.onerror = (e) => {
  if (e.readyState == EventSource.CLOSED) {
    console.log("close");
  } else {
    console.log(e);
  }

即使我刷新浏览器中的页面，如何保持 sse 发射器的连接？

Answer 1

当你刷新时。您必须再次订阅您的客户端。

这将在后端创建一个新的 SseEmitter。然后当你想从后端发送新数据时发送到所有相关的SseEmitters。

一个会成功，其他将从后端发送失败（因为刷新破坏了前端的旧 eventSource 侦听器）。从发射器服务中删除那些失败的。