Compare commits

...

5 Commits

3 changed files with 54 additions and 38 deletions

View File

@ -95,8 +95,10 @@ public class SSRCFactory {
} }
void rebuild() { void rebuild() {
try {
List<MediaServer> servers = mediaServerService.getAll(); List<MediaServer> servers = mediaServerService.getAll();
for (MediaServer server : servers) { for (MediaServer server : servers) {
try {
if (server.isRtpEnable() && userSetting.getSsrcRandom()) { if (server.isRtpEnable() && userSetting.getSsrcRandom()) {
continue; continue;
} }
@ -120,10 +122,6 @@ public class SSRCFactory {
} catch (NumberFormatException ignored) { } catch (NumberFormatException ignored) {
} }
} }
}
} catch (Exception e) {
log.warn("[SSRC重建] 查询媒体节点 {} 失败: {}", server.getId(), e.getMessage());
}
usedMap.put(server.getId(), bits); usedMap.put(server.getId(), bits);
if (count > 8000) { if (count > 8000) {
log.info("[SSRC重建] 媒体节点 {} 的SSRC使用率已超过80%,请注意扩展服务提升性能", server.getId()); log.info("[SSRC重建] 媒体节点 {} 的SSRC使用率已超过80%,请注意扩展服务提升性能", server.getId());
@ -132,6 +130,17 @@ public class SSRCFactory {
log.debug("[SSRC重建] 节点 {} 已占用 {} 个SSRC", server.getId(), count); 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()) { if (sendRtpItem.isTcpActive()) {
MediaServer mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId()); MediaServer mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId());
try { try {
mediaServerService.startSendRtpPassive(mediaServer, sendRtpItem, 5); mediaServerService.startSendRtpPassive(mediaServer, sendRtpItem, 5*1000);
DeviceChannel deviceChannel = deviceChannelService.getOneForSourceById(sendRtpItem.getChannelId()); DeviceChannel deviceChannel = deviceChannelService.getOneForSourceById(sendRtpItem.getChannelId());
if (deviceChannel != null) { if (deviceChannel != null) {
redisCatchStorage.sendPlatformStartPlayMsg(sendRtpItem, deviceChannel, platform); redisCatchStorage.sendPlatformStartPlayMsg(sendRtpItem, deviceChannel, platform);

View File

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