跨平台轻量级RTSP服务模块设计思路及实现探讨

  /*
   * SmartPublisherJniV2.java
   * Author: daniusdk.com
   * Created on 2015/09/20.
   */
  /*
   * Init rtsp server(和UnInitRtspServer配对使用，即便是启动多个RTSP服务，也只需调用一次InitRtspServer，请确保在OpenRtspServer之前调用)
   *
   * @param ctx: get by this.getApplicationContext()
   *
   * @return {0} if successful
   */
  public native int InitRtspServer(Object ctx);
  /*
   * 创建一个rtsp server
   *
     * @param reserve：保留参数传0
   *
   * @return rtsp server 句柄
   */
  public native long OpenRtspServer(int reserve);
  /*
   * 设置rtsp server 监听端口, 在StartRtspServer之前必须要设置端口
   *
     * @param rtsp_server_handle: rtsp server 句柄
   *
     * @param port: 端口号，可以设置为554,或者是1024到65535之间,其他值返回失败
   *
   * @return {0} if successful
   */
  public native int SetRtspServerPort(long rtsp_server_handle, int port);
  /*
   * 设置rtsp server 鉴权用户名和密码, 这个可以不设置，只有需要鉴权的再设置
   *
     * @param rtsp_server_handle: rtsp server 句柄
   *
     * @param user_name: 用户名(必须是英文)
   * 
     * @param password：密码(必须是英文)
   *
   * @return {0} if successful
   */
  public native int SetRtspServerUserNamePassword(long rtsp_server_handle, String user_name, String password);
  /*
   * 设置rtsp server 组播, 如果server设置成组播就不能单播，组播和单播只能选一个, 一般来说单播网络设备支持的好，wifi组播很多路由器不支持
   *
   * @param rtsp_server_handle: rtsp server 句柄
   *
   * @param is_multicast: 是否组播, 1为组播, 0为单播, 其他值接口返回错误, 默认是单播
   *
   * @return {0} if successful
   */
  public native int SetRtspServerMulticast(long rtsp_server_handle, int is_multicast);
  /*
   * 设置rtsp server 组播组播地址
   *
   * @param rtsp_server_handle: rtsp server 句柄
   *
   * @param multicast_address: 组播地址
   *
   * 如果设置的不是组播地址, 将返回错误
   * 组播地址范围说明: [224.0.0.0, 224.0.0.255] 为组播预留地址, 不能设置. 可设置范围为[224.0.1.0, 239.255.255.255], 其中SSM地址范围为[232.0.0.0, 232.255.255.255]
   *
   *  @return {0} if successful
   */
  public native int SetRtspServerMulticastAddress(long rtsp_server_handle, String multicast_address);
  /*
   * 获取rtsp server当前的客户会话数, 这个接口必须在StartRtspServer之后再调用
   *
     * @param rtsp_server_handle: rtsp server 句柄
   *
   * @return {当前rtsp server会话数}
   */
  public native int GetRtspServerClientSessionNumbers(long rtsp_server_handle);
  /*
   * 启动rtsp server
   *
     * @param rtsp_server_handle: rtsp server 句柄
   *
     * @param reserve: 保留参数传0
   *
   * @return {0} if successful
   */
  public native int StartRtspServer(long rtsp_server_handle, int reserve);
  /*
   * 停止rtsp server
   *
     * @param rtsp_server_handle: rtsp server 句柄
   *
   * @return {0} if successful
   */
  public native int StopRtspServer(long rtsp_server_handle);
  /*
   * 关闭rtsp server
   *
   * @param rtsp_server_handle: rtsp server 句柄
   *
   * NOTE: 调用这个接口之后rtsp_server_handle失效，
   *
   * @return {0} if successful
   */
  public native int CloseRtspServer(long rtsp_server_handle);
  /*
   * UnInit rtsp server(和InitRtspServer配对使用，即便是启动多个RTSP服务，也只需调用一次UnInitRtspServer)
   *
   * @return {0} if successful
   */
  public native int UnInitRtspServer();
  /*
   * 设置rtsp的流名称
   *
   * @param handle: 推送实例句柄
   *
     * @param stream_name: 流程名称，不能为空字符串，必须是英文
   *
   * 这个作用是: 比如rtsp的url是:rtsp://192.168.0.111/test, test就是设置下去的stream_name
   *
   * @return {0} if successful
   */
  public native int SetRtspStreamName(long handle, String stream_name);
  /*
   * 给要发布的rtsp流设置rtsp server, 一个流可以发布到多个rtsp server上，rtsp server的创建启动请参考OpenRtspServer和StartRtspServer接口
   *
     * @param handle: 推送实例句柄
   *
     * @param rtsp_server_handle：rtsp server句柄
     *
   * @param reserve：保留参数，传0
   *
   * @return {0} if successful
   */
  public native int AddRtspStreamServer(long handle, long rtsp_server_handle, int reserve);
  /*
   * 清除设置的rtsp server
   *
   * @param handle: 推送实例句柄
   *
   * @return {0} if successful
   */
  public native int ClearRtspStreamServer(long handle);
  /*
   * 启动rtsp流
   *
   * @param handle: 推送实例句柄
   *
   * @param reserve: 保留参数，传0
   *
   * @return {0} if successful
   */
  public native int StartRtspStream(long handle, int reserve);
  /*
   * 停止rtsp流
   *
   * @param handle: 推送实例句柄
   *
   * @return {0} if successful
   */
  public native int StopRtspStream(long handle);

//启动/停止RTSP服务
class ButtonRtspServiceListener implements View.OnClickListener {
  public void onClick(View v) {
    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实例失败! 请检查SDK有效性");
    } else {
      int port = 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;
    }
  }
}