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