AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

Android平台GB28181设备接入端如何实现多视频通道接入？

2023-08-08 244
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： GB28181设备接入端如何实现多视频通道接入？

 技术背景

我们在设计Android平台GB28181设备接入模块的时候，有这样的场景诉求，一个设备可能需要多个通道，常见的场景，比如车载终端，一台设备，可能需要接入多个摄像头，那么这台车载终端设备可以作为主设备，然后，主设备下，配置多个通道，听起来是不是有点儿类似于DVR或NVR？

技术实现

camera2 gb28181界面.jpg

这里，我们说下，我们当时做这块，是怎么设计的，首先，在InitGB28181Agent的时候，添加设备通道，具体代码如下：

privatebooleaninitGB28181Agent() {
if ( gb28181_agent_!=null )
returntrue;
getLocation(context_);
Stringlocal_ip_addr=IPAddrUtils.getIpAddress(context_);
Log.i(TAG, "[daniusdk.com]initGB28181Agent local ip addr: "+local_ip_addr);
if ( local_ip_addr==null||local_ip_addr.isEmpty() ) {
Log.e(TAG, "[daniusdk.com]initGB28181Agent local ip is empty");
returnfalse;
        }
gb28181_agent_=GBSIPAgentFactory.getInstance().create();
if ( gb28181_agent_==null ) {
Log.e(TAG, "[daniusdk.com]initGB28181Agent create agent failed");
returnfalse;
        }
gb28181_agent_.addListener(this);
gb28181_agent_.addPlayListener(this);
gb28181_agent_.addAudioBroadcastListener(this);
gb28181_agent_.addDeviceControlListener(this);
gb28181_agent_.addQueryCommandListener(this);
// 必填信息gb28181_agent_.setLocalAddress(local_ip_addr);
gb28181_agent_.setServerParameter(gb28181_sip_server_addr_, gb28181_sip_server_port_, gb28181_sip_server_id_, gb28181_sip_domain_);
gb28181_agent_.setUserInfo(gb28181_sip_username_, gb28181_sip_password_);
//gb28181_agent_.setUserInfo(gb28181_sip_username_, gb28181_sip_username_, gb28181_sip_password_);// 可选参数gb28181_agent_.setUserAgent(gb28181_sip_user_agent_filed_);
gb28181_agent_.setTransportProtocol(gb28181_sip_trans_protocol_==0?"UDP":"TCP");
// GB28181配置gb28181_agent_.config(gb28181_reg_expired_, gb28181_heartbeat_interval_, gb28181_heartbeat_count_);
com.gb.ntsignalling.Devicegb_device=newcom.gb.ntsignalling.Device("34020000001380000001", "安卓测试设备", Build.MANUFACTURER, Build.MODEL,
"宇宙","火星1","火星", true);
if (mLongitude!=null&&mLatitude!=null) {
com.gb.ntsignalling.DevicePositiondevice_pos=newcom.gb.ntsignalling.DevicePosition();
device_pos.setTime(mLocationTime);
device_pos.setLongitude(mLongitude);
device_pos.setLatitude(mLatitude);
gb_device.setPosition(device_pos);
gb_device.setSupportMobilePosition(true); // 设置支持移动位置上报        }
gb28181_agent_.addDevice(gb_device);
com.gb28181.ntsignalling.Devicegb_device1=newcom.gb28181.ntsignalling.Device("34020000001380000002", "安卓测试设备2", Build.MANUFACTURER, Build.MODEL,
"宇宙","火星1","火星", true);
if (mLongitude!=null&&mLatitude!=null) {
com.gb28181.ntsignalling.DevicePositiondevice_pos=newcom.gb28181.ntsignalling.DevicePosition();
device_pos.setTime(mLocationTime);
device_pos.setLongitude(mLongitude);
device_pos.setLatitude(mLatitude);
gb_device1.setPosition(device_pos);
gb_device1.setSupportMobilePosition(true);
        }
gb28181_agent_.addDevice(gb_device1);
if (!gb28181_agent_.createSipStack()) {
gb28181_agent_=null;
Log.e(TAG, "[daniusdk.com]initGB28181Agent gb28181_agent_.createSipStack failed.");
returnfalse;
        }
booleanis_bind_local_port_ok=false;
// 最多尝试5000个端口inttry_end_port=gb28181_sip_local_port_base_+5000;
try_end_port=try_end_port>65536?65536: try_end_port;
for (inti=gb28181_sip_local_port_base_; i<try_end_port; ++i) {
if (gb28181_agent_.bindLocalPort(i)) {
is_bind_local_port_ok=true;
break;
            }
        }
if (!is_bind_local_port_ok) {
gb28181_agent_.releaseSipStack();
gb28181_agent_=null;
Log.e(TAG, "[daniusdk.com]initGB28181Agent gb28181_agent_.bindLocalPort failed.");
returnfalse;
        }
if (!gb28181_agent_.initialize()) {
gb28181_agent_.unBindLocalPort();
gb28181_agent_.releaseSipStack();
gb28181_agent_=null;
Log.e(TAG, "[daniusdk.com]initGB28181Agent gb28181_agent_.initialize failed.");
returnfalse;
        }
returntrue;
    }

image.gif

可以看到，我们调用addDevice(gb_device);添加了两个通道，具体如下：

com.gb.ntsignalling.Devicegb_device=newcom.gb.ntsignalling.Device("34020000001380000001", "安卓测试设备", Build.MANUFACTURER, Build.MODEL,
"宇宙","火星1","火星", true);
if (mLongitude!=null&&mLatitude!=null) {
com.gb.ntsignalling.DevicePositiondevice_pos=newcom.gb.ntsignalling.DevicePosition();
device_pos.setTime(mLocationTime);
device_pos.setLongitude(mLongitude);
device_pos.setLatitude(mLatitude);
gb_device.setPosition(device_pos);
gb_device.setSupportMobilePosition(true); // 设置支持移动位置上报}
gb28181_agent_.addDevice(gb_device);
com.gb28181.ntsignalling.Devicegb_device1=newcom.gb28181.ntsignalling.Device("34020000001380000002", "安卓测试设备2", Build.MANUFACTURER, Build.MODEL,
"宇宙","火星1","火星", true);
if (mLongitude!=null&&mLatitude!=null) {
com.gb28181.ntsignalling.DevicePositiondevice_pos=newcom.gb28181.ntsignalling.DevicePosition();
device_pos.setTime(mLocationTime);
device_pos.setLongitude(mLongitude);
device_pos.setLatitude(mLatitude);
gb_device1.setPosition(device_pos);
gb_device1.setSupportMobilePosition(true);
}
gb28181_agent_.addDevice(gb_device1);

image.gif

一台设备，分别对应了两个device。

invite请求过来的时候，我们会把deviceid回上来，上层可以针对不同的deviceid做预览处理：

@OverridepublicvoidntsOnInvitePlay(StringdeviceId, SessionDescriptionsession_des) {
handler_.postDelayed(newRunnable() {
@Overridepublicvoidrun() {
// 先振铃响应下gb28181_agent_.respondPlayInvite(180, device_id_);
MediaSessionDescriptionvideo_des=null;
SDPRtpMapAttributeps_rtpmap_attr=null;
// 28181 视频使用PS打包Vector<MediaSessionDescription>video_des_list=session_des_.getVideoPSDescriptions();
if (video_des_list!=null&&!video_des_list.isEmpty()) {
for(MediaSessionDescriptionm : video_des_list) {
if (m!=null&&m.isValidAddressType() &&m.isHasAddress() ) {
video_des=m;
ps_rtpmap_attr=video_des.getPSRtpMapAttribute();
break;
                        }
                    }
                }
if (null==video_des) {
gb28181_agent_.respondPlayInvite(488, device_id_);
Log.i(TAG, "ntsOnInvitePlay get video description is null, response 488, device_id:"+device_id_);
return;
                }
if (null==ps_rtpmap_attr) {
gb28181_agent_.respondPlayInvite(488, device_id_);
Log.i(TAG, "ntsOnInvitePlay get ps rtp map attribute is null, response 488, device_id:"+device_id_);
return;
                }
Log.i(TAG,"ntsOnInvitePlay, device_id:"+device_id_+", is_tcp:"+video_des.isRTPOverTCP()
+" rtp_port:"+video_des.getPort() +" ss rc:"+video_des.getSS-RC()
+" address_type:"+video_des.getAddressType() +" address:"+video_des.getAddress());
longrtp_sender_handle=libPublisher.CreateRTPSender(0);
if ( rtp_sender_handle==0 ) {
gb28181_agent_.respondPlayInvite(488, device_id_);
Log.i(TAG, "ntsOnInvitePlay CreateRTPSender failed, response 488, device_id:"+device_id_);
return;
                }
gb28181_rtp_payload_type_=ps_rtpmap_attr.getPayloadType();
gb28181_rtp_encoding_name_=ps_rtpmap_attr.getEncodingName();
libPublisher.SetRTPSenderTransportProtocol(rtp_sender_handle, video_des.isRTPOverUDP()?0:1);
libPublisher.SetRTPSenderIPAddressType(rtp_sender_handle, video_des.isIPv4()?0:1);
libPublisher.SetRTPSenderLocalPort(rtp_sender_handle, 0);
libPublisher.SetRTPSenderSS-RC(rtp_sender_handle, video_des.getSS-RC());
libPublisher.SetRTPSenderSocketSendBuffer(rtp_sender_handle, 2*1024*1024); // 设置到2MlibPublisher.SetRTPSenderClockRate(rtp_sender_handle, ps_rtpmap_attr.getClockRate());
libPublisher.SetRTPSenderDestination(rtp_sender_handle, video_des.getAddress(), video_des.getPort());
if ( libPublisher.InitRTPSender(rtp_sender_handle) !=0 ) {
gb28181_agent_.respondPlayInvite(488, device_id_);
libPublisher.DestoryRTPSender(rtp_sender_handle);
return;
                }
intlocal_port=libPublisher.GetRTPSenderLocalPort(rtp_sender_handle);
if (local_port==0) {
gb28181_agent_.respondPlayInvite(488, device_id_);
libPublisher.DestoryRTPSender(rtp_sender_handle);
return;
                }
Log.i(TAG,"get local_port:"+local_port);
Stringlocal_ip_addr=IPAddrUtils.getIpAddress(context_);
MediaSessionDescriptionlocal_video_des=newMediaSessionDescription(video_des.getType());
local_video_des.addFormat(String.valueOf(ps_rtpmap_attr.getPayloadType()));
local_video_des.addRtpMapAttribute(ps_rtpmap_attr);
local_video_des.setAddressType(video_des.getAddressType());
local_video_des.setAddress(local_ip_addr);
local_video_des.setPort(local_port);
local_video_des.setTransportProtocol(video_des.getTransportProtocol());
local_video_des.setSS-RC(video_des.getSS-RC());
if (!gb28181_agent_.respondPlayInviteOK(device_id_,local_video_des) ) {
libPublisher.DestoryRTPSender(rtp_sender_handle);
Log.e(TAG, "ntsOnInvitePlay call respondPlayInviteOK failed.");
return;
                }
gb28181_rtp_sender_handle_=rtp_sender_handle;
            }
privateStringdevice_id_;
privateSessionDescriptionsession_des_;
publicRunnableset(Stringdevice_id, SessionDescriptionsession_des) {
this.device_id_=device_id;
this.session_des_=session_des;
returnthis;
            }
        }.set(deviceId, session_des),0);
    }

image.gif

收到ACK后，也携带了deviceid作为区分：

@OverridepublicvoidntsOnAckPlay(StringdeviceId) {
handler_.postDelayed(newRunnable() {
@Overridepublicvoidrun() {
Log.i(TAG,"ntsOnACKPlay, device_id:"+device_id_);
if (!isRTSPPublisherRunning&&!isPushingRtmp&&!isRecording) {
InitAndSetConfig();
                }
libPublisher.SetGB28181RTPSender(publisherHandle, gb28181_rtp_sender_handle_, gb28181_rtp_payload_type_, gb28181_rtp_encoding_name_);
//libPublisher.SetGBTCPConnectTimeout(publisherHandle, 10*60*1000);//libPublisher.SetGBInitialTCPReconnectInterval(publisherHandle, 1000);//libPublisher.SetGBInitialTCPMaxReconnectAttempts(publisherHandle, 3);intstartRet=libPublisher.StartGB28181MediaStream(publisherHandle);
if (startRet!=0) {
if (!isRTSPPublisherRunning&&!isPushingRtmp&&!isRecording) {
if (publisherHandle!=0) {
longhandle=publisherHandle;
publisherHandle=0;
libPublisher.SmartPublisherClose(handle);
                        }
                    }
destoryRTPSender();
Log.e(TAG, "Failed to start GB28181 service..");
return;
                }
if (!isRTSPPublisherRunning&&!isPushingRtmp&&!isRecording) {
CheckInitAudioRecorder();
                }
startLayerPostThread();
isGB28181StreamRunning=true;
            }
privateStringdevice_id_;
publicRunnableset(Stringdevice_id) {
this.device_id_=device_id;
returnthis;
            }
        }.set(deviceId),0);
    }

image.gif

TerminatePlay处理如下：

@OverridepublicvoidntsOnTerminatePlay(StringdeviceId) {
handler_.postDelayed(newRunnable() {
@Overridepublicvoidrun() {
Log.i(TAG, "ntsOnTerminatePlay, stop GB28181 media stream, deviceId="+device_id_);
stopGB28181Stream();
destoryRTPSender();
            }
privateStringdevice_id_;
publicRunnableset(Stringdevice_id) {
this.device_id_=device_id;
returnthis;
            }
        }.set(deviceId),0);
    }

image.gif

这样每个deviceid对应一个实例，如果有多个摄像头的话，摄像头，可以按照deviceid来做区分，国标平台侧请求哪个deviceid的话，就启动这个deviceid对应的camera采集、编码和数据打包上传。

文章标签：
Android开发
关键词：
Android设备
Android平台
Android平台gb28181
Android视频
Android通道
音视频牛哥
目录
相关文章
luanpanfei
|
9月前
|
存储 Android开发
如何查看Flutter应用在Android设备上已被撤销的权限？
如何查看Flutter应用在Android设备上已被撤销的权限？
luanpanfei
404 64
游客3d7oliqinlcxa
|
12月前
|
编解码 安全 Android开发
如何修复 Android 和 Windows 不支持视频编解码器的问题？
视频播放时遇到“编解码器不支持”错误（如0xc00d36c4或0xc00d5212）是常见问题，即使文件格式为MP4或MKV。编解码器是编码和解码数据的工具，不同设备和版本支持不同的编解码器。解决方法包括：1) 安装所需编解码器，如K-Lite Codec Pack；2) 使用自带编解码器的第三方播放器，如VLC、KMPlayer等。这些方法能帮助你顺利播放视频。
游客3d7oliqinlcxa
6022 7
luanpanfei
|
9月前
|
存储 Android开发 数据安全/隐私保护
如何在Android设备上撤销Flutter应用程序的所有权限？
如何在Android设备上撤销Flutter应用程序的所有权限？
luanpanfei
555 64
luanpanfei
|
9月前
|
缓存 Android开发 开发者
Flutter环境配置完成后，如何在Android设备上运行Flutter应用程序？
Flutter环境配置完成后，如何在Android设备上运行Flutter应用程序？
luanpanfei
1679 62
luanpanfei
|
9月前
|
开发工具 Android开发 开发者
在Android设备上运行Flutter应用程序时，如果遇到设备未授权的问题该如何解决？
在Android设备上运行Flutter应用程序时，如果遇到设备未授权的问题该如何解决？
luanpanfei
582 61
游客rci3gd3n2dlu2
|
6月前
|
监控 Android开发 数据安全/隐私保护
批量发送短信的平台，安卓群发短信工具插件脚本，批量群发短信软件【autojs版】
这个Auto.js脚本实现了完整的批量短信发送功能，包含联系人管理、短信内容编辑、发送状态监控等功能
游客rci3gd3n2dlu2
595 0
音视频牛哥
|
10月前
|
存储 编解码 监控
Android平台GB28181执法记录仪技术方案与实现
本文介绍了大牛直播SDK的SmartGBD在执法记录仪场景中的应用。GB28181协议作为视频监控联网的国家标准，为设备互联互通提供规范。SmartGBD专为Android平台设计，支持音视频采集、编码与传输，具备自适应算法和多功能扩展优势。文章分析了执法记录仪的需求，如实时音视频传输、设备管理及数据安全，并详细阐述了基于SmartGBD的技术实现方案，包括环境准备、SDK集成、设备注册、音视频处理及功能扩展等步骤。最后展望了SmartGBD在未来智慧物联领域的广阔应用前景。
音视频牛哥
625 13
音视频牛哥
|
10月前
|
存储 编解码 开发工具
Android平台毫秒级低延迟HTTP-FLV直播播放器技术探究与实现
本文详细探讨了在Android平台上实现HTTP-FLV播放器的过程。首先介绍了FLV格式的基础，包括文件头和标签结构。接着分析了HTTP-FLV传输原理，通过分块传输实现流畅播放。然后重点讲解了播放器的实现步骤，涵盖网络请求、数据解析、音视频解码与渲染，以及播放控制功能的设计。文章还讨论了性能优化和网络异常处理的方法，并总结了HTTP-FLV播放器的技术价值，尤其是在特定场景下的应用意义。
音视频牛哥
490 11
翻滚的樱桃肉
|
10月前
|
监控 Shell Linux
Android调试终极指南：ADB安装+多设备连接+ANR日志抓取全流程解析，覆盖环境变量配置/多设备调试/ANR日志分析全流程，附Win/Mac/Linux三平台解决方案
ADB（Android Debug Bridge）是安卓开发中的重要工具，用于连接电脑与安卓设备，实现文件传输、应用管理、日志抓取等功能。本文介绍了 ADB 的基本概念、安装配置及常用命令。包括：1) 基本命令如 `adb version` 和 `adb devices`；2) 权限操作如 `adb root` 和 `adb shell`；3) APK 操作如安装、卸载应用；4) 文件传输如 `adb push` 和 `adb pull`；5) 日志记录如 `adb logcat`；6) 系统信息获取如屏幕截图和录屏。通过这些功能，用户可高效调试和管理安卓设备。
翻滚的樱桃肉
7052 2
浣熊干面包
|
Android开发
19条ANDROID平台设计规范(转)
浣熊干面包
1443 0

