国网B接口语音对讲和广播技术探究及与GB28181差别

接口描述

在谈国网B接口的语音广播和语音对讲的时候，大家会觉得，国网B接口是不是和GB28181大同小异？实际上确实信令有差别，但是因为要GB28181设备接入测的对接，再次做国网B接口就简单多了。

语音对讲和广播包括信令接口和媒体流接口，采用与“调阅实时视频”流程相同的机制，不同之处
在于用户发出的请求消息的 SDP 仅携带音频描述信息。
语音所采用的编解码算法为 ITU-T G.711A。
语音对讲和广播，被调阅的平台无需进行音频分发行为。

接口流程

语音对讲和广播的接口流程如下：

主要功能流程如下：
a） F1：平台用户，对前端系统指定的前端系统摄像机发起实时音频的调阅请求，发送 INVITE 消
息，携带 SDP 内容，通过平台转发到前端系统。
b） F2：按照 SIP 要求，如前端系统在 0.5 s 内未处理该请求，则先发送 1xx 临时响应给平台。
c） F3：前端系统接受了调阅请求的操作，则发送携带 SDP 的 200 OK 响应到平台。
d） F4：平台发送 ACK 给前端系统，确认会话建立。
e） 实时语音流开始传输，前端设备/用户根据相应的解码器解码并语音输出。
f） F5：用户结束会话，平台发送 BYE 消息到前端系统。
g） F6：前端系统发送确认，将媒体通道拆线，会话结束。

接口参数

SIP头字段如下：

SIP响应码返回码如下：

SIP参数定义：

 

 RTP 动态 Payload 定义如下：

 消息示例

INVITE sip:前端设备地址编码@前端系统所属平台域名或IP地址 SIP/2.0
From: <sip:用户地址编码@用户所属平台域名或IP地址>;tag=3101300
To: <sip:前端设备地址编码@前端系统所属平台域名或IP地址>
Contact: <sip:用户地址编码@用户所属平台域名或IP地址>
Call-ID: c47k42
Via: SIP/2.0/UDP 用户所属平台IP地址;branch=z9hG4bK
CSeq: 1 INVITE
Content-type: application/SDP
Content-Length: 消息体的长度
v=0
o=- 0 0 IN IP4 用户会话IP地址描述
s=-
c=IN IP4 用户媒体IP地址描述
m=audio 38564 RTP/AVP 8
a=rtpmap:8 PCMA/8000
a=sendrecv

 语音会话请求响应如下：

SIP/2.0 200 OK
From: <sip: 用户地址编码@用户所属平台域名或IP地址>;tag=3101300
To: <sip: 前端设备地址编码@前端系统所属平台域名或IP地址>;tag=20b0660
Contact: <sip: 用户地址编码@用户所属平台域名或IP地址>
Call-ID: c47k42
Via: SIP/2.0/UDP 用户所属平台IP地址;branch=z9hG4bK
CSeq: 1 INVITE
Content-type: application/SDP
Content-Length: 消息体的长度
v=0
o=- 0 0 IN IP4 前端设备会话IP地址描述
s=-
c=IN IP4 前端设备媒体IP地址描述
m=audio 1000 RTP/AVP 8
a=rtpmap:8 PCMA/8000
a=sendrecv

