Windows下利用live555实现H264实时流RTSP发送的方案
发布时间:2023-10-10 18:21:40
最近在做的项目要求利用RTSP协议转发处理完的H264视频数据给上一层客户端,在网上查了一下发现别人贴出来的代码基本都是Linux上面的Windows不能用,所以下面分享一个用live555进行RTSP的播放适用于Windows系统的,需要的朋友可以参考下
文如其名,最近在做的项目要求利用RTSP协议转发处理完的H264视频数据给上一层客户端,环境是Windows的VS2013,于是就各种百度谷歌找代码。结果在得到利用live555去做比较简单的结论的同时也悲情地发现,网上别人贴出来的代码基本都是Linux上面的。在修改了两份来适用于Windows无效后,又一次陷入了百度谷歌的无尽搜索中。Anyway,最后终于解决了,所以贴出代码跟大家分享下,希望能给和我需求相似的童鞋一点启发,也希望有高手指正其中的问题。
用live555进行RTSP的播放基本上是通过修改其给出来的播放本地文件的DEMO来实现的。但由于其DEMO封装的比较深,所以要直接修改他的fread处的代码变成内存拷贝来实现实时传输会显得比较别扭。本文参考了网上的一些代码,自定义了一个继承自H264VideoFileServerMediaSubsession的类来来进行处理,同时定义了一个继承自FramedSource的类来做内存的拷贝操作,该类亦是区别于读本地文件和实时流之紧要处。
代码如下,如果觉得需要或者懒得自己搭建live555的环境亦可以在文中最后的链接中下载该工程(环境为VS2013),如果你的VS版本合适即可直接运行。
主文件(程序入口)
#include "H264LiveVideoServerMediaSubssion.hh"
#include "H264FramedLiveSource.hh"
#include "liveMedia.hh"
#include "BasicUsageEnvironment.hh"
#define BUFSIZE 1024*200
static void announceStream(RTSPServer* rtspServer, ServerMediaSession* sms,char const* streamName)//显示RTSP连接信息
{
char* url = rtspServer->rtspURL(sms);
UsageEnvironment& env = rtspServer->envir();
env <<streamName<< "\n";
env << "Play this stream using the URL \"" << url << "\"\n";
delete[] url;
}
int main(int argc, char** argv)
{
//设置环境
UsageEnvironment* env;
Boolean reuseFirstSource = False;//如果为“true”则其他接入的客户端跟第一个客户端看到一样的视频流,否则其他客户端接入的时候将重新播放
TaskScheduler* scheduler = BasicTaskScheduler::createNew();
env = BasicUsageEnvironment::createNew(*scheduler);
//创建RTSP服务器
UserAuthenticationDatabase* authDB = NULL;
RTSPServer* rtspServer = RTSPServer::createNew(*env, 8554, authDB);
if (rtspServer == NULL) {
*env << "Failed to create RTSP server: " << env->getResultMsg() << "\n";
exit(1);
}
char const* descriptionString= "Session streamed by \"testOnDemandRTSPServer\"";
//模拟实时流发送相关变量
int datasize;//数据区长度
unsigned char* databuf;//数据区指针
databuf = (unsigned char*)malloc(1024*1024);
bool dosent;//rtsp发送标志位,为true则发送,否则退出
//从文件中拷贝1M数据到内存中作为实时网络传输内存模拟,如果实时网络传输应该是双线程结构,记得在这里加上线程锁
//此外实时传输的数据拷贝应该是发生在H264FramedLiveSource文件中,所以这里只是自上往下的传指针过去给它
FILE *pf;
fopen_s(&pf, "test.264", "rb");
fread(databuf, 1, BUFSIZE, pf);
datasize = BUFSIZE;
dosent = true;
fclose(pf);
//上面的部分除了模拟网络传输的部分外其他的基本跟live555提供的demo一样,而下面则修改为网络传输的形式,为此重写addSubsession的第一个参数相关文件
char const* streamName = "h264ESVideoTest";
ServerMediaSession* sms = ServerMediaSession::createNew(*env, streamName, streamName,descriptionString);
sms->addSubsession(H264LiveVideoServerMediaSubssion::createNew(*env, reuseFirstSource, &datasize, databuf,&dosent));//修改为自己实现的H264LiveVideoServerMediaSubssion
rtspServer->addServerMediaSession(sms);
announceStream(rtspServer, sms, streamName);//提示用户输入连接信息
env->taskScheduler().doEventLoop(); //循环等待连接
free(databuf);//释放掉内存
return 0;
}
自定义H264VideoFileServerMediaSubsession类
H264VideoFileServerMediaSubsession.hh
#ifndef _H264_LIVE_VIDEO_SERVER_MEDIA_SUBSESSION_HH
#define _H264_LIVE_VIDEO_SERVER_MEDIA_SUBSESSION_HH
#include "H264VideoFileServerMediaSubsession.hh"
class H264LiveVideoServerMediaSubssion : public H264VideoFileServerMediaSubsession {
public:
static H264LiveVideoServerMediaSubssion* createNew(UsageEnvironment& env, Boolean reuseFirstSource, int *datasize, unsigned char* databuf, bool *dosent);
protected: // we're a virtual base class
H264LiveVideoServerMediaSubssion(UsageEnvironment& env, Boolean reuseFirstSource, int *datasize, unsigned char* databuf, bool *dosent);
~H264LiveVideoServerMediaSubssion();
protected: // redefined virtual functions
FramedSource* createNewStreamSource(unsigned clientSessionId,unsigned& estBitrate);
public:
char fFileName[100];
int *Server_datasize;//数据区大小指针
unsigned char* Server_databuf;//数据区指针
bool *Server_dosent;//发送标示
};
#endifH264VideoFileServerMediaSubsession.cpp
#include "H264LiveVideoServerMediaSubssion.hh"
#include "H264FramedLiveSource.hh"
#include "H264VideoStreamFramer.hh"
H264LiveVideoServerMediaSubssion* H264LiveVideoServerMediaSubssion::createNew(UsageEnvironment& env, Boolean reuseFirstSource, int *datasize, unsigned char* databuf, bool *dosent)
{
return new H264LiveVideoServerMediaSubssion(env, reuseFirstSource, datasize, databuf, dosent);
}
H264LiveVideoServerMediaSubssion::H264LiveVideoServerMediaSubssion(UsageEnvironment& env, Boolean reuseFirstSource, int *datasize, unsigned char* databuf, bool *dosent)
: H264VideoFileServerMediaSubsession(env, fFileName, reuseFirstSource)//H264VideoFileServerMediaSubsession不是我们需要修改的文件,
//但是我们又要用它来初始化我们的函数,
//所以给个空数组进去即可
{
Server_datasize = datasize;//数据区大小指针
Server_databuf = databuf;//数据区指针
Server_dosent = dosent;//发送标示
}
H264LiveVideoServerMediaSubssion::~H264LiveVideoServerMediaSubssion()
{
}
FramedSource* H264LiveVideoServerMediaSubssion::createNewStreamSource(unsigned clientSessionId, unsigned& estBitrate)
{
/* Remain to do : assign estBitrate */
estBitrate = 1000; // kbps, estimate
//创建视频源
H264FramedLiveSource* liveSource = H264FramedLiveSource::createNew(envir(), Server_datasize, Server_databuf, Server_dosent);
if (liveSource == NULL)
{
return NULL;
}
// Create a framer for the Video Elementary Stream:
return H264VideoStreamFramer::createNew(envir(), liveSource);
}
自定义H264FramedLiveSource类
H264FramedLiveSource.hh
#ifndef _H264FRAMEDLIVESOURCE_HH
#define _H264FRAMEDLIVESOURCE_HH
#include
class H264FramedLiveSource : public FramedSource
{
public:
static H264FramedLiveSource* createNew(UsageEnvironment& env, int *datasize, unsigned char* databuf, bool *dosent, unsigned preferredFrameSize = 0, unsigned playTimePerFrame = 0);
protected:
H264FramedLiveSource(UsageEnvironment& env, int *datasize, unsigned char* databuf, bool *dosent, unsigned preferredFrameSize, unsigned playTimePerFrame);
~H264FramedLiveSource();
private:
virtual void doGetNextFrame();
int TransportData(unsigned char* to, unsigned maxSize);
protected:
int *Framed_datasize;//数据区大小指针
unsigned char *Framed_databuf;//数据区指针
bool *Framed_dosent;//发送标示
int readbufsize;//记录已读取数据区大小
int bufsizel;//记录数据区大小
};
#endifH264FramedLiveSource.cpp
#include "H264FramedLiveSource.hh"
H264FramedLiveSource::H264FramedLiveSource(UsageEnvironment& env, int *datasize, unsigned char* databuf, bool *dosent, unsigned preferredFrameSize, unsigned playTimePerFrame)
: FramedSource(env)
{
Framed_datasize = datasize;//数据区大小指针
Framed_databuf = databuf;//数据区指针
Framed_dosent = dosent;//发送标示
}
H264FramedLiveSource* H264FramedLiveSource::createNew(UsageEnvironment& env, int *datasize, unsigned char* databuf, bool *dosent, unsigned preferredFrameSize, unsigned playTimePerFrame)
{
H264FramedLiveSource* newSource = new H264FramedLiveSource(env, datasize, databuf, dosent, preferredFrameSize, playTimePerFrame);
return newSource;
}
H264FramedLiveSource::~H264FramedLiveSource()
{
}
void H264FramedLiveSource::doGetNextFrame()
{
if (*Framed_dosent == true)
{
*Framed_dosent = false;
bufsizel = *Framed_datasize;
readbufsize = 0;
fFrameSize = fMaxSize;
memcpy(fTo, Framed_databuf + readbufsize, fFrameSize);
readbufsize += fFrameSize;
}
else
{
if (bufsizel - readbufsize>fMaxSize)
{
fFrameSize = fMaxSize;
memcpy(fTo, Framed_databuf + readbufsize, fFrameSize);
readbufsize += fFrameSize;
}
else
{
memcpy(fTo, Framed_databuf + readbufsize, bufsizel - readbufsize);
*Framed_dosent = true;
}
}
nextTask() = envir().taskScheduler().scheduleDelayedTask(0,(TaskFunc*)FramedSource::afterGetting, this);//表示延迟0秒后再执行 afterGetting 函数
return;
}
猜你喜欢
- 有些用户在win10系统中会遇到一些无法解决的问题。例如,一些用户报告更新win10失败,并提示错误0x80244022,可以参考以下方法解
- 在Word 2007“选项卡”对话框中,只有一项必须用标尺无法完成的任务:设置领导者选项卡。但是 W¯¯帽子是一个引导者标签?甲前导标签产生
- 经常需要制作各种各样的表格,很多时候我们都需要根据表格数据来制作图表,很多朋友在图表制作完毕后就默认图表的表现形式,其实图表是可以改变显示形
- wps软件是一款深受用户喜欢的一款办公软件,给用户带来了许多的帮助,在wps软件中用户可以编辑各种各样的文件,这是因为wps软件一直有着其它
- 我们可以利用WPS文字提供的文档网格功能,可以快速实现文档每页22行每行28字排版要求。操作步骤如下:1.在“页面布局”选项卡上的“页面设置
- 这篇文章主要介绍了开启Win8系统控制面板的多种方法,需要的朋友可以参考下方法一在任务栏左下角鼠标右键单击“控制面板”。就会弹出控制面板的窗
- 欢迎观看illustrator教程,小编带大家学习 illustrator 的基本工具和使用技巧,了解如何在 illustrator 中的图
- wps设置表格对齐方式的方法。在wps文字中编辑文档,总会需要设置文本的对其方式,那么要怎么设置将其对齐呢?下面给大家分享wps设置表格对齐
- Win7系统可以说是最常见的系统之一,最近有不少使用win7系统的小伙伴在设置wifi时遇到了名称是乱码的情况,那么碰到这个问题应该怎么办呢
- win10系统下怎么将腾讯qlv格式转换mp4格式?在腾讯客户端下载了视频,但是发现只能在腾讯中播放,现在想转成mp4,win10系统中自带
- 很多时候是由于各方面原因造成的。对于锐捷经常连接网卡后总掉线的问题,经过多次实验发现一个绝妙的解决方法,下面与大家分享下锐捷客户端作为校园网
- word在平时工作的中经常会使用到,比如做一些文档等。但是经常使用难免会出现一些问题,像出现乱码就是其中之一。出现word乱码之后很多朋友不
- Win11是微软新推出的系统,但使用过程中难免会遇到一些问题,有用户就问小编自己想要初始化电脑,该如何操作呢?那下面小编就给大家带来了Win
- 你知道吗?在iPhone和iPad上的可自定义小部件也可以在Mac上使用了!现在在最新的macOS Big Sur或更高版本的Mac上,我们
- Excel表格自动求积公式,具体该怎么去进行操作的呢?今天,小编就教大家在Excel中表格自动求积公式的操作方法。Excel中表格自动求积公
- 在之前做Office的这么长时间里,就Office和WPS的事情,听过诸多人的观点,这里给大家写一下我使用上的一些感受和看法。工具的核心在于
- 可以连续打印已给文件夹里多个word文档里面的内容,其方法:1、选中需要打印的文档;2、单击鼠标右键,在弹出的快捷菜单中选择打印命令即可,如
- 文件夹左侧快速访问列表固定的那些文件夹,或许并不适合所有用户,若要将它们从快速访问取消固定,可以参考下面的方法微软的开发者们在设计系统时多少
- win10中OneNote无法登陆该怎么办?win10系统中打开OneNote提示:“抱歉,出现问题。无法登陆请重试”该怎么办?下面我们来看
- 根据彭博社知名爆料者 Mark Gurman 消息,苹果目前正考虑研发更大尺寸的 iPad,屏幕尺寸将大于当前在售的 iPad Pro 12