热门文章

最新文章

  • 1
    Android 修改host文件的3种方法
  • 2
    Android学习之Handler， Looper，MessageQueue
  • 3
    Android官方开发文档Training系列课程中文版：手势处理之监测通用手势
  • 4
    Android UI详解之颜色资源的使用
  • 5
    android 划屏动画
  • 6
    【Android R】车载 Android 核心服务 - CarPropertyService
  • 7
    android中ListView介绍
  • 8
    Android更改包名
  • 9
    android实现综合布局
  • 10
    Android Studio下载安装及配置图文教程
  • 1
    批量发送短信的平台，安卓群发短信工具插件脚本，批量群发短信软件【autojs版】
    595
  • 2
    Thanox安卓系统增加工具下载，管理、阻止、限制后台每个APP运行情况
    692
  • 3
    qq虚拟视频插件下载安装手机版， 安卓虚拟视频插件，替换摄像头工具
    661
  • 4
    微信虚拟摄像头模块，微信虚拟视频聊天，安卓虚拟摄像头插件
    216
  • 5
    安卓ck提取工具，可提取手机cookie插件，AUTOJS即可实现
    1232
  • 6
    手机型号修改器， 安卓修改手机型号软件， 一键修改手机型号
    412
  • 7
    安卓手机硬改工具， 设备型号修改神器， 安卓硬改一键新机
    860
  • 8
    安卓硬改一键新机工具，一键修改手机型号，串号网卡Imei、sn码【仅供学习参考】
    1754
  • 9
    安卓硬改一键新机，一键新机改串软件，免ROOT网卡串号Imei/sn码
    896
  • 10
    安卓改机工具免root,一键过设备检测,串号SN码【jar即可实现】
    1133

    • 相关课程

    更多
  • 开源Android容器化框架Atlas开发者指南

    • 相关电子书

    更多
  • 58同城Android客户端Walle框架演进与实践之路
  • Android组件化实现
  • 蚂蚁聚宝Android秒级编译——Freeline
    • 下一篇
    基于JAVA的高校宿舍管理系统的设计与实现(论文+源码)_kaic