Java Springboot SSE 解决永久存活 判断客户端离线问题

在Spring Boot中使用SSE（Server-Sent Events）时，可以通过HttpServletRequest来判断客户端是否已经断开连接，以此来处理客户端的离线情况。

以下是一个简单的示例，展示了如何在Spring Boot控制器中使用SSE来解决客户端离线问题：

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
 
@RestController
public class SseController {
 
    @GetMapping(path = "/sse-connection", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public SseEmitter handleSse(HttpServletRequest request) {
        SseEmitter emitter = new SseEmitter();
 
        // 在新线程中运行以避免阻塞主线程
        new Thread(() -> {
            try {
                // 模拟发送数据的逻辑
                while (!emitter.isComplete() && !request.getHttpSession().isNew()) {
                    // 检查客户端是否断开连接
                    if (emitter.isComplete() || !isClientConnected(request)) {
                        break;
                    }
                    // 发送一个事件
                    emitter.send("data: " + System.currentTimeMillis() + "\n\n");
                    Thread.sleep(1000); // 每秒发送一次
                }
                // 客户端断开或会话过期
                emitter.complete();
            } catch (IOException | InterruptedException e) {
                // 处理异常
                emitter.completeWithError(e);
            }
        }).start();
 
        return emitter;
    }
 
    private boolean isClientConnected(HttpServletRequest request) {
        // 检查客户端是否断开连接的逻辑
        // 例如，可以检查servlet容器的isAsyncSupported或是否有特定的Http状态码
        return true; // 假设总是连接状态
    }
}

在这个示例中，我们创建了一个新的线程来模拟一个持续的数据流。在这个线程中，我们定期检查客户端是否仍然连接（通过调用isClientConnected方法）。如果客户端断开连接，我们通过调用emitter.complete()来结束事件流的发送。

请注意，实际的isClientConnected方法的实现可能会根据你的具体需求和环境有所不同。在某些情况下，你可能需要依赖特定的HTTP状态码或者其他方式来判断客户端是否已经断开连接。