| | |
| | | mediaServerItem.setId(zlmServerConfig.getGeneralMediaServerId()); |
| | | zlmServerConfig.setIp(mediaServerItem.getIp()); |
| | | mediaServerMapper.add(mediaServerItem); |
| | | handLeZLMServerConfig(zlmServerConfig); |
| | | zlmServerOnline(zlmServerConfig); |
| | | result.setCode(0); |
| | | result.setMsg("success"); |
| | | }else { |
| | |
| | | return mediaServerMapper.add(mediaSerItem); |
| | | } |
| | | |
| | | @Override |
| | | public int updateToDatabase(MediaServerItem mediaSerItem) { |
| | | return mediaServerMapper.update(mediaSerItem); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 处理zlm上线 |
| | | * @param zlmServerConfig zlm上线携带的参数 |
| | | */ |
| | | @Override |
| | | public void handLeZLMServerConfig(ZLMServerConfig zlmServerConfig) { |
| | | public void zlmServerOnline(ZLMServerConfig zlmServerConfig) { |
| | | logger.info("[ ZLM:{} ]-[ {}:{} ]已连接", |
| | | zlmServerConfig.getGeneralMediaServerId(), zlmServerConfig.getIp(), zlmServerConfig.getHttpPort()); |
| | | |
| | |
| | | logger.warn("[未注册的zlm] 拒接接入:来自{}:{}", zlmServerConfig.getIp(),zlmServerConfig.getHttpPort() ); |
| | | return; |
| | | } |
| | | 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()); |
| | | } |
| | | if (StringUtils.isEmpty(serverItem.getId())) { |
| | | serverItem.setId(zlmServerConfig.getGeneralMediaServerId()); |
| | | mediaServerMapper.updateByHostAndPort(serverItem); |