package com.whyc.webSocket; import com.whyc.config.WebSocketConfig; import com.whyc.dto.Response; import com.whyc.dto.RtStateDto; import com.whyc.service.DevA200RtStateService; import com.whyc.service.ActmRealStateService; import com.whyc.service.BattLithiumRtDataService; import com.whyc.service.WorkStateChangeEventService; import com.whyc.util.ActionUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import javax.websocket.*; import javax.websocket.server.ServerEndpoint; import java.util.HashMap; import java.util.Map; /** * 锂电设备实时连接信息 */ @Component @ServerEndpoint(value = "/DevLithiumRtState",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class) public class DevLithiumRtStateSocket { private Session session; private Thread thread; private static BattLithiumRtDataService battLithiumRtDataService; private static DevA200RtStateService devA200RtStateService; private static ActmRealStateService actmRtStateService; private static WorkStateChangeEventService eventService; private volatile boolean runFlag = true; private volatile Map threadMap = new HashMap<>(); private volatile Map threadFlagMap = new HashMap<>(); @Autowired public void setBattRtDataService(BattLithiumRtDataService battLithiumRtDataService) { DevLithiumRtStateSocket.battLithiumRtDataService = battLithiumRtDataService; } @Autowired public void setDevA200RtStateService(DevA200RtStateService devA200RtStateService) { DevLithiumRtStateSocket.devA200RtStateService = devA200RtStateService; } @Autowired public void setActmRealStateService(ActmRealStateService actmRtStateService) { DevLithiumRtStateSocket.actmRtStateService = actmRtStateService; } @Autowired public void setWorkStateChangeEventService(WorkStateChangeEventService eventService) { DevLithiumRtStateSocket.eventService = eventService; } @OnOpen public void onOpen(Session session) { this.session = session; } @OnMessage public void onMessage(Session session, String message) { RtStateDto dto= ActionUtil.getGson().fromJson(message, RtStateDto.class); thread = new Thread("DevLithiumRtStateSocket") { @Override public void run() { while (runFlag && !isInterrupted()) { Thread thread = currentThread(); threadFlagMap.put(thread.getId(), true); Response res = new Response(); try { switch (dto.getDevType()){ case 1:res=getA200State(dto.getDevId());break; case 2:res=getActmState(dto.getDevId());break; } if (session.isOpen()) { //推送信息 synchronized (session) { session.getBasicRemote().sendObject(res); } threadFlagMap.put(thread.getId(), false); } sleep(4000); } catch (Exception e) { interrupt(); } } } }; thread.start(); threadFlagMap.put(thread.getId(),true); //停止老的socket线程 Thread threadBefore = threadMap.get(session.getId()); if(threadBefore !=null && threadBefore.isAlive()){ while (threadFlagMap.get(threadBefore.getId())){ } threadBefore.interrupt(); } //将线程存储,便于调用定位 threadMap.put(session.getId(), this.thread); } //均衡仪Actm实时数据 private Response getActmState(int devId) { Map map = new HashMap<>(); Response resActmState=actmRtStateService.getActmState(devId); Response rtDataState0= battLithiumRtDataService.getActmRtdataState(devId,0); Response rtDataState1= battLithiumRtDataService.getActmRtdataState(devId,1); Response event=eventService.getWorkEvent(devId); map.put("resActmState",resActmState); map.put("rtDataState0",rtDataState0); map.put("rtDataState1",rtDataState1); map.put("event",event); return new Response().setII(1,true,map,"均衡仪Actm实时数据"); } //一体机A200实时数据 private Response getA200State(int devId) { Map map = new HashMap<>(); Response resA200State=devA200RtStateService.getA200State(devId); Response rtDataState= battLithiumRtDataService.getA200RtDataState(devId); Response event=eventService.getWorkEvent(devId); map.put("resA200State",resA200State); map.put("rtDataState",rtDataState); map.put("event",event); return new Response().setII(1,true,map,"一体机A200实时数据"); } @OnClose public void onClose(CloseReason closeReason){ System.err.println("closeReason = " + closeReason); runFlag = false; if (thread != null && thread.isAlive()) { thread.interrupt(); } threadMap.remove(session.getId()); } @OnError public void onError(Throwable error) { error.printStackTrace(); if (thread != null && thread.isAlive()) { thread.interrupt(); } threadMap.remove(session.getId()); } }