为什么要设计轻量级RTSP服务
首先声明一点,本blog提到的轻量级RTSP服务,类似于网络摄像头(IPC),而非传统意义的接受外部推流的RTSP服务器。
轻量级RTSP服务解决的核心痛点:避免用户单独部署RTSP或者RTMP服务,实现本地的音视频数据(如摄像头|屏幕、麦克风),编码后,汇聚到内置RTSP服务,对外提供可供拉流的RTSP URL,轻量级RTSP服务,适用于内网环境下,对并发要求不高的场景,视频编码支持H.264/H.265,音频对外输出AAC,支持RTSP鉴权、单播、组播模式,考虑到单个服务承载能力,支持同时创建多个RTSP服务,并支持获取当前RTSP服务会话连接数。
如何设计轻量级RTSP服务接口
轻量级RTSP服务接口,通过服务和发布RTSP结合的方式,可在Android端快速实现类似于IPC功能,详细接口也可参看大牛直播SDK提供的官方DEMO模块(地址)。
1. InitRtspServer()
顾名思义,初始化RTSP服务,和UnInitRTSPServer()接口配套使用,不管启动几个RTSP服务,Init和UnInit接口仅需调一次即可。
/** Init rtsp server(和UnInitRtspServer配对使用,即便是启动多个RTSP服务,也只需调用一次InitRtspServer,请确保在OpenRtspServer之前调用)** @param ctx: get by this.getApplicationContext()** @return {0} if successful*/public native int InitRtspServer(Object ctx);
2.UnInitRtspServer()
如InitRtspServer()所述,不再赘述,接口设计如下:
/** UnInit rtsp server(和InitRtspServer配对使用,即便是启动多个RTSP服务,也只需调用一次UnInitRtspServer)** @return {0} if successful*/public native int UnInitRtspServer();
3. OpenRtspServer()
创建个RTSP Server实例,返回实例句柄。
/** 创建一个rtsp server** @param reserve:保留参数传0** @return rtsp server 句柄*/public native long OpenRtspServer(int reserve);
4. SetRtspServerPort()
设置RTSP服务的监听端口,一般来说,可以设置如554、1554等。
/** 设置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);
5. SetRtspServerUserNamePassword()
接口目的是为了设置rtsp server 鉴权用户名和密码, 这个可以不设置,只有需要鉴权的再设置。
/** 设置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);
6. SetRtspServerMulticast()
设置rtsp server 组播, 如果server设置成组播就不能单播,组播和单播只能选一个, 一般来说单播网络设备支持的好,wifi组播很多路由器不支持。一般不建议设置组播。
/** 设置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);
7. SetRtspServerMulticastAddress()
设置rtsp server 组播组播地址。
/** 设置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);
8. GetRtspServerClientSessionNumbers()
获取rtsp server当前的客户会话数, 这个接口必须在StartRtspServer之后再调用。
/** 获取rtsp server当前的客户会话数, 这个接口必须在StartRtspServer之后再调用** @param rtsp_server_handle: rtsp server 句柄** @return {当前rtsp server会话数}*/public native int GetRtspServerClientSessionNumbers(long rtsp_server_handle);
9. StartRtspServer()
启动RTSP服务。
/** 启动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);
10. StopRtspServer()
停止RTSP服务。
/** 停止rtsp server** @param rtsp_server_handle: rtsp server 句柄** @return {0} if successful*/public native int StopRtspServer(long rtsp_server_handle);
如何调用接口
1. 先调InitRtspServer()接口
libPublisher = new SmartPublisherJniV2();libPublisher.InitRtspServer(myContext); //和UnInitRtspServer配对使用,即便是启动多个RTSP服务,也只需调用一次InitRtspServer,请确保在OpenRtspServer之前调用
2. 启动、停止RTSP服务
//启动/停止RTSP服务class ButtonRtspServiceListener implements 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端口失败! 请检查端口是否重复或者端口不在范围内!");}//String user_name = "admin";//String password = "12345";//libPublisher.SetRtspServerUserNamePassword(rtsp_handle_, user_name, password);//一般来说单播网络设备支持的好,wifi组播很多路由器不支持,默认单播模式;如需使用组播模式,确保设备支持后,打开注释代码测试即可/*boolean is_enable_multicast = true;if(is_enable_multicast){int is_multicast = 1;libPublisher.SetRtspServerMulticast(rtsp_handle_, is_multicast);boolean is_enable_ssm_multicast = true;String multicast_address = "";if(is_enable_ssm_multicast){multicast_address = MakeSSMMulticastAddress();}else{multicast_address = MakeMulticastAddress();}Log.i(TAG, "is_enable_ssm_multicast:" + is_enable_ssm_multicast + " multiAddr: " + multicast_address);libPublisher.SetRtspServerMulticastAddress(rtsp_handle_, multicast_address);}*/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;}}}
3. 发布、停止RTSP流
//发布/停止RTSP流class ButtonRtspPublisherListener implements OnClickListener {public void onClick(View v) {if (isRTSPPublisherRunning) {stopRtspPublisher();if (!isPushingRtmp && !isRecording && !isPushingRtsp) {ConfigControlEnable(true);}btnRtspPublisher.setText("发布RTSP流");btnGetRtspSessionNumbers.setEnabled(false);btnRtspService.setEnabled(true);isRTSPPublisherRunning = false;return;}Log.i(TAG, "onClick start rtsp publisher..");if (!isPushingRtmp && !isRecording && !isPushingRtsp) {InitAndSetConfig();}if (publisherHandle == 0) {Log.e(TAG, "Start rtsp publisher, publisherHandle is null..");return;}String rtsp_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 && !isRecording && !isPushingRtsp) {if (pushType == 0 || pushType == 1) {CheckInitAudioRecorder(); //enable pure video publisher..}ConfigControlEnable(false);}btnRtspPublisher.setText("停止RTSP流");btnGetRtspSessionNumbers.setEnabled(true);btnRtspService.setEnabled(false);isRTSPPublisherRunning = true;}};
4. 获取RTSP会话数
//当前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();}//获取RTSP会话数class ButtonGetRtspSessionNumbersListener implements OnClickListener {public void onClick(View v) {if (libPublisher != null && rtsp_handle_ != 0) {int session_numbers = libPublisher.GetRtspServerClientSessionNumbers(rtsp_handle_);Log.i(TAG, "GetRtspSessionNumbers: " + session_numbers);PopRtspSessionNumberDialog(session_numbers);}}};
5. UnInitRtspServer()
libPublisher.UnInitRtspServer(); //如已启用内置服务功能(InitRtspServer),调用UnInitRtspServer, 注意,即便是启动多个RTSP服务,也只需调用UnInitRtspServer一次
6. 生成组播地址
private String MakeMulticastAddress(){// 239.0.1.0 ~ 239.255.255.255long begin = 0xEF000100;long end = 0xEFFFFFFF;long count = end - begin;Random random = new Random();long addr_host = begin + (random.nextInt((int)count));return DigitToIpAddr(addr_host);}private String MakeSSMMulticastAddress(){// 232.0.1.0 ~ 232.255.255.255long begin = 0xE8000100;long end = 0xE8FFFFFF;long count = end - begin;Random random = new Random();long addr_host = begin + (random.nextInt((int)count));return DigitToIpAddr(addr_host);}private String DigitToIpAddr(long ip) {return ((ip >> 24) & 0xFF) + "."+ ((ip >> 16) & 0xFF) + "."+ ((ip >> 8) & 0xFF) + "."+ (ip & 0xFF);}
总结
为满足内网无纸化/电子教室等内网超低延迟需求,避免让用户配置单独的服务器,我们在推送端发布了轻量级RTSP服务SDK,简单来说,之前推送端SDK支持的功能,内置轻量级RTSP服务SDK后,功能继续支持。
轻量级RTSP可扩展内网RTSP网关模块,完成外部RTSP/RTMP数据拉取并注入到轻量级RTSP服务模块工作,多个内网客户端直接访问内网轻量级RTSP服务获取公网数据,无需部署单独的服务器,支持RTSP/RTMP H.265数据接入。