搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2023-10-11 7de73ebd2bc07a51f0f9db031d6f616bdcfe549c 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java

old mode 100644
new mode 100755

@@ -1,13 +1,17 @@


package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl;




import com.genersoft.iot.vmp.common.VideoManagerConstants;


import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.genersoft.iot.vmp.common.InviteSessionType;


import com.genersoft.iot.vmp.common.StreamInfo;


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.gb28181.bean.*;


import com.genersoft.iot.vmp.gb28181.session.AudioBroadcastManager;


import com.genersoft.iot.vmp.gb28181.session.SSRCFactory;


import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;


import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver;


import com.genersoft.iot.vmp.gb28181.transmit.SIPSender;


import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;


@@ -19,10 +23,7 @@


import com.genersoft.iot.vmp.media.zlm.ZlmHttpHookSubscribe;


import com.genersoft.iot.vmp.media.zlm.dto.*;


import com.genersoft.iot.vmp.media.zlm.dto.hook.OnStreamChangedHookParam;


import com.genersoft.iot.vmp.service.IMediaServerService;


import com.genersoft.iot.vmp.service.IPlayService;


import com.genersoft.iot.vmp.service.IStreamProxyService;


import com.genersoft.iot.vmp.service.IStreamPushService;


import com.genersoft.iot.vmp.service.*;


import com.genersoft.iot.vmp.service.bean.ErrorCallback;


import com.genersoft.iot.vmp.service.bean.InviteErrorCode;


import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;


@@ -50,6 +51,8 @@


import javax.sip.message.Response;


import java.text.ParseException;


import java.time.Instant;


import java.util.HashMap;


import java.util.Map;


import java.util.Random;


import java.util.Vector;




@@ -78,6 +81,9 @@




    @Autowired


    private IRedisCatchStorage redisCatchStorage;




    @Autowired


    private IInviteStreamService inviteStreamService;




    @Autowired


    private SSRCFactory ssrcFactory;


@@ -121,6 +127,9 @@




    @Autowired


    private RedisGbPlayMsgListener redisGbPlayMsgListener;




    @Autowired


    private VideoStreamSessionManager streamSession;






    @Override


@@ -406,6 +415,7 @@


                        content.append("y=" + sendRtpItem.getSsrc() + "\r\n");


                        content.append("f=\r\n");






                        try {


                            // 超时未收到Ack应该回复bye,当前等待时间为10秒


                            dynamicTask.startDelay(callIdHeader.getCallId(), () -> {


@@ -418,8 +428,34 @@


                                    logger.error("[命令发送失败] 国标级联 发送BYE: {}", e.getMessage());


                                }


                            }, 60 * 1000);




                             responseSdpAck(request, content.toString(), platform);


                            responseSdpAck(request, content.toString(), platform);


                            // tcp主动模式，回复sdp后开启监听


                            if (sendRtpItem.isTcpActive()) {


                                MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());


                                Map<String, Object> param = new HashMap<>(12);


                                param.put("vhost","__defaultVhost__");


                                param.put("app",sendRtpItem.getApp());


                                param.put("stream",sendRtpItem.getStream());


                                param.put("ssrc", sendRtpItem.getSsrc());


                                if (!sendRtpItem.isTcpActive()) {


                                    param.put("dst_url",sendRtpItem.getIp());


                                    param.put("dst_port", sendRtpItem.getPort());


                                }


                                String is_Udp = sendRtpItem.isTcp() ? "0" : "1";


                                param.put("is_udp", is_Udp);


                                param.put("src_port", localPort);


                                param.put("pt", sendRtpItem.getPt());


                                param.put("use_ps", sendRtpItem.isUsePs() ? "1" : "0");


                                param.put("only_audio", sendRtpItem.isOnlyAudio() ? "1" : "0");


                                if (!sendRtpItem.isTcp()) {


                                    // 开启rtcp保活


                                    param.put("udp_rtcp_timeout", sendRtpItem.isRtcp()? "1":"0");


                                }


                                JSONObject startSendRtpStreamResult = zlmServerFactory.startSendRtpPassive(mediaInfo, param);


                                if (startSendRtpStreamResult != null) {


                                    startSendRtpStreamHand(evt, sendRtpItem, null, startSendRtpStreamResult, param, callIdHeader);


                                }


                            }


                        } catch (SipException | InvalidArgumentException | ParseException e) {


                            logger.error("[命令发送失败] 国标级联 回复SdpAck", e);


                        }


