1、完成ws发送

src/main/java/cn/clevercsc/niuniutool/service/NiuniuService.java

@@ -7,10 +7,13 @@ import cn.clevercsc.niuniutool.dto.UserInfoDto;
 import cn.clevercsc.niuniutool.util.ConnectUtils;
 import cn.clevercsc.niuniutool.util.DateUtils;
 import cn.clevercsc.niuniutool.util.HttpResult;
+import cn.clevercsc.niuniutool.ws.DashboardWs;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.jsoup.Connection;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
@@ -30,6 +33,9 @@ import java.util.Map;
 @Slf4j
 public class NiuniuService {
 
+    @Autowired
+    private DashboardWs dashboardWs;
+
     public String accessToken;
 
     public PinTuanDto lastPintuanDto;
@@ -125,4 +131,9 @@ public class NiuniuService {
             dashboardDto.setChange(pinTuanDto.getAlready_pinzhong()-lastPintuanDto.getAlready_pinzhong());
         }
     }
+
+    @Scheduled(cron = "0/5 * * * * ? ")
+    public void sendDashboardWs() {
+        dashboardWs.send(JSONObject.toJSONString(dashboardDto, SerializerFeature.DisableCircularReferenceDetect));
+    }
 }

src/main/java/cn/clevercsc/niuniutool/ws/DashboardWs.java

@@ -18,11 +18,11 @@ import java.io.IOException;
 @Component
 @ServerEndpoint("/ws/dashboard")
 public class DashboardWs {
+    Session session;
 
     @OnOpen
     public void onOpen(Session session) {
-
-
+        this.session = session;
     }
 
     @OnClose
@@ -30,7 +30,7 @@ public class DashboardWs {
         session.close();
     }
 
-    public static void send(Session session, String data) {
+    public  void send(String data) {
         try {
             if (session.isOpen()) {
                 session.getAsyncRemote().sendText(data);

src/main/resources/application.properties

@@ -6,7 +6,7 @@ management.endpoints.jmx.exposure.include=*
 management.endpoints.web.exposure.include=*
 management.endpoint.health.show-details=always
 # \u5E94\u7528\u670D\u52A1 WEB \u8BBF\u95EE\u7AEF\u53E3
-server.port=8080
+server.port=8082
 
 logging.config=classpath:logback-spring.xml
 #\u6B64\u5904\u7684\u914D\u7F6E\u5E94\u5728\u8FD0\u884C\u65F6\u7531\u547D\u4EE4\u884C\u6307\u5B9A\uFF0C\u5982\uFF1Anohup java -jar /mnt/ground_system/scheduler/$type/scheduler_master.jar --logback.loghome=/mnt/ground_system/scheduler/$type/servant.$i --logback.logprefix = servant.$i