Compare commits

...

5 Commits

3 changed files with 54 additions and 38 deletions

View File

@ -95,8 +95,10 @@ public class SSRCFactory {
}
void rebuild() {
try {
List<MediaServer> servers = mediaServerService.getAll();
for (MediaServer server : servers) {
try {
if (server.isRtpEnable() && userSetting.getSsrcRandom()) {
continue;
}
@ -120,10 +122,6 @@ public class SSRCFactory {
} catch (NumberFormatException ignored) {
}
}
}
} catch (Exception e) {
log.warn("[SSRC重建] 查询媒体节点 {} 失败: {}", server.getId(), e.getMessage());
}
usedMap.put(server.getId(), bits);
if (count > 8000) {
log.info("[SSRC重建] 媒体节点 {} 的SSRC使用率已超过80%,请注意扩展服务提升性能", server.getId());
@ -132,6 +130,17 @@ public class SSRCFactory {
log.debug("[SSRC重建] 节点 {} 已占用 {} 个SSRC", server.getId(), count);
}
}
} catch (Exception e) {
log.warn("[SSRC重建] 查询媒体节点 {} 失败: {}", server.getId(), e.getMessage());
}
}
}catch (Exception e) {
log.warn("[SSRC重建] 处理媒体节点 {} 失败: {}", server.getId(), e.getMessage());
}
}
}catch (Exception e) {
log.error("[SSRC] 重建SSRC失败", e);
}
}
}

View File

@ -212,7 +212,7 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements
if (sendRtpItem.isTcpActive()) {
MediaServer mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId());
try {
mediaServerService.startSendRtpPassive(mediaServer, sendRtpItem, 5);
mediaServerService.startSendRtpPassive(mediaServer, sendRtpItem, 5*1000);
DeviceChannel deviceChannel = deviceChannelService.getOneForSourceById(sendRtpItem.getChannelId());
if (deviceChannel != null) {
redisCatchStorage.sendPlatformStartPlayMsg(sendRtpItem, deviceChannel, platform);

View File

@ -148,10 +148,17 @@ export default {
}
},
watch: {
planArray: function(array) {
planArray: {
handler(array) {
if (!array || !array.length) {
return
}
for (let i = 0; i < array.length; i++) {
this.weekData[i].data = array[i].data
}
},
deep: true,
immediate: true
}
},
created() {