义乌门户网站建设,中国手机网站,公司网站建设计入明细科目,建设工程教育网站论坛GB/T 28181-2016心跳机制
通过周期性的状态信息报送#xff0c;实现注册服务器与源设备之间的状态检测即心跳机制。
心跳发送方、接收方需统一配置“心跳间隔”参数#xff0c;按照“心跳间隔”定时发送心跳消息#xff0c;默认心跳间隔60s。心跳发送方、接收方…GB/T 28181-2016心跳机制
通过周期性的状态信息报送实现注册服务器与源设备之间的状态检测即心跳机制。
心跳发送方、接收方需统一配置“心跳间隔”参数按照“心跳间隔”定时发送心跳消息默认心跳间隔60s。心跳发送方、接收方需统一配置“心跳超时次数”参数心跳消息连续超时达到“心跳超时次数”则认为对方下线默认心跳超时次数3次。
心跳接收方在心跳发送方上线状态态下检测到心跳消息连续超时达到商定次数则认为心跳发送方离线心跳发送方在心跳接收方上线状态下检测到心跳消息响应消息连续超时达到商定次数则认为心跳接收方离线。
状态信息流程如下 具体技术实现
本文以我们实现的Android平台GB28181国标接入模块为例探讨下大概实现。
相关参数定义
private int gb28181_reg_expired_ 3600; // 注册有效期时间最小3600秒
private int gb28181_heartbeat_interval_ 20; // 心跳间隔GB28181默认是60, 目前调整到20秒
private int gb28181_heartbeat_count_ 3; // 心跳间隔3次失败表示和服务器断开了
设置到GB28181实现层
// GB28181配置
gb28181_agent_.config(gb28181_reg_expired_, gb28181_heartbeat_interval_, gb28181_heartbeat_count_);
MESSAGE组成
MESSAGE sip:340200000020000000013402000000 SIP/2.0
Via: SIP/2.0/TCP 192.168.0.120:60771;rport;branchz9hG4bK741568174
From: sip:340200000020000000053402000000;tag790237397
To: sip:340200000020000000013402000000
Call-ID: 282416456
CSeq: 20 MESSAGE
Content-Type: Application/MANSCDPxml
Max-Forwards: 70
User-Agent: IP Camera
Content-Length: 176?xml version1.0 encodingGB2312?
Notify
CmdTypeKeepalive/CmdType
SN2/SN
DeviceID34020000002000000005/DeviceID
StatusOK/Status
Info
/Info
/Notify
底层针对异常的处理如果超过设定的异常次数状态回调上去便于上层做进一步处理
int count mExcepitonCount.incrementAndGet();
if ( count mConfig.getHeartBeatCount() ) {Log.e(GBDefine.LOGTAG, KeepAlive.sendRequest() KeepAlive reached HeartBeatTimeoutCount: mConfig.getHeartBeatCount() , notify listener);GBSIPAgentListener listener this.getListener();if ( listener ! null) {listener.ntsOnHeartBeatException(count, e.getMessage());}
}
上层收到底层发过来的心跳异常回调并做相应的处理
/** CameraPublishActivity.java* CameraPublishActivity* 针对心跳异常处理** Github: https://github.com/daniulive/SmarterStreaming*/
Overridepublic void ntsOnHeartBeatException(int exceptionCount, String lastExceptionInfo) {Log.e(TAG, ntsOnHeartBeatException heart beat timeout count reached, count: exceptionCount, exception info: (lastExceptionInfo!null?lastExceptionInfo:));// 10毫秒后,停止信令, 然后重启handler.postDelayed(new Runnable() {Overridepublic void run() {Log.i(TAG, gb28281_heart_beart_timeout);stopGB28181Stream();destoryRTPSender();if (gb28181_agent_ ! null) {Log.i(TAG, gb28281_heart_beart_timeout sip stop);gb28181_agent_.stop();Log.i(TAG, gb28281_heart_beart_timeout sip start);gb28181_agent_.start();}}},10);}
感兴趣的开发者可以自行参考实现。
