|
@@ -1,17 +1,13 @@
|
|
package org.jeecg.modules.largeScreen.component;
|
|
package org.jeecg.modules.largeScreen.component;
|
|
|
|
|
|
import org.jeecg.modules.itdmOpenDaping.entity.ItdmDaping;
|
|
import org.jeecg.modules.itdmOpenDaping.entity.ItdmDaping;
|
|
-import org.jeecg.modules.itdmOpenDaping.mapper.ItdmDapingMapper;
|
|
|
|
import org.jeecg.modules.largeScreen.config.CronTaskRegistrar;
|
|
import org.jeecg.modules.largeScreen.config.CronTaskRegistrar;
|
|
import org.jeecg.modules.largeScreen.task.DemoTask2;
|
|
import org.jeecg.modules.largeScreen.task.DemoTask2;
|
|
import org.jeecg.modules.largeScreen.task.SchedulingRunnable;
|
|
import org.jeecg.modules.largeScreen.task.SchedulingRunnable;
|
|
import org.jeecg.modules.largeScreen.util.EncoderClassListVo;
|
|
import org.jeecg.modules.largeScreen.util.EncoderClassListVo;
|
|
import org.jeecg.modules.largeScreen.util.SpringUtils;
|
|
import org.jeecg.modules.largeScreen.util.SpringUtils;
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
-import javax.annotation.PostConstruct;
|
|
|
|
-import javax.annotation.Resource;
|
|
|
|
import javax.websocket.*;
|
|
import javax.websocket.*;
|
|
import javax.websocket.server.ServerEndpoint;
|
|
import javax.websocket.server.ServerEndpoint;
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
@@ -28,16 +24,6 @@ import java.util.concurrent.CopyOnWriteArraySet;
|
|
@ServerEndpoint(value = "/itdmWebsocket/list2", encoders = {EncoderClassListVo.class})
|
|
@ServerEndpoint(value = "/itdmWebsocket/list2", encoders = {EncoderClassListVo.class})
|
|
public class WebSocketServer2 {
|
|
public class WebSocketServer2 {
|
|
|
|
|
|
-// @Resource
|
|
|
|
-// private ItdmDapingMapper dapingMapper;
|
|
|
|
-// @Autowired
|
|
|
|
-// public static WebSocketServer2 testUtils;
|
|
|
|
-//
|
|
|
|
-// @PostConstruct
|
|
|
|
-// public void init(){
|
|
|
|
-// testUtils = this;
|
|
|
|
-// }
|
|
|
|
-
|
|
|
|
//静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。
|
|
//静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。
|
|
private static int onlineCount = 0;
|
|
private static int onlineCount = 0;
|
|
|
|
|
|
@@ -109,10 +95,6 @@ public class WebSocketServer2 {
|
|
list.add(map);
|
|
list.add(map);
|
|
|
|
|
|
sendAll(list);
|
|
sendAll(list);
|
|
-// ItdmDaping daping = new ItdmDaping();
|
|
|
|
-// daping.setId(1);
|
|
|
|
-// daping.setDakaidaping(1);
|
|
|
|
-// testUtils.dapingMapper.updateById(daping);
|
|
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|