Spring Boot中的SSE与缓存集成：使用Redis加速事件推送

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
@RestController
public class SseController {
 
    private final StringRedisTemplate redisTemplate;
 
    @Autowired
    public SseController(StringRedisTemplate redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
 
    @GetMapping(path = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public SseEmitter stream() {
        SseEmitter emitter = new SseEmitter();
 
        // 在新线程中运行以避免阻塞主线程
        new Thread(() -> {
            try {
                ValueOperations<String, String> ops = redisTemplate.opsForValue();
                while (!emitter.isComplete()) {
                    // 假设事件的键是固定的
                    String eventKey = "latestEvent";
                    String data = ops.get(eventKey);
                    if (data != null) {
                        emitter.send(SseEmitter.event().data(data));
                        // 取得数据后从Redis删除，或设置过期时间
                        ops.delete(eventKey);
                    }
                    // 可以使用Redis的发布/订阅功能或其他机制来触发获取数据
                    Thread.sleep(500); // 模拟等待事件触发
                }
            } catch (Exception e) {
                emitter.completeWithError(e);
            }
        }).start();
 
        return emitter;
    }
}

这段代码示例展示了如何在Spring Boot应用中使用SseEmitter和Redis来实现一个简单的服务端发送事件（SSE）系统。在这个例子中，我们假设每个事件都有一个Redis键与之对应，并且我们通过轮询Redis来检查新的事件。当事件到达时，它会被发送给客户端，并从Redis中删除或设置过期时间。这种方式可以减少服务器负载，并允许客户端以流的形式接收更新。