增加SSE前端推送支持

Lawrence

2021-01-20 9789c55ef944ffdbfd7b2bdaf9d2a210f6572a32

增加SSE前端推送支持

 src/main/java/com/genersoft/iot/vmp/vmanager/SEEController/SEEController.java

New file
@@ -0,0 +1,32 @@
package com.genersoft.iot.vmp.vmanager.SEEController;

import com.genersoft.iot.vmp.gb28181.event.alarm.AlarmEventListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 * @description: SSE推送
 * @author: lawrencehj
 * @data: 2021-01-20
 */

@Controller
@RequestMapping("/api")
public class SEEController {
    @Autowired 
    AlarmEventListener alarmEventListener;
    
       //设置响应
    @RequestMapping("/emit")
    public SseEmitter emit() {
        SseEmitter sseEmitter = new SseEmitter(0L);
        try {
            alarmEventListener.addSseEmitters(sseEmitter);
        }catch (Exception e){
            sseEmitter.completeWithError(e);
        }
        return sseEmitter;
    }
}