Forráskód Böngészése

伊宁版本更新:
a.新增sse服务器代码逻辑:全局以会话id为key存储各自会话的通讯链接,心跳包以及登出指令都以当前会话id为基础单位发送指令
b.修改伊宁mainView首页,增加跳转参数clientId用以sse通讯
c.新增sse请求地址获取接口
d.增加weblog前端日志接口
e.更改伊宁逻辑,修改登录缓存逻辑
f.优化sse链接代码

1037015548@qq.com 5 napja
szülő
commit
773d258d54

+ 13 - 9
ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SseServlet.java

@@ -171,19 +171,23 @@ public class SseServlet extends BaseController {
 
     @PostMapping("/sse/weblog")
     @CrossOrigin(origins = "*") // 允许所有来源
-    protected void doGetLog(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
-        response.setContentType("text/event-stream");
-        response.setCharacterEncoding("UTF-8");
-        response.setHeader("Cache-Control", "no-cache");
-        response.setHeader("Connection", "keep-alive");
+    protected void doGetLog(HttpServletRequest request, HttpServletResponse response){
+        try {
+            response.setContentType("text/event-stream");
+            response.setCharacterEncoding("UTF-8");
+            response.setHeader("Cache-Control", "no-cache");
+            response.setHeader("Connection", "keep-alive");
 
-        String body = getJsonBodyStr(request);
-        log.info(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))+":"+body);
+            String body = getJsonBodyStr(request);
+            log.info(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + ":" + body);
+        }catch(Exception ex){
+            log.error("sse/weblog异常:"+ex.getLocalizedMessage());
+        }
     }
 
     @PostMapping("/sse/logout")
     @ResponseBody
-    protected AjaxResult logout(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+    protected AjaxResult logout(HttpServletRequest request, HttpServletResponse response){
         try {
             String body = getJsonBodyStr(request);
             JSONArray jsonArray = JSONArray.parseArray(body);
@@ -235,7 +239,7 @@ public class SseServlet extends BaseController {
 
     @GetMapping("/sse/geturl")
     @ResponseBody
-    protected AjaxResult geturl(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+    protected AjaxResult geturl(HttpServletRequest request, HttpServletResponse response){
         try {
             return AjaxResult.success().put("data",sseUrl);
         }catch(Exception ex){