| | |
| | | // 与某个客户端的连接会话,需要通过它来给客户端发送数据 |
| | | private Session session; |
| | | |
| | | private String orgId; |
| | | |
| | | private String accountId; |
| | | |
| | | |
| | | private Connection connection; |
| | | |
| | | private Channel channel; |
| | |
| | | this.session = session; |
| | | //这个一定要写,第一次很容易忽略! |
| | | webSocketSet.add(this); |
| | | //取参 |
| | | String[] flag=param.split("&"); |
| | | |
| | | String orgId = flag[0]; |
| | | String accountId = flag[1]; |
| | | String monitPointId = flag[2]; |
| | | String p=flag[3]; |
| | | |
| | | String QUEUE_NAME = "deviceData_" + accountId; |
| | | Map<String, Object> paramMap = new HashMap<String, Object>(); |
| | | List<Device> deviceList = deviceService.getDeviceById2(Integer.parseInt(monitPointId)); |
| | |
| | | |
| | | @OnClose |
| | | public void onClose() { |
| | | |
| | | //**从安全Set中 移除当前连接对象*//**//**//**//**//**//**//**//* |
| | | |
| | | webSocketSet.remove(this); |
| | | try { |
| | | connection.close(); |