增加SSE前端推送支持
This commit is contained in:
parent
1488b50c1d
commit
ea787fdcba
@ -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;
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user