| | |
| | | package com.whyc.webSocket; |
| | | |
| | | import com.whyc.config.WebSocketConfig; |
| | | import com.whyc.dto.Page; |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.dto.RtstateDto; |
| | | import com.whyc.service.A200RealstateService; |
| | | import com.whyc.service.ActmRealstateService; |
| | | import com.whyc.service.BattRtdataService; |
| | | import com.whyc.service.DevInfService; |
| | | import com.whyc.util.ActionUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.servlet.http.HttpSession; |
| | | import javax.websocket.*; |
| | | import javax.websocket.server.ServerEndpoint; |
| | | import java.util.HashMap; |
| | |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |
| | | session.getBasicRemote().sendObject(new Response().set(1, res)); |
| | | session.getBasicRemote().sendObject(res); |
| | | } |
| | | threadFlagMap.put(thread.getId(), false); |
| | | } |