​​Android平台GB28181历史视音频文件下载规范探讨及技术实现

/*** Author: daniusdk.com*/packagecom.gb.ntsignalling;
publicinterfaceGBSIPAgent {
voidaddDownloadListener(GBSIPAgentDownloadListenerdownloadListener);
voidremoveDownloadListener(GBSIPAgentDownloadListenerremoveListener);
/**响应Invite Download 200 OK*/booleanrespondDownloadInviteOK(longid, StringdeviceId, StringstartTime, StringstopTime, MediaSessionDescriptionlocalMediaDescription);
/**响应Invite Download 其他状态码*/booleanrespondDownloadInvite(intstatusCode, longid, StringdeviceId, StringstartTime, StringstopTime);
/** 媒体流发送者在文件下载结束后发Message消息通知SIP服务器回文件已发送完成* notifyType 必须是"121“*/booleannotifyDownloadMediaStatus(longid, StringdeviceId, StringstartTime, StringstopTime, StringnotifyType);
/**终止Download会话*/voidterminateDownload(longid, StringdeviceId, StringstartTime, StringstopTime, booleanisSendBYE);
/**终止所有Download会话*/voidterminateAllDownloads(booleanisSendBYE);
}

/*** Author: daniusdk.com*/packagecom.gb.ntsignalling;
publicinterfaceGBSIPAgentDownloadListener {
/**收到s=Download的文件下载Invite*/voidntsOnInviteDownload(longid, StringdeviceId, SessionDescriptionsessionDescription);
/**发送Download invite response 异常*/voidntsOnDownloadInviteResponseException(longid, StringdeviceId, StringstartTime, StringstopTime, intstatusCode, StringerrorInfo);
/** 收到CANCEL Download INVITE请求*/voidntsOnCancelDownload(longid, StringdeviceId, StringstartTime, StringstopTime);
/** 收到Ack*/voidntsOnAckDownload(longid, StringdeviceId, StringstartTime, StringstopTime);
/** 更改下载速度*/voidntsOnDownloadMANSRTSPScaleCommand(longid, StringdeviceId, StringstartTime, StringstopTime, doublescale);
/** 收到Bye*/voidntsOnByeDownload(longid, StringdeviceId, StringstartTime, StringstopTime);
/** 不是在收到BYE Message情况下， 终止Download*/voidntsOnTerminateDownload(longid, StringdeviceId, StringstartTime, StringstopTime);
/** Download会话对应的对话终止, 一般不会触发这个回调,目前只有在响应了200K, 但在64*T1时间后还没收到ACK,才可能会出发收到这个, 请做相关清理处理*/voidntsOnDownloadDialogTerminated(longid, StringdeviceId, StringstartTime, StringstopTime);
}