@@ -438,8 +474,10 @@


                    sendRtpItem.setApp("rtp");


                    if ("Playback".equalsIgnoreCase(sessionName)) {


                        sendRtpItem.setPlayType(InviteStreamType.PLAYBACK);


                        SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, null, null, device.isSsrcCheck(), true, 0, false, false, device.getStreamModeForParam());


                        sendRtpItem.setStream(ssrcInfo.getStream());


                        String startTimeStr = DateUtil.urlFormatter.format(start);


                        String endTimeStr = DateUtil.urlFormatter.format(end);


                        String stream = device.getDeviceId() + "_" + channelId + "_" + startTimeStr + "_" + endTimeStr;


                        SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, stream, null, device.isSsrcCheck(), true, 0,false, false, device.getStreamModeForParam());


                        // 写入redis， 超时时回复


                        redisCatchStorage.updateSendRTPSever(sendRtpItem);


                        playService.playBack(mediaServerItem, ssrcInfo, device.getDeviceId(), channelId, DateUtil.formatter.format(start),


@@ -485,10 +523,10 @@


                                        errorEvent.run(code, msg, data);


                                    }


                                });


                    }else {


                    } else {




                        SSRCInfo ssrcInfo = playService.play(mediaServerItem, device.getDeviceId(), channelId, ssrc, ((code, msg, data) -> {


                            if (code == InviteErrorCode.SUCCESS.getCode()){


                            if (code == InviteErrorCode.SUCCESS.getCode()) {


                                hookEvent.run(code, msg, data);


                            } else if (code == InviteErrorCode.ERROR_FOR_SIGNALLING_TIMEOUT.getCode() || code == InviteErrorCode.ERROR_FOR_STREAM_TIMEOUT.getCode()) {


                                logger.info("[上级点播]超时, 用户：{}， 通道：{}", username, channelId);


@@ -499,12 +537,7 @@


                            }


                        }));


                        sendRtpItem.setPlayType(InviteStreamType.PLAY);


                        String streamId = null;


                        if (mediaServerItem.isRtpEnable()) {


                            streamId = String.format("%s_%s", device.getDeviceId(), channelId);


                        }else {


                            streamId = String.format("%08x", Integer.parseInt(ssrcInfo.getSsrc())).toUpperCase();


                        }


                        String streamId = String.format("%s_%s", device.getDeviceId(), channelId);


                        sendRtpItem.setStream(streamId);


                        sendRtpItem.setSsrc(ssrcInfo.getSsrc());


                        redisCatchStorage.updateSendRTPSever(sendRtpItem);


@@ -550,6 +583,18 @@


            logger.error("sdp解析错误", e);


        } catch (SdpException e) {


            logger.error("未处理的异常 ", e);


        }


    }




    private void startSendRtpStreamHand(RequestEvent evt, SendRtpItem sendRtpItem, ParentPlatform parentPlatform,


                                        JSONObject jsonObject, Map<String, Object> param, CallIdHeader callIdHeader) {


        if (jsonObject == null) {


            logger.error("下级TCP被动启动监听失败: 请检查ZLM服务");


        } else if (jsonObject.getInteger("code") == 0) {


            logger.info("调用ZLM-TCP被动推流接口, 结果： {}",  jsonObject);


            logger.info("启动监听TCP被动推流成功[ {}/{} ]，{}->{}:{}, " ,param.get("app"), param.get("stream"), jsonObject.getString("local_port"), param.get("dst_url"), param.get("dst_port"));


        } else {


            logger.error("启动监听TCP被动推流失败: {}, 参数：{}",jsonObject.getString("msg"), JSON.toJSONString(param));


        }


    }




@@ -1099,9 +1144,10 @@


            audioBroadcastCatch.setStatus(AudioBroadcastCatchStatus.Ok);


            audioBroadcastCatch.setSipTransactionInfoByRequset(sipResponse);


            audioBroadcastManager.update(audioBroadcastCatch);




            streamSession.put(device.getDeviceId(), sendRtpItem.getChannelId(), request.getCallIdHeader().getCallId(), sendRtpItem.getStream(), sendRtpItem.getSsrc(), sendRtpItem.getMediaServerId(), sipResponse, InviteSessionType.BROADCAST);


            // 开启发流，大华在收到200OK后就会开始建立连接


            if (!device.isBroadcastPushAfterAck()) {


                logger.info("[语音喊话] 回复200OK后发现 BroadcastPushAfterAck为False，现在开始推流");


                playService.startPushStream(sendRtpItem, sipResponse, parentPlatform, request.getCallIdHeader());


            }