From 9789c55ef944ffdbfd7b2bdaf9d2a210f6572a32 Mon Sep 17 00:00:00 2001
From: Lawrence <1934378145@qq.com>
Date: 星期三, 20 一月 2021 20:42:58 +0800
Subject: [PATCH] 增加SSE前端推送支持
---
src/main/java/com/genersoft/iot/vmp/vmanager/SEEController/SEEController.java | 32 ++++++++++++++++++++++++++++++++
1 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/SEEController/SEEController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/SEEController/SEEController.java
new file mode 100644
index 0000000..689b967
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/SEEController/SEEController.java
@@ -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;
+ }
+}
--
Gitblit v1.8.0