| | |
| | | } |
| | | } catch (Exception e) { |
| | | log.info("SN: {}-开启直播失败!原因:{}", sn, e.getMessage()); |
| | | String jsonString = getResult(sn, "开启直播失败!原因:" + e.getMessage()); |
| | | _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), jsonString); |
| | | resultLive = getResult(sn, "开启直播失败!原因:" + e.getMessage()); |
| | | // _dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), jsonString); |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | |
| | | // rlive.setType(MessageType.LIVESTREAM.getType()); |
| | | // resultLive = _objectMapper.writeValueAsString(rlive); |
| | | RedisOpsUtils.del(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn); |
| | | log.info("SN: {}-停止直播,并删除redis直播信息!", sn); |
| | | } catch (Exception e) { |
| | | log.info("SN: {}-停止直播时发生异常,原因:{}", sn,e.getMessage()); |
| | | e.printStackTrace(); |
| | | } |
| | | // 停止直播不返回数据,直接删除redis中的直播地址标记即可;并且方法在websocket连接断开后执行。 |
| | | //_dockWebSocketHandler.sendMessageToSubscribers(sn, MessageType.LIVESTREAM.getType(), resultLive); |
| | | } |
| | | |