| | |
|---|
| | | import com.genersoft.iot.vmp.service.IMediaServerService; |
|---|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorage; |
|---|
| | | import com.genersoft.iot.vmp.utils.SerializeUtils; |
|---|
| | | import org.ehcache.shadow.org.terracotta.offheapstore.storage.IntegerStorageEngine; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | |
|---|
| | | param.put("src_port", sendRtpItem.getLocalPort()); |
|---|
| | | param.put("pt", sendRtpItem.getPt()); |
|---|
| | | param.put("use_ps", sendRtpItem.isUsePs() ? "1" : "0"); |
|---|
| | | param.put("only_audio", sendRtpItem.isOnlyAudio()); |
|---|
| | | param.put("only_audio", sendRtpItem.isOnlyAudio() ? "1" : "0"); |
|---|
| | | JSONObject jsonObject = zlmrtpServerFactory.startSendRtpStream(mediaInfo, param); |
|---|
| | | if (jsonObject == null) { |
|---|
| | | logger.error("RTP推流失败: 请检查ZLM服务"); |
|---|
| | | } else if (jsonObject.getInteger("code") == 0) { |
|---|
| | | logger.info("RTP推流成功[ {}/{} ]，{}->{}:{}, " ,param.get("app"), param.get("stream"), jsonObject.getString("local_port"), param.get("dst_url"), param.get("dst_port")); |
|---|
| | | byte[] dialogByteArray = SerializeUtils.serialize(evt.getDialog()); |
|---|
| | | sendRtpItem.setDialog(dialogByteArray); |
|---|
| | | byte[] transactionByteArray = SerializeUtils.serialize(evt.getServerTransaction()); |
|---|
| | | sendRtpItem.setTransaction(transactionByteArray); |
|---|
| | | redisCatchStorage.updateSendRTPSever(sendRtpItem); |
|---|
| | | } else { |
|---|
| | | logger.error("RTP推流失败: {}, 参数：{}",jsonObject.getString("msg"),JSONObject.toJSON(param)); |
|---|
| | | if (sendRtpItem.isOnlyAudio()) { |
|---|
