Android国标接入端如何播放GB28181平台端语音广播数据

class PlayerExternalPCMOutput implements NTExternalAudioOutput {
  private int buffer_size_ = 0;
  private ByteBuffer pcm_buffer_ = null;
  @Override
  public ByteBuffer getPcmByteBuffer(int size)  {
    //Log.i("getPcmByteBuffer", "size: " + size);
    if(size < 1)
      return null;
    if(buffer_size_ != size) {
      buffer_size_ = size;
      pcm_buffer_ = ByteBuffer.allocateDirect(buffer_size_);
    }
    return pcm_buffer_;
  }
  public void onGetPcmFrame(int ret, int sampleRate, int channel, int sampleSize, int is_low_latency) {
    /*Log.i("onGetPcmFrame", "ret: " + ret + ", sampleRate: " + sampleRate + ", channel: " + channel + ", sampleSize: " + sampleSize +
        ",is_low_latency:" + is_low_latency + " buffer_size：" + buffer_size);*/
    if (null == pcm_buffer_)
      return;
    pcm_buffer_.rewind();
    if (ret == 0 && isGB28181StreamRunning && publisherHandle != 0 )
      libPublisher.SmartPublisherOnFarEndPCMData(publisherHandle, pcm_buffer_, sampleRate, channel, sampleSize, is_low_latency);
  }
}
private static int align(int d, int a) { return (d + (a - 1)) & ~(a - 1); }
class PlayerAudioDataOutput implements NTAudioDataCallback {
  private int buffer_size_ = 0;
  private int param_info_size_ = 0;
  private ByteBuffer buffer_ = null;
  private ByteBuffer parameter_info_ = null;
  @Override
  public ByteBuffer getAudioByteBuffer(int size) {
    //Log.i("getAudioByteBuffer", "size: " + size);
    if( size < 1 ) return null;
    if (size <= buffer_size_ && buffer_ != null )
      return buffer_;
    buffer_size_ = align(size + 256, 16);
    buffer_ = ByteBuffer.allocateDirect(buffer_size_);
    // Log.i("getAudioByteBuffer", "size: " + size + " buffer_size:" + audio_buffer_size);
    return buffer_;
  }
  @Override
  public ByteBuffer getAudioParameterInfo(int size) {
    //Log.i("getAudioParameterInfo", "size: " + size);
    if(size < 1) return null;
    if ( size <= param_info_size_ &&  parameter_info_ != null )
      return  parameter_info_;
    param_info_size_ = align(size + 32, 16);
    parameter_info_ = ByteBuffer.allocateDirect(param_info_size_);
    //Log.i("getAudioParameterInfo", "size: " + size + " buffer_size:" + param_info_size);
    return parameter_info_;
  }
  public void onAudioDataCallback(int ret, int audio_codec_id, int sample_size, int is_key_frame, long timestamp, int sample_rate, int channel, int parameter_info_size, long reserve)  {
    /*Log.i("onAudioDataCallback", "ret: " + ret + ", audio_codec_id: " + audio_codec_id + ", sample_size: " + sample_size + ", timestamp: " + timestamp +
        ",sample_rate:" + sample_rate);
     */
    last_received_audio_data_time_.set(SystemClock.elapsedRealtime());
  }
}

class AudioPlayerPCMTimer implements Runnable {
  public static final int THRESHOLD_MS = 60*1000; // 暂时设置到1分钟
  public static final int INTERVAL_MS = 10*1000; // 十秒一次, 太频繁影响主线程
  public AudioPlayerPCMTimer(long handle) {
    handle_ = handle;
  }
  @Override
  public void run() {
    if (0 == handle_)
      return;
    if (handle_ != player_handle_) {
      Log.i(TAG, "AudioPlayerPCMTimer handle changed, will stop this timer, handle:" + handle_ + " new handle:" + player_handle_);
      return;
    }
    long last_update_time = last_received_audio_data_time_.get();
    long cur_time = SystemClock.elapsedRealtime();
    // Log.i(TAG, "AudioPlayerPCMTimer last_update_time:" + last_update_time + " cur_time:" + cur_time);
    if ( (last_update_time + this.THRESHOLD_MS) >  cur_time) {
      // 继续定时器
      handler_.postDelayed(new AudioPlayerPCMTimer(this.handle_), this.INTERVAL_MS);
      //  Log.i(TAG, "AudioPlayerPCMTimer running.");
    }
    else {
      Log.i(TAG, "AudioPlayerPCMTimer,trigger threshold, bye audio, stop player.");
      if (gb_broadcast_source_id_ != null && gb_broadcast_target_id_ != null) {
        if (gb28181_agent_ != null)
          gb28181_agent_.byeAudioBroadcast(gb_broadcast_source_id_, gb_broadcast_target_id_);
      }
      gb_broadcast_source_id_ = null;
      gb_broadcast_target_id_ = null;
      stopAudioPlayer();
      destoryRTPReceiver();
      btnGB28181AudioBroadcast.setText("GB28181语音广播");
      btnGB28181AudioBroadcast.setEnabled(false);
    }
  }
  private long handle_;
}

private void stopAudioPlayer() {
  if (player_handle_ != 0 ) {
    lib_player_.SmartPlayerStopPullStream(player_handle_);
    lib_player_.SmartPlayerStopPlay(player_handle_);
    lib_player_.SmartPlayerClose(player_handle_);
    player_handle_ = 0;
  }
}

private void destoryRTPReceiver() {
  if (rtp_receiver_handle_ != 0) {
    lib_player_.UnInitRTPReceiver(rtp_receiver_handle_);
    lib_player_.DestoryRTPReceiverSession(rtp_receiver_handle_);
    lib_player_.DestoryRTPReceiver(rtp_receiver_handle_);
    rtp_receiver_handle_ = 0;
  }
}