Android平台GB28181设备接入侧如何同时对外输出RTSP流？

//启动/停止RTSP服务classButtonRtspServiceListenerimplementsView.OnClickListener {
publicvoidonClick(Viewv) {
if (isRTSPServiceRunning) {
stopRtspService();
btnRtspService.setText("启动RTSP服务");
btnRtspPublisher.setEnabled(false);
isRTSPServiceRunning=false;
return;
    }
Log.i(TAG, "onClick start rtsp service..");
rtsp_handle_=libPublisher.OpenRtspServer(0);
if (rtsp_handle_==0) {
Log.e(TAG, "创建rtsp server实例失败! 请联系 https://daniusdk.com 检查SDK有效性");
    } else {
intport=8554;
if (libPublisher.SetRtspServerPort(rtsp_handle_, port) !=0) {
libPublisher.CloseRtspServer(rtsp_handle_);
rtsp_handle_=0;
Log.e(TAG, "创建rtsp server端口失败! 请检查端口是否重复或者端口不在范围内!");
      }
if (libPublisher.StartRtspServer(rtsp_handle_, 0) ==0) {
Log.i(TAG, "启动rtsp server 成功!");
      } else {
libPublisher.CloseRtspServer(rtsp_handle_);
rtsp_handle_=0;
Log.e(TAG, "启动rtsp server失败! 请检查设置的端口是否被占用!");
      }
btnRtspService.setText("停止RTSP服务");
btnRtspPublisher.setEnabled(true);
isRTSPServiceRunning=true;
    }
  }
}

//发布/停止RTSP流classButtonRtspPublisherListenerimplementsView.OnClickListener {
publicvoidonClick(Viewv) {
if (isRTSPPublisherRunning) {
stopRtspPublisher();
btnRtspPublisher.setText("发布RTSP流");
btnGetRtspSessionNumbers.setEnabled(false);
btnRtspService.setEnabled(true);
return;
    }
Log.i(TAG, "onClick start rtsp publisher..");
if (!isPushingRtmp&&!isGB28181StreamRunning&&!isRecording) {
InitAndSetConfig();
    }
if (publisherHandle==0) {
Log.e(TAG, "Start rtsp publisher, publisherHandle is null..");
return;
    }
Stringrtsp_stream_name="stream1";
libPublisher.SetRtspStreamName(publisherHandle, rtsp_stream_name);
libPublisher.ClearRtspStreamServer(publisherHandle);
libPublisher.AddRtspStreamServer(publisherHandle, rtsp_handle_, 0);
if (libPublisher.StartRtspStream(publisherHandle, 0) !=0) {
Log.e(TAG, "调用发布rtsp流接口失败!");
return;
    }
if (!isPushingRtmp&&!isGB28181StreamRunning&&!isRecording) {
CheckInitAudioRecorder();    //enable pure video publisher..    }
startLayerPostThread();
btnRtspPublisher.setText("停止RTSP流");
btnGetRtspSessionNumbers.setEnabled(true);
btnRtspService.setEnabled(false);
isRTSPPublisherRunning=true;
  }
}

//获取RTSP会话数classButtonGetRtspSessionNumbersListenerimplementsView.OnClickListener {
publicvoidonClick(Viewv) {
if (libPublisher!=null&&rtsp_handle_!=0) {
intsession_numbers=libPublisher.GetRtspServerClientSessionNumbers(rtsp_handle_);
Log.i(TAG, "GetRtspSessionNumbers: "+session_numbers);
PopRtspSessionNumberDialog(session_numbers);
    }
  }
}

privatestaticclassEventHandlerPublisherV2implementsNTSmartEventCallbackV2 {
@OverridepublicvoidonNTSmartEventCallbackV2(longhandle, intid, longparam1, longparam2, Stringparam3, Stringparam4, Objectparam5) {
Log.i(TAG, "EventHandeV2: handle="+handle+" id:"+id);
Stringpublisher_event="";
switch (id) {
     .....
caseNTSmartEventID.EVENT_DANIULIVE_ERC_PUBLISHER_RECORDER_START_NEW_FILE:
publisher_event="开始一个新的录像文件 : "+param3;
break;
caseNTSmartEventID.EVENT_DANIULIVE_ERC_PUBLISHER_ONE_RECORDER_FILE_FINISHED:
if (recorder_io_executor_!=null) {
ExecutorServiceexecutor=recorder_io_executor_.get();
if (executor!=null)
executor.execute(newRecordFileFinishedHandler().set(handle, param3, param1));
        }
publisher_event="已生成一个录像文件 : "+param3;
break;
caseNTSmartEventID.EVENT_DANIULIVE_ERC_PUBLISHER_SEND_DELAY:
publisher_event="发送时延: "+param1+" 帧数:"+param2;
break;
caseNTSmartEventID.EVENT_DANIULIVE_ERC_PUBLISHER_CAPTURE_IMAGE:
publisher_event="快照: "+param1+" 路径："+param3;
if (param1==0) {
publisher_event=publisher_event+"截取快照成功..";
        } else {
publisher_event=publisher_event+"截取快照失败..";
        }
break;
caseNTSmartEventID.EVENT_DANIULIVE_ERC_PUBLISHER_RTSP_URL:
publisher_event="RTSP服务URL: "+param3;
break;
    }
Stringstr="当前回调状态："+publisher_event;
Log.i(TAG, str);
if (handler_!=null) {
android.os.Handlerhandler=handler_.get();
if (handler!=null) {
Messagemessage=newMessage();
message.what=PUBLISHER_EVENT_MSG;
message.obj=publisher_event;
handler.sendMessage(message);
      }
    }
  }
publicNTSmartEventCallbackV2set(android.os.Handlerhandler, ExecutorServicerecorder_io_executor) {
this.handler_=newWeakReference<>(handler);
this.recorder_io_executor_=newWeakReference<>(recorder_io_executor);
returnthis;
  }
privateWeakReference<android.os.Handler>handler_;
privateWeakReference<ExecutorService>recorder_io_executor_;
}