为什么要设计轻量级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.255
long 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.255
long 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数据接入。
|