Android平台如何实现外部RTSP|RTMP流注入轻量级RTSP服务模块（内网RTSP网关）

        //Author: daniusdk.com
            btnPullStream.setOnClickListener(new Button.OnClickListener() {
      // @Override
      public void onClick(View v) {
        if (isPulling)
        {
          if(isPushing || isRecording || isRTSPPublisherRunning)
          {
            Log.e(TAG, "please make sure pusher/recorder/rtsp server stopped first..");
            return;
          }
          StopPull();
          btnPullStream.setText("开始拉流");
          btnPushStream.setEnabled(false);
        }
        else {
          Log.i(TAG, "onClick StartPull Stream..");
          boolean is_pull_suc = StartPull();
          if(!is_pull_suc)
          {
            Log.e(TAG, "call StartPull() failed!");
            return;
          }
          btnPullStream.setText("停止拉流");
          btnPushStream.setEnabled(true);
        }
      }
    });

  //启动/停止RTSP服务
  class ButtonRtspServiceListener implements OnClickListener {
    public void onClick(View v) {
      if (isRTSPServiceRunning) {
        stopRtspService();
        btnRtspService.setText("启动RTSP服务");
        btnRtspPublisher.setEnabled(false);
        isRTSPServiceRunning = false;
        return;
      }
      if(!OpenPushHandle())
      {
        return;
      }
      Log.i(TAG, "onClick start rtsp service..");
      rtsp_handle_ = libPublisher.OpenRtspServer(0);
      if (rtsp_handle_ == 0) {
        Log.e(TAG, "创建rtsp server实例失败! 请检查SDK有效性");
      } else {
        int port = 8554;
        if (libPublisher.SetRtspServerPort(rtsp_handle_, port) != 0) {
          libPublisher.CloseRtspServer(rtsp_handle_);
          rtsp_handle_ = 0;
          Log.e(TAG, "创建rtsp server端口失败! 请检查端口是否重复或者端口不在范围内!");
        }
        //String user_name = "admin";
        //String password = "12345";
        //libPublisher.SetRtspServerUserNamePassword(rtsp_handle_, user_name, password);
        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流
  class ButtonRtspPublisherListener implements OnClickListener {
    public void onClick(View v) {
      if (isRTSPPublisherRunning) {
        stopRtspPublisher();
        btnRtspPublisher.setText("发布RTSP流");
        btnGetRtspSessionNumbers.setEnabled(false);
        btnRtspService.setEnabled(true);
      }
      else
      {
        Log.i(TAG, "onClick start rtsp publisher..");
        boolean startRet = StartRtspStream();
        if (!startRet) {
          Log.e(TAG, "Failed to call StartRtspStream().");
          return;
        }
        btnRtspPublisher.setText("停止RTSP流");
        btnGetRtspSessionNumbers.setEnabled(true);
        btnRtspService.setEnabled(false);
      }
    }
  };

  //当前RTSP会话数弹出框
  private void PopRtspSessionNumberDialog(int session_numbers) {
    final EditText inputUrlTxt = new EditText(this);
    inputUrlTxt.setFocusable(true);
    inputUrlTxt.setEnabled(false);
    String session_numbers_tag = "RTSP服务当前客户会话数: " + session_numbers;
    inputUrlTxt.setText(session_numbers_tag);
    AlertDialog.Builder builderUrl = new AlertDialog.Builder(this);
    builderUrl
        .setTitle("内置RTSP服务")
        .setView(inputUrlTxt).setNegativeButton("确定", null);
    builderUrl.show();
  }

    btnStartStopPlayback.setOnClickListener(new Button.OnClickListener() {
      // @Override
      public void onClick(View v) {
        if (isPlaying) {
          Log.i(TAG, "Stop playback stream++");
          StopPlay();
          btnStartStopPlayback.setText("开始播放 ");
          Log.i(TAG, "Stop playback stream--");
        } else {
          Log.i(TAG, "Start playback stream++");
          boolean startRet = StartPlay();
          if (!startRet) {
            Log.e(TAG, "Failed to call StartPlay().");
            return;
          }
          btnStartStopPlayback.setText("停止播放 ");
          Log.i(TAG, "Start playback stream--");
        }
      }
    });
  }