技术背景
我们在做GB28181设备接入端的时候，其中有个功能，不难但非常重要：那就是GB28181实时位置的订阅（mobileposition subscribe）和上报(notify)。
特别是执法记录仪、智能安全帽、车载终端等场景下，现场人员的实时位置是国标平台侧非常关注的。国标平台侧通过周期性的获取GB28181设备接入端的经纬度信息，并在电子地图显示，需要看现场的情况，点开图标，进行音视频回传和语音广播语音对讲等操作，现场人员的总体概况一目了然。
规范解读
其他不表，我们先看看GB/T28181-2016规范中，关于订阅通知流程：
基本流程和注解如下：
- 国标服务平台向Android平台GB28181设备接入终端发送SUBSCRIBE消息体，并携带Expire头域指定订阅过期时间；
- Android平台GB28181设备接入终端收到SUBSCRIBE后，200 OK响应；
- Android平台GB28181设备接入终端发送 NOTIFY 消息相关的位置信息，并使用Event头域描述订阅事件，国标GB28181的移动设备位置订阅这个值是"presence"；
- 国标服务平台收到 Android平台GB28181设备接入终端NOTIFY消息后，200 OK响应；
- NOTIFY...200 OK...NOTIFY...200 OK...etc..
- 国标服务平台在订阅过期之前，向Android国标接入终端发送刷新订阅 SUBSCRIBE 消息，消息头域中使用 Event头域描述订阅事件,消息体中携带订阅的详细参数，使用 Expire头域指定订阅过期时间;
- Android平台GB28181设备接入终端收到订阅消息后，向国标服务平台发送200 OK响应;
- NOTIFY...200 OK...NOTIFY...200 OK........
- 如国标服务平台需要取消订阅，可以向Android平台GB28181设备接入终端发送取消订阅SUBSCRIBE消息，消息头域中使用Event头域描述订阅事件，消息体中携带订阅的详细参数，Expire头域值为0;
- Android国标接入终端收到订阅消息后,向国标服务平台发送200 OK响应，取消向国标服务平台发送实时位置通知消息，取消订阅成功的话，也会发一个最终的NOTIFY给国标服务端；
- 这里需要注意的是：Android平台GB28181设备接入终端收到SUBSCRIBE请求后，会检查SUBSCRIBE请求中"Expires"值的大小，当且仅当这个值大于0且小于1小时，并且小于Notifier配置的最小值时，Notifier可能会返回一个"423 Interval too small"错误，并包含一个""Min-Expires" 头域；
- Android国标接入端发送的NOTIFY请求超时的话，应该移除这个订阅；
- NOTIFY request必须包含"Subscription-State"头，有三个可选的值:"active", "pending", "terminated". 当值是"active"或"pending"时，应该也包含一个”expires“参数，显示订阅剩余时间。
GB/T28181-2016针对MobilePosition描述
<elementname="TargetID"type="tg:deviceIDType"/>移动设备位置数据通知
<! -- 命令类型:移动设备位置数据通知(必选)-->
<elementname="CmdType"fixed="MobilePosition"/>
<! -- 命令序列号(必选)-->
<elementname="SN" type="integer"minInclusivevalue= "1"/>
<! -- 产生通知时间(必选)-->
<elementname="Time" type="dateTime"/>
<! --经度(必选)--> <elementname="Longitude"type="double"/>
<! -- 纬度(必选)--> <elementname="Latitude"type="double"/>
<! --速度,单位:km/h(可选)-->
<elementname="Speed"type="double"/>
<!--方向,取值为当前摄像头方向与正北方的顺时针夹角,取值范围0°~360°,单位:(°)(可选)-->
<elementname="Direction"type="double"/>
<! --海拔高度,单位:m(可选)-->
<elementname="Altitude"type="tg:deviceIDType"/>技术实现
Android平台GB28181设备接入端，启动GB28181后，调用InitGB28181Agent()的时候，添加设备：
相关代码如下：
/*
* Camera2Activity.java
* Author: daniusdk.com
*/
private boolean initGB28181Agent() {
if ( gb28181_agent_ != null )
return true;
getLocation(context_);
String local_ip_addr = IPAddrUtils.getIpAddress(context_);
Log.i(TAG, "initGB28181Agent local ip addr: " + local_ip_addr);
if ( local_ip_addr == null || local_ip_addr.isEmpty() ) {
Log.e(TAG, "initGB28181Agent local ip is empty");
return false;
}
gb28181_agent_ = GBSIPAgentFactory.getInstance().create();
if ( gb28181_agent_ == null ) {
Log.e(TAG, "initGB28181Agent create agent failed");
return false;
}
gb28181_agent_.addListener(this);
gb28181_agent_.addPlayListener(this);
gb28181_agent_.addTalkListener(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_.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.Device gb_device = new com.gb.ntsignalling.Device("34020000001310000001", "安卓测试设备", Build.MANUFACTURER, Build.MODEL,
"宇宙","火星1","火星", true);
if (mLongitude != null && mLatitude != null) {
com.gb.ntsignalling.DevicePosition device_pos = new com.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);
if (!gb28181_agent_.createSipStack()) {
gb28181_agent_ = null;
Log.e(TAG, "initGB28181Agent gb28181_agent_.createSipStack failed.");
return false;
}
boolean is_bind_local_port_ok = false;
// 最多尝试5000个端口
int try_end_port = gb28181_sip_local_port_base_ + 5000;
try_end_port = try_end_port > 65536 ?65536: try_end_port;
for (int i = 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, "initGB28181Agent gb28181_agent_.bindLocalPort failed.");
return false;
}
if (!gb28181_agent_.initialize()) {
gb28181_agent_.unBindLocalPort();
gb28181_agent_.releaseSipStack();
gb28181_agent_ = null;
Log.e(TAG, "initGB28181Agent gb28181_agent_.initialize failed.");
return false;
}
return true;
}Android平台GB28181设备接入端DevicePosition设计如下：
/*
* DevicePosition.java
* Author: daniusdk.com
*/
public class DevicePosition {
private String mTime; // 产生位置信息的时间，格式如:2022-03-16T10:37:21, yyyy-MM-dd'T'HH:mm:ss
private String mLongitude; // 经度
private String mLatitude; //纬度
private String mSpeed; // 速度,单位:km/h
private String mDirection; // 方向,取值为当前摄像头方向与正北方的顺时针夹角,取值范围0°~360°,单位:(°)
private String mAltitude; // 海拔高度,单位:m
public String getTime() {
return mTime;
}
public void setTime(String time) {
this.mTime = time;
}
public String getLongitude() {
return mLongitude;
}
public void setLongitude(double longitude) {
this.mLongitude = String.valueOf(longitude);
}
public void setLongitude(String longitude) { this.mLongitude =longitude; }
public String getLatitude() {
return mLatitude;
}
public void setLatitude(double latitude) {
this.mLatitude = String.valueOf(latitude);
}
public void setLatitude(String latitude) { this.mLatitude = latitude;}
public String getSpeed() {
return mSpeed;
}
public void setSpeed(double speed) {
this.mSpeed = String.valueOf(speed);
}
public String getDirection() {
return mDirection;
}
public void setDirection(double direction) {
this.mDirection = String.valueOf(direction);
}
public String getAltitude() {
return mAltitude;
}
public void setAltitude(double altitude) {
this.mAltitude = String.valueOf(altitude);
}
}当有SUBSCRIBE request请求位置更新，上层处理如下：
@Override
public void ntsOnDevicePositionRequest(String deviceId, int interval) {
handler_.postDelayed(new Runnable() {
@Override
public void run() {
getLocation(context_);
Log.v(TAG, "ntsOnDevicePositionRequest, deviceId:" + this.device_id_ + ", Longitude:" + mLongitude
+ ", Latitude:" + mLatitude + ", Time:" + mLocationTime);
if (mLongitude != null && mLatitude != null) {
com.gb.ntsignalling.DevicePosition device_pos = new com.gb.ntsignalling.DevicePosition();
device_pos.setTime(mLocationTime);
device_pos.setLongitude(mLongitude);
device_pos.setLatitude(mLatitude);
if (gb28181_agent_ != null ) {
gb28181_agent_.updateDevicePosition(device_id_, device_pos);
}
}
}
private String device_id_;
private int interval_;
public Runnable set(String device_id, int interval) {
this.device_id_ = device_id;
this.interval_ = interval;
return this;
}
}.set(deviceId, interval),0);
}总结
国标平台侧获取到Android平台GB28181设备接入端的实时位置信息后，可以非常方便的根据实时经纬度信息，把前端设备位置标注到地图服务上。Android平台获取实时经纬度并无难度，这里不再赘述。
