| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743 | package com.genersoft.iot.vmp.service.impl;import com.alibaba.fastjson2.JSON;import com.alibaba.fastjson2.JSONArray;import com.alibaba.fastjson2.JSONObject;import com.genersoft.iot.vmp.common.CommonCallback;import com.genersoft.iot.vmp.common.VideoManagerConstants;import com.genersoft.iot.vmp.conf.DynamicTask;import com.genersoft.iot.vmp.conf.SipConfig;import com.genersoft.iot.vmp.conf.UserSetting;import com.genersoft.iot.vmp.conf.exception.ControllerException;import com.genersoft.iot.vmp.gb28181.event.EventPublisher;import com.genersoft.iot.vmp.gb28181.session.SSRCFactory;import com.genersoft.iot.vmp.media.zlm.AssistRESTfulUtils;import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils;import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig;import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;import com.genersoft.iot.vmp.media.zlm.dto.ServerKeepaliveData;import com.genersoft.iot.vmp.service.IMediaServerService;import com.genersoft.iot.vmp.service.bean.MediaServerLoad;import com.genersoft.iot.vmp.service.bean.SSRCInfo;import com.genersoft.iot.vmp.storager.IRedisCatchStorage;import com.genersoft.iot.vmp.storager.dao.MediaServerMapper;import com.genersoft.iot.vmp.utils.DateUtil;import com.genersoft.iot.vmp.utils.JsonUtil;import com.genersoft.iot.vmp.utils.redis.RedisUtil;import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;import okhttp3.OkHttpClient;import okhttp3.Request;import okhttp3.Response;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.jdbc.datasource.DataSourceTransactionManager;import org.springframework.stereotype.Service;import org.springframework.transaction.TransactionDefinition;import org.springframework.transaction.TransactionStatus;import org.springframework.util.ObjectUtils;import java.io.File;import java.time.LocalDateTime;import java.util.*;/** * 媒体服务器节点管理 */@Servicepublic class MediaServerServiceImpl implements IMediaServerService {    private final static Logger logger = LoggerFactory.getLogger(MediaServerServiceImpl.class);    private final String zlmKeepaliveKeyPrefix = "zlm-keepalive_";    @Autowired    private SipConfig sipConfig;    @Autowired    private SSRCFactory ssrcFactory;    @Value("${server.ssl.enabled:false}")    private boolean sslEnabled;    @Value("${server.port}")    private Integer serverPort;    @Autowired    private UserSetting userSetting;    @Autowired    private AssistRESTfulUtils assistRESTfulUtils;    @Autowired    private ZLMRESTfulUtils zlmresTfulUtils;    @Autowired    private MediaServerMapper mediaServerMapper;    @Autowired    private DataSourceTransactionManager dataSourceTransactionManager;    @Autowired    private TransactionDefinition transactionDefinition;    @Autowired    private ZLMRTPServerFactory zlmrtpServerFactory;    @Autowired    private EventPublisher publisher;    @Autowired    private DynamicTask dynamicTask;    @Autowired    private IRedisCatchStorage redisCatchStorage;    @Autowired    private RedisTemplate<Object, Object> redisTemplate;    /**     * 初始化     */    @Override    public void updateVmServer(List<MediaServerItem>  mediaServerItemList) {        logger.info("[zlm] 缓存初始化 ");        for (MediaServerItem mediaServerItem : mediaServerItemList) {            if (ObjectUtils.isEmpty(mediaServerItem.getId())) {                continue;            }            // 更新            if (ssrcFactory.hasMediaServerSSRC(mediaServerItem.getId())) {                ssrcFactory.initMediaServerSSRC(mediaServerItem.getId(), null);            }            // 查询redis是否存在此mediaServer            String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + mediaServerItem.getId();            Boolean hasKey = redisTemplate.hasKey(key);            if (hasKey != null && ! hasKey) {                redisTemplate.opsForValue().set(key, mediaServerItem);            }        }    }    @Override    public SSRCInfo openRTPServer(MediaServerItem mediaServerItem, String streamId, String presetSsrc, boolean ssrcCheck,                                  boolean isPlayback, Integer port, Boolean reUsePort, Integer tcpMode) {        if (mediaServerItem == null || mediaServerItem.getId() == null) {            logger.info("[openRTPServer] 失败, mediaServerItem == null || mediaServerItem.getId() == null");            return null;        }        // 获取mediaServer可用的ssrc        String ssrc;        if (presetSsrc != null) {            ssrc = presetSsrc;        }else {            if (isPlayback) {                ssrc = ssrcFactory.getPlayBackSsrc(mediaServerItem.getId());            }else {                ssrc = ssrcFactory.getPlaySsrc(mediaServerItem.getId());            }        }        if (streamId == null) {            streamId = String.format("%08x", Integer.parseInt(ssrc)).toUpperCase();        }        int rtpServerPort;        if (mediaServerItem.isRtpEnable()) {            rtpServerPort = zlmrtpServerFactory.createRTPServer(mediaServerItem, streamId, ssrcCheck?Integer.parseInt(ssrc):0, port, reUsePort, tcpMode);        } else {            rtpServerPort = mediaServerItem.getRtpProxyPort();        }        return new SSRCInfo(rtpServerPort, ssrc, streamId);    }    @Override    public void closeRTPServer(MediaServerItem mediaServerItem, String streamId) {        if (mediaServerItem == null) {            return;        }        zlmrtpServerFactory.closeRtpServer(mediaServerItem, streamId);    }    @Override    public void closeRTPServer(MediaServerItem mediaServerItem, String streamId, CommonCallback<Boolean> callback) {        if (mediaServerItem == null) {            callback.run(false);            return;        }        zlmrtpServerFactory.closeRtpServer(mediaServerItem, streamId, callback);    }    @Override    public void closeRTPServer(String mediaServerId, String streamId) {        MediaServerItem mediaServerItem = this.getOne(mediaServerId);        closeRTPServer(mediaServerItem, streamId);    }    @Override    public Boolean updateRtpServerSSRC(MediaServerItem mediaServerItem, String streamId, String ssrc) {        return zlmrtpServerFactory.updateRtpServerSSRC(mediaServerItem, streamId, ssrc);    }    @Override    public void releaseSsrc(String mediaServerItemId, String ssrc) {        MediaServerItem mediaServerItem = getOne(mediaServerItemId);        if (mediaServerItem == null || ssrc == null) {            return;        }        ssrcFactory.releaseSsrc(mediaServerItemId, ssrc);    }    /**     * zlm 重启后重置他的推流信息, TODO 给正在使用的设备发送停止命令     */    @Override    public void clearRTPServer(MediaServerItem mediaServerItem) {        ssrcFactory.reset(mediaServerItem.getId());    }    @Override    public void update(MediaServerItem mediaSerItem) {        mediaServerMapper.update(mediaSerItem);        MediaServerItem mediaServerItemInRedis = getOne(mediaSerItem.getId());        MediaServerItem mediaServerItemInDataBase = mediaServerMapper.queryOne(mediaSerItem.getId());        if (mediaServerItemInRedis == null || ssrcFactory.hasMediaServerSSRC(mediaSerItem.getId())) {            ssrcFactory.initMediaServerSSRC(mediaServerItemInDataBase.getId(),null);        }        String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + mediaServerItemInDataBase.getId();        redisTemplate.opsForValue().set(key, mediaServerItemInDataBase);    }    @Override    public List<MediaServerItem> getAll() {        List<MediaServerItem> result = new ArrayList<>();        List<Object> mediaServerKeys = RedisUtil.scan(redisTemplate, String.format("%S*", VideoManagerConstants.MEDIA_SERVER_PREFIX+ userSetting.getServerId() + "_" ));        String onlineKey = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        for (Object mediaServerKey : mediaServerKeys) {            String key = (String) mediaServerKey;            MediaServerItem mediaServerItem = JsonUtil.redisJsonToObject(redisTemplate, key, MediaServerItem.class);            if (Objects.isNull(mediaServerItem)) {                continue;            }            // 检查状态            Double aDouble = redisTemplate.opsForZSet().score(onlineKey, mediaServerItem.getId());            if (aDouble != null) {                mediaServerItem.setStatus(true);            }            result.add(mediaServerItem);        }        result.sort((serverItem1, serverItem2)->{            int sortResult = 0;            LocalDateTime localDateTime1 = LocalDateTime.parse(serverItem1.getCreateTime(), DateUtil.formatter);            LocalDateTime localDateTime2 = LocalDateTime.parse(serverItem2.getCreateTime(), DateUtil.formatter);            sortResult = localDateTime1.compareTo(localDateTime2);            return  sortResult;        });        return result;    }    @Override    public List<MediaServerItem> getAllFromDatabase() {        return mediaServerMapper.queryAll();    }    @Override    public List<MediaServerItem> getAllOnline() {        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        Set<Object> mediaServerIdSet = redisTemplate.opsForZSet().reverseRange(key, 0, -1);        List<MediaServerItem> result = new ArrayList<>();        if (mediaServerIdSet != null && mediaServerIdSet.size() > 0) {            for (Object mediaServerId : mediaServerIdSet) {                String mediaServerIdStr = (String) mediaServerId;                String serverKey = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + mediaServerIdStr;                result.add((MediaServerItem) redisTemplate.opsForValue().get(serverKey));            }        }        Collections.reverse(result);        return result;    }    /**     * 获取单个zlm服务器     * @param mediaServerId 服务id     * @return MediaServerItem     */    @Override    public MediaServerItem getOne(String mediaServerId) {        if (mediaServerId == null) {            return null;        }        String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + mediaServerId;        return JsonUtil.redisJsonToObject(redisTemplate, key, MediaServerItem.class);    }    @Override    public MediaServerItem getDefaultMediaServer() {        return mediaServerMapper.queryDefault();    }    @Override    public void clearMediaServerForOnline() {        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        redisTemplate.delete(key);    }    @Override    public void add(MediaServerItem mediaServerItem) {        mediaServerItem.setCreateTime(DateUtil.getNow());        mediaServerItem.setUpdateTime(DateUtil.getNow());        mediaServerItem.setHookAliveInterval(30f);        JSONObject responseJSON = zlmresTfulUtils.getMediaServerConfig(mediaServerItem);        if (responseJSON != null) {            JSONArray data = responseJSON.getJSONArray("data");            if (data != null && data.size() > 0) {                ZLMServerConfig zlmServerConfig= JSON.parseObject(JSON.toJSONString(data.get(0)), ZLMServerConfig.class);                if (mediaServerMapper.queryOne(zlmServerConfig.getGeneralMediaServerId()) != null) {                    throw new ControllerException(ErrorCode.ERROR100.getCode(),"保存失败,媒体服务ID [ " + zlmServerConfig.getGeneralMediaServerId() + " ] 已存在,请修改媒体服务器配置");                }                mediaServerItem.setId(zlmServerConfig.getGeneralMediaServerId());                zlmServerConfig.setIp(mediaServerItem.getIp());                mediaServerMapper.add(mediaServerItem);                zlmServerOnline(zlmServerConfig);            }else {                throw new ControllerException(ErrorCode.ERROR100.getCode(),"连接失败");            }        }else {            throw new ControllerException(ErrorCode.ERROR100.getCode(),"连接失败");        }    }    @Override    public int addToDatabase(MediaServerItem mediaSerItem) {        return mediaServerMapper.add(mediaSerItem);    }    @Override    public int updateToDatabase(MediaServerItem mediaSerItem) {        int result = 0;        if (mediaSerItem.isDefaultServer()) {            TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);            int delResult = mediaServerMapper.delDefault();            if (delResult == 0) {                logger.error("移除数据库默认zlm节点失败");                //事务回滚                dataSourceTransactionManager.rollback(transactionStatus);                return 0;            }            result = mediaServerMapper.add(mediaSerItem);            dataSourceTransactionManager.commit(transactionStatus);     //手动提交        }else {            result = mediaServerMapper.update(mediaSerItem);        }        return result;    }    /**     * 处理zlm上线     * @param zlmServerConfig zlm上线携带的参数     */    @Override    public void zlmServerOnline(ZLMServerConfig zlmServerConfig) {        MediaServerItem serverItem = mediaServerMapper.queryOne(zlmServerConfig.getGeneralMediaServerId());        if (serverItem == null) {            logger.warn("[未注册的zlm] 拒接接入:{}来自{}:{}", zlmServerConfig.getGeneralMediaServerId(), zlmServerConfig.getIp(),zlmServerConfig.getHttpPort() );            logger.warn("请检查ZLM的<general.mediaServerId>配置是否与WVP的<media.id>一致");            return;        }else {            logger.info("[ZLM] 正在连接 : {} -> {}:{}",                    zlmServerConfig.getGeneralMediaServerId(), zlmServerConfig.getIp(), zlmServerConfig.getHttpPort());        }        serverItem.setHookAliveInterval(zlmServerConfig.getHookAliveInterval());        if (serverItem.getHttpPort() == 0) {            serverItem.setHttpPort(zlmServerConfig.getHttpPort());        }        if (serverItem.getHttpSSlPort() == 0) {            serverItem.setHttpSSlPort(zlmServerConfig.getHttpSSLport());        }        if (serverItem.getRtmpPort() == 0) {            serverItem.setRtmpPort(zlmServerConfig.getRtmpPort());        }        if (serverItem.getRtmpSSlPort() == 0) {            serverItem.setRtmpSSlPort(zlmServerConfig.getRtmpSslPort());        }        if (serverItem.getRtspPort() == 0) {            serverItem.setRtspPort(zlmServerConfig.getRtspPort());        }        if (serverItem.getRtspSSLPort() == 0) {            serverItem.setRtspSSLPort(zlmServerConfig.getRtspSSlport());        }        if (serverItem.getRtpProxyPort() == 0) {            serverItem.setRtpProxyPort(zlmServerConfig.getRtpProxyPort());        }        serverItem.setStatus(true);        if (ObjectUtils.isEmpty(serverItem.getId())) {            logger.warn("[未注册的zlm] serverItem缺少ID, 无法接入:{}:{}", zlmServerConfig.getIp(),zlmServerConfig.getHttpPort() );            return;        }        mediaServerMapper.update(serverItem);        String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + zlmServerConfig.getGeneralMediaServerId();        if (ssrcFactory.hasMediaServerSSRC(serverItem.getId())) {            ssrcFactory.initMediaServerSSRC(zlmServerConfig.getGeneralMediaServerId(), null);        }        redisTemplate.opsForValue().set(key, serverItem);        resetOnlineServerItem(serverItem);        if (serverItem.isAutoConfig()) {            // 查看assist服务的录像路径配置            if (serverItem.getRecordAssistPort() > 0 && userSetting.getRecordPath() == null) {                JSONObject info = assistRESTfulUtils.getInfo(serverItem, null);                if (info != null && info.getInteger("code") != null && info.getInteger("code") == 0 ) {                    JSONObject dataJson = info.getJSONObject("data");                    if (dataJson != null) {                        String recordPath = dataJson.getString("record");                        userSetting.setRecordPath(recordPath);                    }                }            }            setZLMConfig(serverItem, "0".equals(zlmServerConfig.getHookEnable()));        }        final String zlmKeepaliveKey = zlmKeepaliveKeyPrefix + serverItem.getId();        dynamicTask.stop(zlmKeepaliveKey);        dynamicTask.startDelay(zlmKeepaliveKey, new KeepAliveTimeoutRunnable(serverItem), (Math.getExponent(serverItem.getHookAliveInterval()) + 5) * 1000);        publisher.zlmOnlineEventPublish(serverItem.getId());        logger.info("[ZLM] 连接成功 {} - {}:{} ",                zlmServerConfig.getGeneralMediaServerId(), zlmServerConfig.getIp(), zlmServerConfig.getHttpPort());    }    class KeepAliveTimeoutRunnable implements Runnable{        private MediaServerItem serverItem;        public KeepAliveTimeoutRunnable(MediaServerItem serverItem) {            this.serverItem = serverItem;        }        @Override        public void run() {            logger.info("[zlm心跳到期]:" + serverItem.getId());            // 发起http请求验证zlm是否确实无法连接,如果确实无法连接则发送离线事件,否则不作处理            JSONObject mediaServerConfig = zlmresTfulUtils.getMediaServerConfig(serverItem);            if (mediaServerConfig != null && mediaServerConfig.getInteger("code") == 0) {                logger.info("[zlm心跳到期]:{}验证后zlm仍在线,恢复心跳信息,请检查zlm是否可以正常向wvp发送心跳", serverItem.getId());                // 添加zlm信息                updateMediaServerKeepalive(serverItem.getId(), null);            }else {                publisher.zlmOfflineEventPublish(serverItem.getId());            }        }    }    @Override    public void zlmServerOffline(String mediaServerId) {        delete(mediaServerId);        final String zlmKeepaliveKey = zlmKeepaliveKeyPrefix + mediaServerId;        dynamicTask.stop(zlmKeepaliveKey);    }    @Override    public void resetOnlineServerItem(MediaServerItem serverItem) {        // 更新缓存        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        // 使用zset的分数作为当前并发量, 默认值设置为0        if (redisTemplate.opsForZSet().score(key, serverItem.getId()) == null) {  // 不存在则设置默认值 已存在则重置            redisTemplate.opsForZSet().add(key, serverItem.getId(), 0L);            // 查询服务流数量            zlmresTfulUtils.getMediaList(serverItem, null, null, "rtsp",(mediaList ->{                Integer code = mediaList.getInteger("code");                if (code == 0) {                    JSONArray data = mediaList.getJSONArray("data");                    if (data != null) {                        redisTemplate.opsForZSet().add(key, serverItem.getId(), data.size());                    }                }            }));        }else {            clearRTPServer(serverItem);        }    }    @Override    public void addCount(String mediaServerId) {        if (mediaServerId == null) {            return;        }        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        redisTemplate.opsForZSet().incrementScore(key, mediaServerId, 1);    }    @Override    public void removeCount(String mediaServerId) {        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        redisTemplate.opsForZSet().incrementScore(key, mediaServerId, - 1);    }    /**     * 获取负载最低的节点     * @return MediaServerItem     */    @Override    public MediaServerItem getMediaServerForMinimumLoad(Boolean hasAssist) {        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId();        Long size = redisTemplate.opsForZSet().zCard(key);        if (size  == null || size == 0) {            logger.info("获取负载最低的节点时无在线节点");            return null;        }        // 获取分数最低的,及并发最低的        Set<Object> objects = redisTemplate.opsForZSet().range(key, 0, -1);        ArrayList<Object> mediaServerObjectS = new ArrayList<>(objects);        MediaServerItem mediaServerItem = null;        if (hasAssist == null) {            String mediaServerId = (String)mediaServerObjectS.get(0);            mediaServerItem = getOne(mediaServerId);        }else if (hasAssist) {            for (Object mediaServerObject : mediaServerObjectS) {                String mediaServerId = (String)mediaServerObject;                MediaServerItem serverItem = getOne(mediaServerId);                if (serverItem.getRecordAssistPort() > 0) {                    mediaServerItem = serverItem;                    break;                }            }        }else if (!hasAssist) {            for (Object mediaServerObject : mediaServerObjectS) {                String mediaServerId = (String)mediaServerObject;                MediaServerItem serverItem = getOne(mediaServerId);                if (serverItem.getRecordAssistPort() == 0) {                    mediaServerItem = serverItem;                    break;                }            }        }        return mediaServerItem;    }    /**     * 对zlm服务器进行基础配置     * @param mediaServerItem 服务ID     * @param restart 是否重启zlm     */    @Override    public void setZLMConfig(MediaServerItem mediaServerItem, boolean restart) {        logger.info("[ZLM] 正在设置 :{} -> {}:{}",                mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort());        String protocol = sslEnabled ? "https" : "http";        String hookPrex = String.format("%s://%s:%s/index/hook", protocol, mediaServerItem.getHookIp(), serverPort);        Map<String, Object> param = new HashMap<>();        param.put("api.secret",mediaServerItem.getSecret()); // -profile:v Baseline        if (mediaServerItem.getRtspPort() != 0) {            param.put("ffmpeg.snap", "%s -rtsp_transport tcp -i %s -y -f mjpeg -t 0.001 %s");        }        param.put("hook.enable","1");        param.put("hook.on_flow_report","");        param.put("hook.on_play",String.format("%s/on_play", hookPrex));        param.put("hook.on_http_access","");        param.put("hook.on_publish", String.format("%s/on_publish", hookPrex));        param.put("hook.on_record_ts","");        param.put("hook.on_rtsp_auth","");        param.put("hook.on_rtsp_realm","");        param.put("hook.on_server_started",String.format("%s/on_server_started", hookPrex));        param.put("hook.on_shell_login","");        param.put("hook.on_stream_changed",String.format("%s/on_stream_changed", hookPrex));        param.put("hook.on_stream_none_reader",String.format("%s/on_stream_none_reader", hookPrex));        param.put("hook.on_stream_not_found",String.format("%s/on_stream_not_found", hookPrex));        param.put("hook.on_server_keepalive",String.format("%s/on_server_keepalive", hookPrex));        param.put("hook.on_send_rtp_stopped",String.format("%s/on_send_rtp_stopped", hookPrex));        param.put("hook.on_rtp_server_timeout",String.format("%s/on_rtp_server_timeout", hookPrex));        if (mediaServerItem.getRecordAssistPort() > 0) {            param.put("hook.on_record_mp4",String.format("http://127.0.0.1:%s/api/record/on_record_mp4", mediaServerItem.getRecordAssistPort()));        }else {            param.put("hook.on_record_mp4","");        }        param.put("hook.timeoutSec","20");        // 推流断开后可以在超时时间内重新连接上继续推流,这样播放器会接着播放。        // 置0关闭此特性(推流断开会导致立即断开播放器)        // 此参数不应大于播放器超时时间        // 优化此消息以更快的收到流注销事件        param.put("protocol.continue_push_ms", "3000" );        // 最多等待未初始化的Track时间,单位毫秒,超时之后会忽略未初始化的Track, 设置此选项优化那些音频错误的不规范流,        // 等zlm支持给每个rtpServer设置关闭音频的时候可以不设置此选项//        param.put("general.wait_track_ready_ms", "3000" );        if (mediaServerItem.isRtpEnable() && !ObjectUtils.isEmpty(mediaServerItem.getRtpPortRange())) {            param.put("rtp_proxy.port_range", mediaServerItem.getRtpPortRange().replace(",", "-"));        }        if (userSetting.getRecordPath() != null) {            File recordPathFile = new File(userSetting.getRecordPath());            File mp4SavePathFile = recordPathFile.getParentFile().getAbsoluteFile();            param.put("protocol.mp4_save_path", mp4SavePathFile.getAbsoluteFile());            param.put("record.appName", recordPathFile.getName());        }        JSONObject responseJSON = zlmresTfulUtils.setServerConfig(mediaServerItem, param);        if (responseJSON != null && responseJSON.getInteger("code") == 0) {            if (restart) {                logger.info("[ZLM] 设置成功,开始重启以保证配置生效 {} -> {}:{}",                        mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort());                zlmresTfulUtils.restartServer(mediaServerItem);            }else {                logger.info("[ZLM] 设置成功 {} -> {}:{}",                        mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort());            }        }else {            logger.info("[ZLM] 设置zlm失败 {} -> {}:{}",                    mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort());        }    }    @Override    public MediaServerItem checkMediaServer(String ip, int port, String secret) {        if (mediaServerMapper.queryOneByHostAndPort(ip, port) != null) {            throw new ControllerException(ErrorCode.ERROR100.getCode(), "此连接已存在");        }        MediaServerItem mediaServerItem = new MediaServerItem();        mediaServerItem.setIp(ip);        mediaServerItem.setHttpPort(port);        mediaServerItem.setSecret(secret);        JSONObject responseJSON = zlmresTfulUtils.getMediaServerConfig(mediaServerItem);        if (responseJSON == null) {            throw new ControllerException(ErrorCode.ERROR100.getCode(), "连接失败");        }        JSONArray data = responseJSON.getJSONArray("data");        ZLMServerConfig zlmServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), ZLMServerConfig.class);        if (zlmServerConfig == null) {            throw new ControllerException(ErrorCode.ERROR100.getCode(), "读取配置失败");        }        if (mediaServerMapper.queryOne(zlmServerConfig.getGeneralMediaServerId()) != null) {            throw new ControllerException(ErrorCode.ERROR100.getCode(), "媒体服务ID [" + zlmServerConfig.getGeneralMediaServerId() + " ] 已存在,请修改媒体服务器配置");        }        mediaServerItem.setHttpSSlPort(zlmServerConfig.getHttpPort());        mediaServerItem.setRtmpPort(zlmServerConfig.getRtmpPort());        mediaServerItem.setRtmpSSlPort(zlmServerConfig.getRtmpSslPort());        mediaServerItem.setRtspPort(zlmServerConfig.getRtspPort());        mediaServerItem.setRtspSSLPort(zlmServerConfig.getRtspSSlport());        mediaServerItem.setRtpProxyPort(zlmServerConfig.getRtpProxyPort());        mediaServerItem.setStreamIp(ip);        mediaServerItem.setHookIp(sipConfig.getIp().split(",")[0]);        mediaServerItem.setSdpIp(ip);        return mediaServerItem;    }    @Override    public boolean checkMediaRecordServer(String ip, int port) {        boolean result = false;        OkHttpClient client = new OkHttpClient();        String url = String.format("http://%s:%s/index/api/record",  ip, port);        Request request = new Request.Builder()                .get()                .url(url)                .build();        try {            Response response = client.newCall(request).execute();            if (response != null) {                result = true;            }        } catch (Exception e) {}        return result;    }    @Override    public void delete(String id) {        redisTemplate.opsForZSet().remove(VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetting.getServerId(), id);        String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + id;        redisTemplate.delete(key);    }    @Override    public void deleteDb(String id){        //同步删除数据库中的数据        mediaServerMapper.delOne(id);    }    @Override    public void updateMediaServerKeepalive(String mediaServerId, ServerKeepaliveData data) {        MediaServerItem mediaServerItem = getOne(mediaServerId);        if (mediaServerItem == null) {            // 缓存不存在,从数据库查询,如果数据库不存在则是错误的            mediaServerItem = getOneFromDatabase(mediaServerId);            if (mediaServerItem == null) {                logger.warn("[更新ZLM 保活信息] 流媒体{}尚未加入使用,请检查节点中是否含有此流媒体 ", mediaServerId);                return;            }            // zlm连接重试            logger.warn("[更新ZLM 保活信息]尝试链接zml id {}", mediaServerId);            ssrcFactory.initMediaServerSSRC(mediaServerItem.getId(), null);            String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetting.getServerId() + "_" + mediaServerItem.getId();            redisTemplate.opsForValue().set(key, mediaServerItem);            clearRTPServer(mediaServerItem);        }        final String zlmKeepaliveKey = zlmKeepaliveKeyPrefix + mediaServerItem.getId();        dynamicTask.stop(zlmKeepaliveKey);        dynamicTask.startDelay(zlmKeepaliveKey, new KeepAliveTimeoutRunnable(mediaServerItem), (mediaServerItem.getHookAliveInterval().intValue() + 5) * 1000);    }    private MediaServerItem getOneFromDatabase(String mediaServerId) {        return mediaServerMapper.queryOne(mediaServerId);    }    @Override    public void syncCatchFromDatabase() {        List<MediaServerItem> allInCatch = getAll();        List<MediaServerItem> allInDatabase = mediaServerMapper.queryAll();        Map<String, MediaServerItem> mediaServerItemMap = new HashMap<>();        for (MediaServerItem mediaServerItem : allInDatabase) {            mediaServerItemMap.put(mediaServerItem.getId(), mediaServerItem);        }        for (MediaServerItem mediaServerItem : allInCatch) {            if (!mediaServerItemMap.containsKey(mediaServerItem.getId())) {                delete(mediaServerItem.getId());            }        }    }    @Override    public boolean checkRtpServer(MediaServerItem mediaServerItem, String app, String stream) {        JSONObject rtpInfo = zlmresTfulUtils.getRtpInfo(mediaServerItem, stream);        if(rtpInfo.getInteger("code") == 0){            return rtpInfo.getBoolean("exist");        }        return false;    }    @Override    public MediaServerLoad getLoad(MediaServerItem mediaServerItem) {        MediaServerLoad result = new MediaServerLoad();        result.setId(mediaServerItem.getId());        result.setPush(redisCatchStorage.getPushStreamCount(mediaServerItem.getId()));        result.setProxy(redisCatchStorage.getProxyStreamCount(mediaServerItem.getId()));        result.setGbReceive(redisCatchStorage.getGbReceiveCount(mediaServerItem.getId()));        result.setGbSend(redisCatchStorage.getGbSendCount(mediaServerItem.getId()));        return result;    }}
 |