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

简介: Android平台GB28181历史视音频文件检索规范探讨及技术实现

技术背景

我们在做Android平台GB28181设备接入侧模块的时候,特别是执法记录仪或类似场景,系统除了对常规的录像有要求,还需要能和GB28181平台侧交互,比如实现设备侧视音频文件检索、下载或回放。本文假定记录仪或相关设备已经完成录像,主要来探讨下设备视音频文件检索相关。

规范解读

先回顾下GB/T28181-2016视音频文件检索基本要求:

文件检索主要用区域、设备、录像时间段、录像地点、录像内容为条件进行查询,用 Message 消息发送检索请求和返回查询结果,传送结果的 Message 消息可以发送多条,应支持附录 N 多响应消息传输的要求。文件检索请求和应答命令采用 MANSCDP 协议格式定义。

命令流程:

image.gif视音频文件检索基本流程.png

信令流程描述如下:

    1. 目录检索方向目录拥有方发送目录查询请求 Message 消息,消息体中包含视音频文件检索条件;
    2. 目录拥有方向目录检索方发送 200 OK,无消息体;
    3. 目录拥有方向目录检索方发送查询结果,消息体中含文件目录,当一条 Message 消息无法传送完所有查询结果时,采用多条消息传送;
    4. 目录检索方向目录拥有方发送 200 OK,无消息体。

    无查询结果的示例如下:

    <?xml version="1.0"encoding="GB2312"?>
    <Query>
      <CmdType>RecordInfo</CmdType>
      <SN>405331641</SN>
      <DeviceID>34020000001380000001</DeviceID>
      <StartTime>2023-09-04T00:00:00</StartTime>
      <EndTime>2023-09-04T06:00:00</EndTime>
      <Type>all</Type>
    </Query>

    image.gif

    没查到录像,那么设备侧回复如下,没有查询到文件的话,<SumNum>元素内容填充"0",  且不携带<RecordList>元素:

    <?xml version="1.0"encoding="GB2312"?>
    <Response>
    <CmdType>RecordInfo</CmdType>
    <SN>405331641</SN>
    <DeviceID>34020000001380000001</DeviceID>
    <Name>DaniuSDK</Name>
    <SumNum>0</SumNum>
    </Response>

    image.gif

    有查询结果:

    有查询结果-录像检索.png

    image.gif

    <Query>
      <CmdType>RecordInfo</CmdType>
      <SN>68331900</SN>
      <DeviceID>34020000001380000001</DeviceID>
      <StartTime>2023-09-04T06:00:00</StartTime>
      <EndTime>2023-09-04T12:00:00</EndTime>
      <Type>all</Type>
    </Query>

    image.gif

    设备侧回复如下:

    <Response>
    <CmdType>RecordInfo</CmdType>
    <SN>68331900</SN>
    <DeviceID>34020000001380000001</DeviceID>
    <Name>DaniuSDK</Name>
    <SumNum>6</SumNum>
    <RecordList Num="3">
    <Item>
    <DeviceID>34020000001380000001</DeviceID>
    <Name>DaniuSDK</Name>
    <StartTime>2023-09-04T10:11:56</StartTime>
    <EndTime>2023-09-04T10:12:58</EndTime>
    <Secrecy>0</Secrecy>
    </Item>
    <Item>
    <DeviceID>34020000001380000001</DeviceID>
    <Name>DaniuSDK</Name>
    <StartTime>2023-09-04T10:13:07</StartTime>
    <EndTime>2023-09-04T10:15:33</EndTime>
    <Secrecy>0</Secrecy>
    </Item>
    <Item>
    <DeviceID>34020000001380000001</DeviceID>
    <Name>DaniuSDK</Name>
    <StartTime>2023-09-04T10:15:37</StartTime>
    <EndTime>2023-09-04T10:16:32</EndTime>
    <Secrecy>0</Secrecy>
    </Item>
    </RecordList>
    </Response>

    image.gif

    需要注意的是,会话外的SIP MESSAGE请求大小不能超过1300个字节。

    技术实现

    以大牛直播SDK的Android平台GB28181设备接入侧为例,设计接口逻辑如下:

    packagecom.gb.ntsignalling;
    publicinterfaceGBSIPAgent {
    voidaddListener(GBSIPAgentListenerlistener);
    voidaddPlayListener(GBSIPAgentPlayListenerplayListener);
    voidremovePlayListener(GBSIPAgentPlayListenerplayListener);
    voidaddDownloadListener(GBSIPAgentDownloadListenerdownloadListener);
    voidremoveDownloadListener(GBSIPAgentDownloadListenerremoveListener);
    voidaddTalkListener(GBSIPAgentTalkListenertalkListener);
    voidremoveTalkListener(GBSIPAgentTalkListenertalkListener);
    voidaddAudioBroadcastListener(GBSIPAgentAudioBroadcastListeneraudioBroadcastListener);
    voidaddDeviceControlListener(GBSIPAgentDeviceControlListenerdeviceControlListener);
    voidaddQueryCommandListener(GBSIPAgentQueryCommandListenerqueryCommandListener);
    voidaddQueryRecordInfoListener(GBSIPAgentQueryRecordInfoListenerqueryRecordInfoListener);
    /*历史视音频文件检索应答*/booleanrespondRecordInfoQueryCommand(StringfromUserName, StringfromUserNameAtDomain, StringtoUserName,StringdeviceName, RecordQueryInfoqueryInfo,
    java.util.List<RecordFileInfo>recordList);
    }

    image.gif

    RecordQueryInfo设计如下:

    //GBSIPAgentQueryRecordInfoListener//Author: daniusdk.compackagecom.gb.ntsignalling;
    publicinterfaceGBSIPAgentQueryRecordInfoListener {
    voidntsOnQueryRecordInfoCommand(StringfromUserName, StringfromUserNameAtDomain,
    StringtoUserName,
    RecordQueryInforecordQueryInfo);
    }
    packagecom.gb.ntsignalling;
    publicinterfaceRecordQueryInfo {
    /**命令序列号(必选)*/StringgetSN();
    /** 目录设备/视频监控联网系统/区域编码(必选)*/StringgetDeviceID();
    /** 录像起始时间(必选)*/StringgetStartTime();
    /** 录像终止时间(必选)*/StringgetEndTime();
    /** 文件路径名 (可选)*/StringgetFilePath();
    /** 录像地址(可选 支持不完全查询)*/StringgetAddress();
    /** 保密属性(可选)缺省为0;0:不涉密,1:涉密*/StringgetSecrecy();
    /** 录像产生类型(可选)time或alarm 或 manual或all*/StringgetType();
    /** 录像触发者ID(可选)*/StringgetRecorderID();
    /**录像模糊查询属性(可选)缺省为0;0:不进行模糊查询,此时根据 SIP 消息中 To头域*URI中的ID值确定查询录像位置,若ID值为本域系统ID 则进行中心历史记录检索,若为前*端设备ID则进行前端设备历史记录检索;1:进行模糊查询,此时设备所在域应同时进行中心*检索和前端检索并将结果统一返回.*/StringgetIndistinctQuery();
    }

    image.gif

    RecordFileInfo设计如下:

    //RecordFileInfo.java//Author: daniusdk.compackagecom.gb.ntsignalling;
    publicclassRecordFileInfo {
    /* 设备/区域编码(必选) */privateStringmDeviceID;
    /* 设备/区域名称(必选) */privateStringmName;
    /*文件路径名 (可选)*/privateStringmFilePath;
    /*录像地址(可选)*/privateStringmAddress;
    /*录像开始时间(可选)*/privateStringmStartTime;
    /*录像结束时间(可选)*/privateStringmEndTime;
    /*保密属性(必选)缺省为0;0:不涉密,1:涉密*/privateStringmSecrecy="0";
    /*录像产生类型(可选)time或alarm 或 manual*/privateStringmType;
    /*录像触发者ID(可选)*/privateStringmRecorderID;
    /*录像文件大小,单位:Byte(可选)*/privateStringmFileSize;
    publicRecordFileInfo() { }
    publicRecordFileInfo(StringdeviceID) {
    this.setDeviceID(deviceID);
        }
    publicRecordFileInfo(StringdeviceID, Stringname) {
    this.setDeviceID(deviceID);
    this.setName(name);
        }
    publicStringgetDeviceID() {
    returnmDeviceID;
        }
    publicvoidsetDeviceID(StringdeviceID) {
    this.mDeviceID=deviceID;
        }
    publicStringgetName() {
    returnmName;
        }
    publicvoidsetName(Stringname) {
    this.mName=name;
        }
    publicStringgetFilePath() {
    returnmFilePath;
        }
    publicvoidsetFilePath(StringfilePath) {
    this.mFilePath=filePath;
        }
    publicStringgetAddress() {
    returnmAddress;
        }
    publicvoidsetAddress(Stringaddress) {
    this.mAddress=address;
        }
    publicStringgetStartTime() {
    returnmStartTime;
        }
    publicvoidsetStartTime(StringstartTime) {
    this.mStartTime=startTime;
        }
    publicStringgetEndTime() {
    returnmEndTime;
        }
    publicvoidsetEndTime(StringendTime) {
    this.mEndTime=endTime;
        }
    publicStringgetSecrecy() {
    returnmSecrecy;
        }
    publicvoidsetSecrecy(Stringsecrecy) {
    this.mSecrecy=secrecy;
        }
    publicStringgetType() {
    returnmType;
        }
    publicvoidsetType(Stringtype) {
    this.mType=type;
        }
    publicStringgetRecorderID() {
    returnmRecorderID;
        }
    publicvoidsetRecorderID(StringrecorderID) {
    this.mRecorderID=recorderID;
        }
    publicStringgetFileSize() {
    returnmFileSize;
        }
    publicvoidsetFileSize(StringfileSize) {
    this.mFileSize=fileSize;
        }
    }

    image.gif

    调用逻辑如下:

    packagecom.mydemo;
    importcom.gb.ntsignalling.GBSIPAgentQueryRecordInfoListener;
    publicclassAndroidG8181DemoImplimplementsGBSIPAgentQueryRecordInfoListener {
    privatestaticclassQueryRecordInfoTaskextendsRecordExecutorService.CancelableTask {
    @Overridepublicvoidrun() {
    RecordBaseQuerybase_query=newRecordBaseQuery(get_canceler(), rec_dir_);
    java.util.Datestart_time_lower=base_query.parser_xml_date_time(record_query_info_.getStartTime());
    java.util.Datestart_time_upper=base_query.parser_xml_date_time(record_query_info_.getEndTime());
    if (null==start_time_lower||null==start_time_upper) {
    Log.e(TAG, "start_time_lower:"+start_time_lower+" or start_time_upper:"+start_time_upper+" is null");
    return;
                }
    base_query.set_start_time_lower(start_time_lower);
    base_query.set_start_time_upper(start_time_upper);
    List<RecordFileDescription>file_list=base_query.execute();
    if (is_cancel())
    return;
    file_list=base_query.sort_by_start_time_asc(file_list);
    if (is_cancel())
    return;
    List<com.gb.ntsignalling.RecordFileInfo>list=base_query.to_record_file_info_list(file_list, record_query_info_.getDeviceID(), null);
    if (is_cancel())
    return;
    if (file_list!=null) {
    for (RecordFileDescriptioni : file_list)
    Log.i(TAG, i.toString(base_query.get_print_begin_date_time_format(), base_query.get_print_end_date_time_format()));
                }
    if (is_cancel() ||null==handler_||null==sip_agent_)
    return;
    Handlerhandler=handler_.get();
    GBSIPAgentsip_agent=sip_agent_.get();
    if (null==handler||null==sip_agent)
    return;
    handler.post(newRunnable() {
    @Overridepublicvoidrun() {
    if (null==this.sip_agent_)
    return;
    GBSIPAgentsip_agent=this.sip_agent_.get();
    if (null==sip_agent)
    return;
    if (this.canceler_!=null&&this.canceler_.get())
    return;
    Stringdevice_name=null;
    sip_agent.respondRecordInfoQueryCommand(from_user_name_, from_user_name_at_domain_,
    to_user_name_, device_name, this.record_query_info_, this.record_list_);
                    }
    privateWeakReference<GBSIPAgent>sip_agent_;
    privateAtomicBooleancanceler_;
    privateStringfrom_user_name_;
    privateStringfrom_user_name_at_domain_;
    privateStringto_user_name_;
    privateRecordQueryInforecord_query_info_;
    privateList<RecordFileInfo>record_list_;
    publicRunnableset(GBSIPAgentsip_agent, AtomicBooleancanceler, Stringfrom_user_name, Stringfrom_user_name_at_domain, Stringto_user_name,
    RecordQueryInforecord_query_info, List<RecordFileInfo>record_list) {
    this.sip_agent_=newWeakReference<>(sip_agent);
    this.canceler_=canceler;
    this.from_user_name_=from_user_name;
    this.from_user_name_at_domain_=from_user_name_at_domain;
    this.to_user_name_=to_user_name;
    this.record_query_info_=record_query_info;
    this.record_list_=record_list;
    returnthis;
                    }
                }.set(sip_agent, get_canceler(), this.from_user_name_, this.from_user_name_at_domain_, this.to_user_name_,
    this.record_query_info_, list));
            }
    publicQueryRecordInfoTaskset(Handlerhandler, GBSIPAgentsip_agent, Stringrec_dir,
    Stringfrom_user_name, Stringfrom_user_name_at_domain,
    Stringto_user_name, RecordQueryInfoquery_info) {
    this.handler_=newWeakReference<>(handler);
    this.sip_agent_=newWeakReference<>(sip_agent);
    this.rec_dir_=rec_dir;
    this.from_user_name_=from_user_name;
    this.from_user_name_at_domain_=from_user_name_at_domain;
    this.to_user_name_=to_user_name;
    this.record_query_info_=query_info;
    returnthis;
            }
    privateWeakReference<Handler>handler_;
    privateWeakReference<GBSIPAgent>sip_agent_;
    privateStringrec_dir_;
    privateStringfrom_user_name_;
    privateStringfrom_user_name_at_domain_;
    privateStringto_user_name_;
    privateRecordQueryInforecord_query_info_;
        }
    @OverridepublicvoidntsOnQueryRecordInfoCommand(StringfromUserName, StringfromUserNameAtDomain, finalStringtoUserName,
    RecordQueryInforecordQueryInfo) {
    handler_.post(newRunnable() {
    @Overridepublicvoidrun() {
    Log.i(TAG, "ntsOnQueryRecordInfoCommand from_user_name:"+from_user_name_+", to_user_name:"+to_user_name_+", sn:"+record_query_info_.getSN()  +", device_id:"+record_query_info_.getDeviceID() +", start_time:"+record_query_info_.getStartTime() +", end_time:"+record_query_info_.getEndTime());
    QueryRecordInfoTaskquery_task=newQueryRecordInfoTask();
    query_task.set(handler_, gb28181_agent_, recDir, from_user_name_, from_user_name_at_domain_, to_user_name_, record_query_info_);
    if (!record_executor_.submit(query_task))
    Log.e(TAG, "ntsOnQueryRecordInfoCommand call record_executor_.submit failed");
                }
    privateStringfrom_user_name_;
    privateStringfrom_user_name_at_domain_;
    privateStringto_user_name_;
    privateRecordQueryInforecord_query_info_;
    publicRunnableset(Stringfrom_user_name, Stringfrom_user_name_at_domain, Stringto_user_name, RecordQueryInforecord_query_info) {
    this.from_user_name_=from_user_name;
    this.from_user_name_at_domain_=from_user_name_at_domain;
    this.to_user_name_=to_user_name;
    this.record_query_info_=record_query_info;
    returnthis;
                }
            }.set(fromUserName, fromUserNameAtDomain, toUserName, recordQueryInfo));
        }
    }

    image.gif

    总结

    GB28181设备接入侧视音频历史文件查询,看似不难,实际上需要处理的逻辑还很多,感兴趣的开发者,可以通过平台,和我私信探讨。

    相关文章
    |
    12天前
    |
    安全 Android开发 iOS开发
    Android vs. iOS:构建生态差异与技术较量的深度剖析###
    本文深入探讨了Android与iOS两大移动操作系统在构建生态系统上的差异,揭示了它们各自的技术优势及面临的挑战。通过对比分析两者的开放性、用户体验、安全性及市场策略,本文旨在揭示这些差异如何塑造了当今智能手机市场的竞争格局,为开发者和用户提供决策参考。 ###
    |
    22天前
    |
    Java Android开发 Swift
    安卓与iOS开发对比:平台选择对项目成功的影响
    【10月更文挑战第4天】在移动应用开发的世界中,选择合适的平台是至关重要的。本文将深入探讨安卓和iOS两大主流平台的开发环境、用户基础、市场份额和开发成本等方面的差异,并分析这些差异如何影响项目的最终成果。通过比较这两个平台的优势与挑战,开发者可以更好地决定哪个平台更适合他们的项目需求。
    83 1
    |
    8天前
    |
    安全 Android开发 iOS开发
    安卓与iOS的较量:技术深度对比
    【10月更文挑战第18天】 在智能手机操作系统领域,安卓和iOS无疑是两大巨头。本文将深入探讨这两种系统的技术特点、优势以及它们之间的主要差异,帮助读者更好地理解这两个平台的独特之处。
    21 0
    |
    5天前
    |
    安全 Android开发 iOS开发
    iOS与安卓:技术生态的双雄争霸
    在当今数字化时代,智能手机操作系统的竞争愈发激烈。iOS和安卓作为两大主流平台,各自拥有独特的技术优势和市场地位。本文将从技术架构、用户体验、安全性以及开发者支持四个方面,深入探讨iOS与安卓之间的差异,并分析它们如何塑造了今天的移动技术生态。无论是追求极致体验的苹果用户,还是享受开放自由的安卓粉丝,了解这两大系统的内在逻辑对于把握未来趋势至关重要。
    |
    6天前
    |
    安全 搜索推荐 Android开发
    揭秘iOS与Android系统的差异:一场技术与哲学的较量
    在当今数字化时代,智能手机操作系统的选择成为了用户个性化表达和技术偏好的重要标志。iOS和Android,作为市场上两大主流操作系统,它们之间的竞争不仅仅是技术的比拼,更是设计理念、用户体验和生态系统构建的全面较量。本文将深入探讨iOS与Android在系统架构、应用生态、用户界面及安全性等方面的本质区别,揭示这两种系统背后的哲学思想和市场策略,帮助读者更全面地理解两者的优劣,从而做出更适合自己的选择。
    |
    10天前
    |
    安全 Android开发 iOS开发
    安卓vs iOS:探索两种操作系统的独特魅力与技术深度###
    【10月更文挑战第16天】 本文旨在深入浅出地探讨安卓(Android)与iOS这两种主流移动操作系统的特色、优势及背后的技术理念。通过对比分析,揭示它们各自如何塑造了移动互联网的生态,并为用户提供丰富多彩的智能体验。无论您是科技爱好者还是普通用户,都能从这篇文章中感受到技术创新带来的无限可能。 ###
    26 2
    |
    10天前
    |
    机器学习/深度学习 人工智能 Android开发
    安卓与iOS:技术演进的双城记
    【10月更文挑战第16天】 在移动操作系统的世界里,安卓和iOS无疑是两个最重要的玩家。它们各自代表了不同的技术理念和市场策略,塑造了全球数亿用户的移动体验。本文将深入探讨这两个平台的发展历程、技术特点以及它们如何影响了我们的数字生活,旨在为读者提供一个全面而深入的视角,理解这两个操作系统背后的哲学和未来趋势。
    25 2
    |
    13天前
    |
    Linux API 开发工具
    FFmpeg开发笔记(五十九)Linux编译ijkplayer的Android平台so库
    ijkplayer是由B站研发的移动端播放器,基于FFmpeg 3.4,支持Android和iOS。其源码托管于GitHub,截至2024年9月15日,获得了3.24万星标和0.81万分支,尽管已停止更新6年。本文档介绍了如何在Linux环境下编译ijkplayer的so库,以便在较新的开发环境中使用。首先需安装编译工具并调整/tmp分区大小,接着下载并安装Android SDK和NDK,最后下载ijkplayer源码并编译。详细步骤包括环境准备、工具安装及库编译等。更多FFmpeg开发知识可参考相关书籍。
    54 0
    FFmpeg开发笔记(五十九)Linux编译ijkplayer的Android平台so库
    |
    16天前
    |
    Java Android开发 Swift
    掌握安卓与iOS应用开发:技术比较与选择指南
    在移动应用开发领域,谷歌的安卓和苹果的iOS系统无疑是两大巨头。它们不仅塑造了智能手机市场,还影响了开发者的日常决策。本文深入探讨了安卓与iOS平台的技术差异、开发环境及工具、以及市场表现和用户基础。通过对比分析,旨在为开发者提供实用的指导,帮助他们根据项目需求、预算限制和性能要求,做出最合适的平台选择。无论是追求高度定制的用户体验,还是期望快速进入市场,本文都将为您的开发旅程提供有价值的见解。
    |
    1天前
    |
    搜索推荐 安全 Android开发
    安卓与iOS的哲学对话:技术生态中的选择与命运
    【10月更文挑战第24天】 在智能设备的世界里,安卓和iOS不仅是操作系统的简单对立,它们代表了不同的技术哲学和生态策略。本文将探讨这两种系统背后的设计理念、用户体验差异以及它们如何塑造我们的数字生活,从而引发对于“我们如何选择技术”这一命题的深入思考。