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--");
				}
			}
		});
	}