/*** SmartPublisherJniV2.java* Author: daniusdk.com*/packagecom.daniulive.smartpublisher;
publicclassSmartPublisherJniV2 {
/*** Open publisher(启动推送实例)** @param ctx: get by this.getApplicationContext()* * @param audio_opt:* if 0: 不推送音频* if 1: 推送编码前音频(PCM)* if 2: 推送编码后音频(aac/pcma/pcmu/speex).* * @param video_opt:* if 0: 不推送视频* if 1: 推送编码前视频(NV12/I420/RGBA8888等格式)* if 2: 推送编码后视频(AVC/HEVC)* if 3: 层叠加模式** <pre>This function must be called firstly.</pre>** @return the handle of publisher instance*/publicnativelongSmartPublisherOpen(Objectctx, intaudio_opt, intvideo_opt,  intwidth, intheight);
/*** 设置流类型* @param type: 0:表示 live 流, 1:表示 on-demand 流, SDK默认为0(live流)* 注意: 流类型设置当前仅对GB28181媒体流有效* @return {0} if successful*/publicnativeintSetStreamType(longhandle, inttype);
/*** 投递视频 on demand包, 当前只用于GB28181推送, 注意ByteBuffer对象必须是DirectBuffer** @param codec_id: 编码id, 当前支持H264和H265, 1:H264, 2:H265** @param packet: 视频数据, 包格式请参考H264/H265 Annex B Byte stream format, 例如:*                0x00000001 nal_unit 0x00000001 ...*                H264 IDR: 0x00000001 sps 0x00000001 pps 0x00000001 IDR_nal_unit .... 或 0x00000001 IDR_nal_unit ....*                H265 IDR: 0x00000001 vps 0x00000001 sps 0x00000001 pps 0x00000001 IDR_nal_unit .... 或 0x00000001 IDR_nal_unit ....** @param offset: 偏移量* @param size: packet size* @param pts_us: 时间戳, 单位微秒* @param is_pts_discontinuity: 是否时间戳间断，0:未间断，1:间断* @param is_key: 是否是关键帧, 0:非关键帧, 1:关键帧* @param codec_specific_data: 可选参数，可传null, 对于H264关键帧包, 如果packet不含sps和pps, 可传0x00000001 sps 0x00000001 pps*                    ,对于H265关键帧包, 如果packet不含vps,sps和pps, 可传0x00000001 vps 0x00000001 sps 0x00000001 pps* @param codec_specific_data_size: codec_specific_data size* @param width: 图像宽, 可传0* @param height: 图像高, 可传0** @return {0} if successful*/publicnativeintPostVideoOnDemandPacketByteBuffer(longhandle, intcodec_id,
ByteBufferpacket, intoffset, intsize, longpts_us, intis_pts_discontinuity, intis_key,
byte[] codec_specific_data, intcodec_specific_data_size,
intwidth, intheight);
/*** 投递音频on demand包, 当前只用于GB28181推送, 注意ByteBuffer对象必须是DirectBuffer** @param codec_id: 编码id, 当前支持PCMA和AAC, 65536:PCMA, 65538:AAC* @param packet: 音频数据* @param offset：packet偏移量* @param size: packet size* @param pts_us: 时间戳, 单位微秒* @param is_pts_discontinuity: 是否时间戳间断，0:未间断，1:间断* @param codec_specific_data: 如果是AAC的话，需要传 Audio Specific Configuration* @param codec_specific_data_size: codec_specific_data size* @param sample_rate: 采样率* @param channels: 通道数** @return {0} if successful*/publicnativeintPostAudioOnDemandPacketByteBuffer(longhandle, intcodec_id,
ByteBufferpacket, intoffset, intsize, longpts_us, intis_pts_discontinuity,
byte[] codec_specific_data, intcodec_specific_data_size,
intsample_rate, intchannels);
/*** 启动 GB28181 媒体流** @return {0} if successful*/publicnativeintStartGB28181MediaStream(longhandle);
/*** 停止 GB28181 媒体流** @return {0} if successful*/publicnativeintStopGB28181MediaStream(longhandle);
/*** 关闭推送实例，结束时必须调用close接口释放资源** @return {0} if successful*/publicnativeintSmartPublisherClose(longhandle);
}

/*** RecordDownloadListenerImpl.java* Author: daniusdk.com*/packagecom.daniulive.smartpublisher;
publicclassRecordDownloadListenerImplimplementscom.gb.ntsignalling.GBSIPAgentDownloadListener {
/**收到s=Download的文件下载Invite*/@OverridepublicvoidntsOnInviteDownload(longid, StringdeviceId, SessionDescriptionsdp) {
if (!post_task(newOnInviteTask(this.context_, this.is_exit_, this.senders_map_, deviceId, sdp, id))) {
Log.e(TAG, "ntsOnInviteDownload post_task failed, "+RecordSender.make_print_tuple(id, deviceId, sdp.getTime().getStartTime(),  sdp.getTime().getStopTime()));
// 这里不发488, 等待事务超时也可以的GBSIPAgentagent=this.context_.get_agent();
if (agent!=null)
agent.respondDownloadInvite(488, id, deviceId, sdp.getTime().getStartTime(), sdp.getTime().getStopTime());
        }
    }
/** 收到CANCEL Download INVITE请求*/@OverridepublicvoidntsOnCancelDownload(longid, StringdeviceId, StringstartTime, StringstopTime) {
Log.i(TAG, "ntsOnCancelDownload, "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
RecordSendersender=senders_map_.remove(id);
if (null==sender)
return;
StopDisposeTasktask=newStopDisposeTask(sender);
if (!post_task(task))
task.run();
    }
/** 收到Ack*/@OverridepublicvoidntsOnAckDownload(longid, StringdeviceId, StringstartTime, StringstopTime) {
Log.i(TAG, "ntsOnAckDownload, "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
RecordSendersender=senders_map_.get(id);
if (null==sender) {
Log.e(TAG, "ntsOnAckDownload get sender is null, "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
GBSIPAgentagent=this.context_.get_agent();
if (agent!=null)
agent.terminateDownload(id, deviceId, startTime, stopTime, false);
return;
        }
StartTasktask=newStartTask(sender, this.senders_map_);
if (!post_task(task))
task.run();
    }
/** 收到Bye*/@OverridepublicvoidntsOnByeDownload(longid, StringdeviceId, StringstartTime, StringstopTime) {
Log.i(TAG, "ntsOnByeDownload, "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
RecordSendersender=this.senders_map_.remove(id);
if (null==sender)
return;
StopDisposeTasktask=newStopDisposeTask(sender);
if (!post_task(task))
task.run();
    }
/** 更改下载速度*/@OverridepublicvoidntsOnDownloadMANSRTSPScaleCommand(longid, StringdeviceId, StringstartTime, StringstopTime, doublescale) {
if (scale<0.01) {
Log.e(TAG, "ntsOnDownloadMANSRTSPScaleCommand invalid scale:"+scale+" "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
return;
        }
RecordSendersender=this.senders_map_.get(id);
if (null==sender) {
Log.e(TAG, "ntsOnDownloadMANSRTSPScaleCommand can not get sender, scale:"+scale+" "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
return;
        }
sender.set_speed(scale);
Log.i(TAG, "ntsOnDownloadMANSRTSPScaleCommand, scale:"+scale+" "+RecordSender.make_print_tuple(id, deviceId, startTime, stopTime));
    }
}

/*** RecordSender.java* Author: daniusdk.com*/packagecom.daniulive.smartpublisher;
publicclassRecordSender {
publicvoidset_speed(doublespeed) {
intpercent_speed= (int)(speed*100);
this.percent_speed_.set(percent_speed);
    }
publicvoidset_file_description(RecordFileDescriptiondesc) {
this.file_description_=desc;
    }
publicstaticStringmake_print_tuple(longid, Stringdevice_id, Stringstart_time, Stringstop_time) {
StringBuildersb=newStringBuilder(96);
sb.append("[id:").append(id);
sb.append(", device:"+device_id);
sb.append(", t=").append(start_time).append(" ").append(start_time);
sb.append("]");
returnsb.toString();
    }
publicbooleanstart() {
SendThreadcurrent_thread=thread_.get();
if (current_thread!=null) {
if (current_thread.is_exit()) {
Log.e(TAG, "start, the thread already exists and has exited, return false, "+get_print_tuple());
returnfalse;
            }
Log.i(TAG, "start, the thread already exists and has exited, return true, "+get_print_tuple());
returntrue;
        }
SendThreadthread=newSendThread();
if (!thread_.compareAndSet(null, thread)) {
Log.i(TAG, "start, call compareAndSet return false, the thread already exists, return true, "+get_print_tuple());
returntrue;
        }
try {
Log.i(TAG, "start thread, "+get_print_tuple());
thread.start();
        }catch (Exceptione) {
thread_.compareAndSet(thread, null);
Log.e(TAG, "start e:", e);
returnfalse;
        }
returntrue;
    }
publicvoidstop() {
SendThreadcurrent_thread=thread_.get();
if (current_thread!=null&&!current_thread.is_exit()) {
current_thread.exit();
Log.i(TAG, "stop, exit thread "+get_print_tuple());
        }
    }
privatebooleaninit_native_sender(StackDisposabledisposables) {
if(native_handle_!=0) {
Log.e(TAG, "init_native_sender, native_handle_ is not 0, "+get_print_tuple());
returnfalse;
        }
if (null==this.media_info_||!this.media_info_.is_has_track() ) {
Log.e(TAG, "init_native_sender, there is no track, "+get_print_tuple());
returnfalse;
        }
if (0==rtp_handle_) {
Log.e(TAG, "init_native_sender, rtp_handle_ is 0, "+get_print_tuple());
returnfalse;
        }
if (null==lib_publisher_){
Log.e(TAG, "init_native_sender, lib_publisher_ is null, "+get_print_tuple());
returnfalse;
        }
Contextcontext=this.context_.get_context();
if (null==context) {
Log.e(TAG, "init_native_sender, context is null, "+get_print_tuple());
returnfalse;
        }
longhandle=lib_publisher_.SmartPublisherOpen(context, media_info_.is_has_audio_track()?2:0, media_info_.is_has_video_track()?2:0, 0, 0);
if (0==handle) {
Log.e(TAG, "init_native_sender, call SmartPublisherOpen failed, "+get_print_tuple());
returnfalse;
        }
NativeSenderDisposablenative_disposable=newNativeSenderDisposable(lib_publisher_, handle);
lib_publisher_.SetStreamType(handle, 1);
List<MediaTrack>tracks=media_info_.get_tracks();
for (MediaTracki : tracks) {
if (i.is_video())
lib_publisher_.SetEncodedVideoCodecId(handle, i.codec_id(), i.csd_set(), i.csd_set() !=null?i.csd_set().length : 0);
elseif(i.is_audio())
lib_publisher_.SetEncodedAudioCodecId(handle, i.codec_id(), i.csd_set(), i.csd_set() !=null?i.csd_set().length : 0);
        }
lib_publisher_.SetGB28181RTPSender(handle, rtp_handle_, rtp_payload_type_, rtp_encoding_name_);
intret=lib_publisher_.StartGB28181MediaStream(handle);
if (ret!=0) {
Log.e(TAG, "init_native_sender, call StartGB28181MediaStream failed, "+get_print_tuple());
native_disposable.dispose();
returnfalse;
        }
native_disposable.is_need_call_stop(true);
disposables.push(native_disposable);
native_handle_=handle;
returntrue;
    }
privatebooleanpost_media_packet(MediaPacketpacket) {
/*Log.i(TAG, "post "+ MediaTrack.get_media_type_string(packet.media_type()) + " " +MediaTrack.get_codec_id_string(packet.codec_id()) + " packet, pts:" + out_point_3(packet.pts_us()/1000.0) +"ms, key:"+ (packet.is_key()?1:0) + ", size:" + packet.size()); */if (null==lib_publisher_||0==native_handle_||!packet.is_has_data())
returnfalse;
if (packet.is_audio()) {
if (packet.is_aac()) {
if (packet.is_has_codec_specific_data_set())
return0==lib_publisher_.PostAudioOnDemandPacketByteBuffer(native_handle_, packet.codec_id(), packet.data(), 0, packet.size(),
packet.pts_us(), 0, packet.codec_specific_data_set(), packet.codec_specific_data_set_size(), 0, 0);
            }
        }elseif (packet.is_video()) {
if (packet.is_avc() ||packet.is_hevc()) {
return0==lib_publisher_.PostVideoOnDemandPacketByteBuffer(native_handle_, packet.codec_id(), packet.data(),
0, packet.size(), packet.pts_us(), 0, packet.is_key()?1:0,
packet.codec_specific_data_set(), packet.codec_specific_data_set_size(), 0, 0);
            }
        }
returnfalse;
    }
privatevoidrelease_packets(Deque<MediaPacket>packets) {
while (!packets.isEmpty())
packets.removeFirst().release_buffer();
    }
privatestaticStringout_point_3(doublev) { returnString.format("%.3f", v); }
publicstaticStringto_mega_bytes_string(longbytes) {
doublemb=bytes/(1024*1024.0);
returnout_point_3(mb);
    }
privateclassSendThreadextendsThread {
@Overridepublicvoidrun() {
/****相关代码**/        }
    }
}