Explorar el Código

完成监听接口

tsurumure hace 10 meses
padre
commit
f5ef5eb732

+ 4 - 0
README.md

@@ -49,6 +49,10 @@ tail -f backendsys.log
 
 ### 开发指南
 
+监听控制台消息 (单点)
+```
+http://xxxx.com/api/log/stream/watch?sign={配置文件固定密钥}
+```
 #### 自定义工具类
 
 ###### SecurityUtil

+ 22 - 1
configuration/nginx/ai.api.conf

@@ -3,7 +3,6 @@ server {
     server_name     ai.api.daoguyujia.com;
 
     location / {
-
         # # 允许跨域
         # add_header Access-Control-Allow-Origin * always;
         # add_header Access-Control-Allow-Headers * always;
@@ -21,8 +20,19 @@ server {
         # proxy_set_header Host $proxy_host;
         # proxy_set_header X-Real-IP $remote_addr;
         # proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+    }
 
+    location /sqx_fast/sse/stream {
+        proxy_pass http://127.0.0.1:48080/api/log/stream/watch;
+        proxy_http_version 1.1;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection "upgrade";
+        # 以下设置确保SSE正常工作
+        proxy_buffering off;                # 关闭缓冲,确保数据实时发送
+        proxy_cache off;                    # 关闭代理缓存
+        proxy_set_header Connection "";     # 清除原有的Connection头,避免影响
     }
+
 }
 
 # server {
@@ -53,4 +63,15 @@ server {
 #         proxy_redirect off;
 #     }
 
+#     location /sqx_fast/sse/stream {
+#         proxy_pass http://127.0.0.1:48080/api/log/stream/watch;
+#         proxy_http_version 1.1;
+#         proxy_set_header Upgrade $http_upgrade;
+#         proxy_set_header Connection "upgrade";
+#         # 以下设置确保SSE正常工作
+#         proxy_buffering off;                # 关闭缓冲,确保数据实时发送
+#         proxy_cache off;                    # 关闭代理缓存
+#         proxy_set_header Connection "";     # 清除原有的Connection头,避免影响
+#     }
+
 # }

+ 1 - 1
src/main/java/com/backendsys/modules/common/config/security/AnonymousProperties.java

@@ -68,7 +68,7 @@ public class AnonymousProperties implements InitializingBean, ApplicationContext
                 Pattern regex = Pattern.compile("\\[(.*?)\\]");
                 String url = ReUtil.getGroup1(regex, info.toString());
                 if (StrUtil.isNotEmpty(url)) {
-                    System.out.println("(@Anonymous) url: " + url);
+                    // System.out.println("(@Anonymous) url: " + url);
                     urls.add(url);
                 }
 

+ 2 - 2
src/main/resources/application-local.yml

@@ -14,8 +14,8 @@ HTTP_ACTUATOR_URI: https://jsonplaceholder.typicode.com
 log-stream:
   sign: 97e3ef8e-a8b9-46f3-b63a-f0504154efb7
   enable: true
-  charset: GBK
-  exec: 'ping 127.0.0.1'
+  charset: UTF-8 # GBK
+  exec: 'powershell -Command "Get-Content -Path D:\CodeJava\QuickLaunchSpring\BackendSys\logs\backendsys.log -Wait"'
 
 spring:
   config: