| | |
|---|
| | | |
|---|
| | | if (clientMap.containsKey(socketEntity.getCurrent())){ |
|---|
| | | client.sendEvent("connectError",R.fail("连接已存在")); |
|---|
| | | log.info("设备{}连接失败",socketEntity.getCurrent()); |
|---|
| | | log.info("设备{}连接已存在",socketEntity.getCurrent()); |
|---|
| | | }else { |
|---|
| | | clientMap.put(socketEntity.getCurrent(),client); |
|---|
| | | client.sendEvent("connectOk",R.success("连接成功")); |
|---|
| | |
|---|
| | | public void OnEvent(SocketIOClient client) { |
|---|
| | | String connectInfo = client.getHandshakeData().getSingleUrlParam("connectInfo"); |
|---|
| | | SocketEntity socketEntity = parseMsg(connectInfo); |
|---|
| | | //保证断连只会断连自己，不会断连其他客户端 |
|---|
| | | clientMap.forEach((key,value)->{ |
|---|
| | | if (value.getSessionId().equals(client.getSessionId())){ |
|---|
| | | clientMap.remove(key); |
|---|