代码实现

    @Overridepublic void ntsOnInviteTalk(String deviceId, SessionDescription sessionDescription) {handler_.postDelayed(new Runnable() {@Overridepublic void run() {// 先振铃响应下gb28181_agent_.respondTalkInvite(180, device_id_);MediaSessionDescription audio_description = null;SDPRtpMapAttribute rtp_map_attribute = null;Vector<MediaSessionDescription> audio_des_list = session_description_.getAudioDescriptions();if (audio_des_list != null && !audio_des_list.isEmpty()) {// 先尝试获取PCMA格式for(MediaSessionDescription m : audio_des_list) {if (m != null && m.isValidAddressType() && m.isHasAddress()) {rtp_map_attribute = m.getRtpMapAttribute(SDPRtpMapAttribute.PCMA_ENCODING_NAME);if (rtp_map_attribute != null) {audio_description = m;break;}}}// 如果没有PCMA格式，尝试获取PS格式if (null == rtp_map_attribute) {for(MediaSessionDescription m : audio_des_list) {if (m != null && m.isValidAddressType() && m.isHasAddress()) {rtp_map_attribute = m.getRtpMapAttribute(SDPRtpMapAttribute.PS_ENCODING_NAME);if (rtp_map_attribute != null) {audio_description = m;break;}}}}}if (null == audio_description) {gb28181_agent_.respondTalkInvite(488, device_id_);Log.i(TAG, "ntsOnInviteTalk get audio description is null, response 488, device_id:" + device_id_);return;}if (null == rtp_map_attribute ) {gb28181_agent_.respondTalkInvite(488, device_id_);Log.i(TAG, "ntsOnInviteTalk get rtp map attribute is null, response 488, device_id:" + device_id_);return;}Log.i(TAG,"ntsOnInviteTalk, device_id:" +device_id_+", is_tcp:" + audio_description.isRTPOverTCP()+ " rtp_port:" + audio_description.getPort() + " ssrc:" + audio_description.getSSRC()+ " address_type:" + audio_description.getAddressType() + " address:" + audio_description.getAddress()+ " payload_type:" +   rtp_map_attribute.getPayloadType() + " encoding_name:" + rtp_map_attribute.getEncodingName());long rtp_sender_handle = libPublisher.CreateRTPSender(0);if (0 == rtp_sender_handle) {gb28181_agent_.respondTalkInvite(488, device_id_);Log.i(TAG, "ntsOnInviteTalk CreateRTPSender failed, response 488, device_id:" + device_id_);return;}gb_talk_rtp_payload_type_  = rtp_map_attribute.getPayloadType();gb_talk_rtp_encoding_name_ = rtp_map_attribute.getEncodingName();Log.i(TAG, "gb_talk_rtp_payload_type: " + gb_talk_rtp_payload_type_ + " gb_talk_rtp_encoding_name: " + gb_talk_rtp_encoding_name_);gb_talk_rtp_encoding_name_ =  "PS";libPublisher.SetRTPSenderTransportProtocol(rtp_sender_handle, audio_description.isRTPOverUDP()?0:1);libPublisher.SetRTPSenderIPAddressType(rtp_sender_handle, audio_description.isIPv4()?0:1);//libPublisher.SetRTPSenderLocalPort(rtp_sender_handle, 0);libPublisher.SetRTPSenderLocalPort(rtp_sender_handle, audio_description.getPort());libPublisher.SetRTPSenderSSRC(rtp_sender_handle, audio_description.getSSRC());libPublisher.SetRTPSenderSocketSendBuffer(rtp_sender_handle, 256*1024); // 音频配置到256KBlibPublisher.SetRTPSenderClockRate(rtp_sender_handle, rtp_map_attribute.getClockRate());libPublisher.SetRTPSenderDestination(rtp_sender_handle, audio_description.getAddress(), audio_description.getPort());gb_talk_is_receive_ = audio_description.isHasAttribute("sendrecv");Log.i(TAG, "gb_talk_is_receive: " + gb_talk_is_receive_);if (gb_talk_is_receive_) {libPublisher.EnableRTPSenderReceive(rtp_sender_handle, 1);// 收包SSRC, 暂时不设置, 因为部分平台ssrc不一致的// libPublisher.SetRTPSenderReceiveSSRC(rtp_sender_handle, audio_description.getSSRC());// 这个一定要设置libPublisher.SetRTPSenderReceivePayloadType(rtp_sender_handle, gb_talk_rtp_payload_type_, gb_talk_rtp_encoding_name_, 2,  rtp_map_attribute.getClockRate());// 目前发现某些平台 PS-PCMA 是8000, 不建议设置if (gb_talk_rtp_encoding_name_.equals("PS")) {libPublisher.SetRTPSenderReceivePSClockFrequency(rtp_sender_handle, 8000);}// 如果是PCMA编码, 采样率和通道可以先不设置// libPublisher.SetRTPSenderReceiveAudioSamplingRate(rtp_sender_handle, 8000);// libPublisher.SetRTPSenderReceiveAudioChannels(rtp_sender_handle, 1);}if (libPublisher.InitRTPSender(rtp_sender_handle) != 0 ) {gb28181_agent_.respondTalkInvite(488, device_id_);libPublisher.DestoryRTPSender(rtp_sender_handle);return;}int local_port = libPublisher.GetRTPSenderLocalPort(rtp_sender_handle);if (0==local_port) {gb28181_agent_.respondTalkInvite(488, device_id_);libPublisher.DestoryRTPSender(rtp_sender_handle);return;}Log.i(TAG,"ntsOnInviteTalk get local_port:" + local_port);String local_ip_addr = IPAddrUtils.getIpAddress(context_);MediaSessionDescription main_local_audio_des = new MediaSessionDescription(audio_description.getType());main_local_audio_des.addFormat(String.valueOf(rtp_map_attribute.getPayloadType()));main_local_audio_des.addRtpMapAttribute(rtp_map_attribute);main_local_audio_des.addAttribute(new SDPAttribute("sendonly"));if (audio_description.isRTPOverTCP()) {// tcp主动链接服务端main_local_audio_des.addAttribute(new SDPAttribute("setup", "active"));main_local_audio_des.addAttribute(new SDPAttribute("connection", "new"));}main_local_audio_des.setPort(local_port);main_local_audio_des.setTransportProtocol(audio_description.getTransportProtocol());main_local_audio_des.setSSRC(audio_description.getSSRC());MediaSessionDescription sub_local_audio_des = null;if (gb_talk_is_receive_) {sub_local_audio_des = new MediaSessionDescription(audio_description.getType());sub_local_audio_des.addFormat(String.valueOf(rtp_map_attribute.getPayloadType()));sub_local_audio_des.addRtpMapAttribute(rtp_map_attribute);sub_local_audio_des.addAttribute(new SDPAttribute("recvonly"));if (audio_description.isRTPOverTCP()) {// tcp主动链接服务端sub_local_audio_des.addAttribute(new SDPAttribute("setup", "active"));sub_local_audio_des.addAttribute(new SDPAttribute("connection", "new"));}sub_local_audio_des.setPort(local_port);sub_local_audio_des.setTransportProtocol(audio_description.getTransportProtocol());sub_local_audio_des.setSSRC(audio_description.getSSRC());}if (!gb28181_agent_.respondTalkInviteOK(device_id_, audio_description.getAddressType(), local_ip_addr, main_local_audio_des, sub_local_audio_des) ) {libPublisher.DestoryRTPSender(rtp_sender_handle);Log.e(TAG, "ntsOnInviteTalk call respondPlayInviteOK failed.");return;}gb_talk_rtp_sender_handle_ = rtp_sender_handle;}private String device_id_;private SessionDescription session_description_;public Runnable set(String device_id, SessionDescription session_des) {this.device_id_ = device_id;this.session_description_ = session_des;return this;}}.set(deviceId, sessionDescription),0);}

总结

国网B接口的语音广播和语音对讲，和GB28181的还是有些差别，B接口的语音广播和语音对讲，不需要先发broadcast过来，不用设备接入端发invite请求，而是电网平台侧发invite，类似实时视频请求播放流程，感兴趣的开发者，可以根据规范仔细解读研究。