|
@@ -4,10 +4,13 @@ import com.alibaba.fastjson.JSONObject;
|
|
|
import com.google.gson.Gson;
|
|
|
import com.qmth.themis.business.constant.SpringContextHolder;
|
|
|
import com.qmth.themis.business.constant.SystemConstant;
|
|
|
+import com.qmth.themis.business.dto.MqDto;
|
|
|
import com.qmth.themis.business.dto.WebsocketDto;
|
|
|
import com.qmth.themis.business.entity.TBSession;
|
|
|
-import com.qmth.themis.business.enums.SystemOperationEnum;
|
|
|
+import com.qmth.themis.business.enums.MqTagEnum;
|
|
|
+import com.qmth.themis.business.enums.MqTopicEnum;
|
|
|
import com.qmth.themis.business.enums.WebsocketTypeEnum;
|
|
|
+import com.qmth.themis.business.service.MqDtoService;
|
|
|
import com.qmth.themis.business.util.JacksonUtil;
|
|
|
import com.qmth.themis.business.util.RedisUtil;
|
|
|
import com.qmth.themis.business.util.WebsocketUtil;
|
|
@@ -18,10 +21,6 @@ import com.qmth.themis.common.signature.SignatureInfo;
|
|
|
import com.qmth.themis.common.signature.SignatureType;
|
|
|
import com.qmth.themis.exam.listener.service.MqOeLogicService;
|
|
|
import com.qmth.themis.exam.websocketTemplete.WebSocketOeMessageTemplete;
|
|
|
-import com.qmth.themis.business.dto.MqDto;
|
|
|
-import com.qmth.themis.business.enums.MqTagEnum;
|
|
|
-import com.qmth.themis.business.enums.MqTopicEnum;
|
|
|
-import com.qmth.themis.business.service.MqDtoService;
|
|
|
import com.qmth.themis.mq.templete.Concurrently;
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
|
|
@@ -114,7 +113,8 @@ public class WebSocketOeServer implements Concurrently {
|
|
|
log.info("用户连接:" + this.sessionId + ",当前在线人数为:" + getOnlineCount());
|
|
|
InetSocketAddress addr = (InetSocketAddress) WebsocketUtil.getFieldInstance(this.session.getAsyncRemote(), "base#socketWrapper#socket#sc#remoteAddress");
|
|
|
this.ip = addr.toString().replace("/", "").split(":")[0];
|
|
|
- this.sendMessage("ip[" + this.ip + "]连接成功");
|
|
|
+// this.sendMessage("ip[" + this.ip + "]连接成功");
|
|
|
+ log.info("ip[:{}]连接成功", this.ip);
|
|
|
tranMap = new HashMap<>();
|
|
|
tranMap.put("recordId", this.recordId);
|
|
|
tranMap.put("deviceId", this.deviceId);
|