一套rk3588 rtsp服务器推流的 github 方案及记录 -01

我不生产代码，我只是代码的搬运工，信赖我，看完这个文章你的图片一定能酿成流媒体推出去。
诉求：使用opencv拉流，转成bgr数据，需要把处理后的数据（BGR）编码成264，然后推流推出去，相称于直播（实时编码）
播放器

超低延迟的RTSP播放器
https://github.com/tsingsee/EasyPlayer-RTSP-Win
青犀的一个播放器，直接下他的EasyPlayer-RTSP-Win用来测试就行。划重点，超低延时，我团体方案的延时大概是600-700ms,使用海康相机，rtsp拉流，做了yolo处理，再推出去,有编码，有解码，vlc的延时设置低了就回卡帧，Gop已经改成5了还是卡帧，没有测试Gop改成1的环境，但是vlc的延时和流畅，团体看是不太兼容的。ffmpeg使用nobuffer也会卡帧。直观感受卡的就是Gop的P帧。
服务器

live555 方案

假如你不发急的话。。。 可以试试这个方案，这方面的参考文献给列下面了，由于确实端庄研究了几天还看了不少代码，认真想了应该怎么处理，但是确实不太想写，而且对我的需求来讲live555冗余了很多功能，再加上网上确实没有写好的，我又很发急要结果，确定方案能用，以是也没有用这个方案。
官方demo

live555自己的测试文件是有推流demo的，主要是根据实时需求推264文件，以及无脑做一个推264文件的服务器，当时看代码的时候一头雾水加上发急，也没太认真看，主要在live555\testProgs下面，testOnDemandRTSPServer,testH264VideoStreamer ，第二个是无脑推，第一个是你来一个哀求，我重新开始给你播放一次视频文件。
这个东西的底层是向一个fTo指针里面拷贝264码流。
假如你Cpp、coding能力强的话，应该是能看懂直接改的，也就不用往后看了。
参考demo 零声 usb相机推流

网上基本上和我需求最接近的live555方案下的代码是国内的做音视频开发教学的一个零声出的视频还有他们传的这个代码。
主要功能是 v4l2相机读取mjpeg，然后ffmpeg的avcodec相关库编码，然后送live555，然后推实时流，像是改的testOnDemandRTSPServer，结构很清晰，除了不能用我也找不到原因外都挺好的。另外他的课是5K的，有点贵。
视频的话去B站带关键词，基本都能搜到，这个代码我加了那个联系QQ要到的。但是在我本地没有推成功，我也不确定是哪里的题目，编译过了，放在这里
https://gitee.com/qingfuliao/v4l2_ipc_live555?_from=gitee_search
在我这是下面这个demo 实现了一个相似的功能，编译实测是可以读取usb相机然后推流成功的。但是代码结构没有上面那个清晰。
参考demo

https://github.com/mpromonet/v4l2rtspserver
这个功能是基于linux的v4l2,使用264的方式读取相机视频流（假如你的usb相机不支持264输出，会驱动失败），然后直接拆帧把流发出去
需要自己下一个libv4l2cpp的代码放进来就能编译了
这个如今看轻微改一改就能用了，不外当时对团体没有概念，改了一阵子不知道怎么动手把我自己的码流酿成demo的输入，码流送进去了但是没有推成功，定位了一会儿很难定位题目，也就搁置了。有爱好的可以基于这个改一改。
https://blog.csdn.net/qq_43418269/article/details/122488866
这个方案我是成功了的，不外延时不太能满足我的需求，这个复现很快。他是用一个管道文件做的，我把编码之后264文件直接写到live555的testOnDemandRTSPServer.cpp这边的读取文件里面，然后逻辑是live555这边接收到哀求，创建管道，相机程序初始化后阻塞住，管道被创建后往管道里写，然后另一边就开始播。。
这个就相称于是运行在一个demo里的两个程序。流倒是推出来了，只不外，我如许实现，延时很大，他说的百毫秒量级我做不到，我是2s左右。感觉也大概是我操作不当。
https://blog.csdn.net/lifexx/article/details/52823777
live555读文件改为内存读取实现，确实C++不太行，这个文章对我理解Live555，还有改成内存中的数据方向给了很大启发，但是没有按照他的做，而且他的参考代码无法运行。对我理解另一个推相机的demo有帮助
其他开源服务器框架

这个也是一个很容易就编译成功的服务器，可以使用这个做服务器，然后调用ffmpeg推流，在RK3588上也推成功了，基本没改make相关的配置，需要按照他给的快速开始流程使用git下附加库，功能很强大，但是对我的需求来讲，这个功能我进行二次开发比力慢。不排除我太菜。
https://github.com/ZLMediaKit/ZLMediaKit/tree/master
这里写这个的主要原因是他的一些文章对我的启发和快速上手有很大的参考意义，比如下面这个。
https://github.com/ZLMediaKit/ZLMediaKit/wiki/%E6%80%8E%E4%B9%88%E6%B5%8B%E8%AF%95ZLMediaKit%E7%9A%84%E5%BB%B6%E6%97%B6%EF%BC%9F
RK3399 参考

网上有瑞芯微其他方案的rtsp推流，我只能帮忙排除错误选项
https://t.rock-chips.com/forum.php?mod=viewthread&tid=749&extra=page%3D1
假如你是在看这个帖子，可以不用看了，这个猫头的代码虽然推出去了，但是他的Rtsp是调库，这个库是闭源的，3588没有，这个网站注册要两三天才气通过，不必等这个，用不了。
rtsp推流

在github上搜刮rtsp,排名最高的那个结果，就是那个小乌龟，
https://github.com/PHZ76/RtspServer
这个功能比力单一，但是充足满足我的需求了，他还使用他自己的库做了一个windows下的应用，windows上编译成功了，但是不太好用，不外对我理解他的Demo运行有一定帮助。由于用的是一套库。另外他主页还有一个rtmp ,我没进去看也没试能不能用。
https://github.com/PHZ76/DesktopSharing

下载安装

下载下来直接在3588上面make就可以，编译的是RtspServer-master/example里面的main 文件，这里的rtsp_h264_file.cpp是可以直接推运行推264文件的，一般不需要修改就能直接用，假如不能用，有大概是554端口被占用，改一个大点的就好了

1.     std::string suffix = "live";
2.         std::string ip = "127.0.0.1";
3.         std::string port = "5543";// 改这里 不要改那个"0.0.0.0" 那个是对的不用改
4.         std::string rtsp_url = "rtsp://" + ip + ":" + port + "/" + suffix;

复制代码

然后rtsp_pusher.cpp还有rtsp_server.cpp都把发送文件的部门注释掉了，需要结合h264那个文件来对比把264码流写进去。
运行测试

编译出来之后运行 ./rtsp_h264_file ./test.264 就能推出来了
工程已经被我魔改过了，重新生成一个sample 来演示下结果
这是RK3588 服务器

这是VLC的界面IP

下面的是显示的结果

改cmake 支持opencv 、rknn,mpp

由于我使用的RKNN之间是在Qt里面编译的，工程使用的都是Cmake的cmakelists，他的makefile也不难改，主要的题目是我自己写的解码器，在使用makefile指定mpp库之后编译出来的mpp库运行不正常，详细报错找不到了，然后我qt上用是没题目的，定位到是makefile没写好，改成cmakelist就可以正常编译了
-g是为了支持gdb调试，配合我的vscode 调试配置文件，可以单步调试，全程在板上编译，没配置交织编译环境

1. cmake_minimum_required(VERSION 3.5)
2. project(rtspserver)
3. set(CMAKE_INCLUDE_CURRENT_DIR ON)
5. set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -DSOCKLEN_T=socklen_t -g ")
7. find_package(OpenCV 4.5.5 REQUIRED)
8. find_package(OpenSSL REQUIRED)
10. # MPP
11. set(MPP_PATH /home/orangepi/code/mpp-develop/inc)
12. set(MPP_LIBS /home/orangepi/code/mpp-develop/mpp/librockchip_mpp.so)
13. include_directories(${MPP_PATH})
15. # OSAL
16. set(OSAL_PATH /home/orangepi/code/mpp-develop/osal/inc/ /home/orangepi/code/mpp-develop/utils)
17. set(OSAL_LIBS /home/orangepi/code/mpp-develop/osal/libosal.a /home/orangepi/code/mpp-develop/utils/libutils.a)
18. include_directories(${OSAL_PATH})
20. # RKNN lib
21. set(RKNN_API_PATH ${CMAKE_SOURCE_DIR}/lib)
22. set(RKNN_RT_LIB ${RKNN_API_PATH}/aarch64/librknnrt.so)
23. include_directories(${RKNN_API_PATH}/include)
24. include_directories(${CMAKE_SOURCE_DIR}/3rdparty)
26. # RGA
27. set(RGA_PATH ${CMAKE_SOURCE_DIR}/3rdparty/rga/RK3588)
28. set(RGA_LIB ${RGA_PATH}/lib/Linux/aarch64/librga.so)
29. include_directories(${RGA_PATH}/include)
32. aux_source_directory(src/xop SOURCE1)
33. aux_source_directory(src/net SOURCE2)
35. include_directories(   
36.     src   
37.     src/xop
38.     src/net
39.     src/3rdpart
40.     )
42. # add_executable(rtsp
43. # example/rtsp_server.cpp
44. # ${SOURCE1}
45. # ${SOURCE2}
46. # src/3rdpart/md5/md5.hpp
47. # )
48. # target_link_libraries(rtsp ${MPP_LIBS} ${OSAL_LIBS}  ${OpenCV_LIBS} ${RKNN_RT_LIB} ${RGA_LIB} OpenSSL::SSL OpenSSL::Crypto )
49. # add_executable(rh264
50. # example/rtsp_h264_file.cpp
51. # ${SOURCE1}
52. # ${SOURCE2}
53. # src/3rdpart/md5/md5.hpp
54. # )
55. # target_link_libraries(rh264 ${MPP_LIBS} ${OSAL_LIBS}  ${OpenCV_LIBS} OpenSSL::SSL OpenSSL::Crypto )
56. add_executable(sample
57. example/sample.cpp
58. ${SOURCE1}
59. ${SOURCE2}
60. src/3rdpart/md5/md5.hpp
61. )
62. target_link_libraries(sample ${MPP_LIBS} ${OSAL_LIBS}  ${OpenCV_LIBS}  ${RKNN_RT_LIB} ${RGA_LIB} OpenSSL::SSL OpenSSL::Crypto )

复制代码

代码修改

代码是基于他的rtsp_server来修改的，主要修改的内容是sendFrameThread,大概思绪是如许的，还差一个题目，怎么把你的原始mat图像转成264码流

1. bool IsKeyFrame(const char* data, uint32_t size)
2. {
3.         if (size > 4) {
4.                 //0x67:sps ,0x65:IDR, 0x6: SEI
5.                 if (data[4] == 0x67 || data[4] == 0x65 ||
6.                         data[4] == 0x6 || data[4] == 0x27) {
7.                         return true;
8.                 }
9.         }
11.         return false;
12. }
14. void SendFrameThread(xop::RtspServer* rtsp_server, xop::MediaSessionId session_id, int& clients)
15. {      
16.         encoder e;
17.    
18.        
19.    
20. //  encoder相关 内存拷贝
21.         int size = 0;
22.         char* buffer ;
24.         // 编码标志位
25.     int i = 0;
27.     // 生成图像
28.     int width = 1920;
29.     int height = 1080;
30.         cv::Mat colorBar= cv::Mat::zeros(height, width, CV_8UC3);
31.     // 设置彩条的宽度
32.     int barWidth = width / 8; // 8个彩条，你可以根据需要调整
33.     // 生成彩条
34.     for (int i = 0; i < 8; ++i) {
35.         // 计算彩条的起始和结束位置
36.         int startX = i * barWidth;
37.         int endX = (i + 1) * barWidth;
38.         // 设置彩条颜色（BGR格式）
39.         cv::Vec3b color;
40.         if (i % 2 == 0) {
41.             color = cv::Vec3b(255, 0, 155); // 蓝色
42.         } else {
43.             color = cv::Vec3b(0, 255, 0); // 绿色
44.         }
45.         // 在colorBar上画出彩条
46.         colorBar(cv::Rect(startX, 0, barWidth, height)) = color;
47.     }
49.         while(1)
50.         {
51.                
52.                 if(clients > 0) /* 会话有客户端在线, 发送音视频数据 */
53.                 {
54.                         {     
55.                                 xop::AVFrame videoFrame = {0};
56.                                 // printf("width is %d, height is %d",colorBar.rows,colorBar.cols);
57.                                 // 编码 发包
58.                                 if(0==i){
59.                                         // 第一帧有sps信息 给他两帧拼一起
60.                                         char *buffer1;
61.                                         int size1;
62.                                         e.init(buffer1,size1);
63.                                         videoFrame.size = size1;
64.                                         e.postAframe(colorBar,buffer,size);
65.                                         videoFrame.size += size;                                       
66.                                         videoFrame.buffer.reset(new uint8_t[videoFrame.size]);
67.                                         memcpy(videoFrame.buffer.get(), buffer1, size1);
68.                                         memcpy(videoFrame.buffer.get()+size1, buffer, size);
69.                                         i++;
70.                                 }               
71.                                 else{
72.                                         e.postAframe(colorBar,buffer,size);
73.                                         videoFrame.size = size;  // 视频帧大小
74.                                         videoFrame.buffer.reset(new uint8_t[videoFrame.size]);
75.                                         memcpy(videoFrame.buffer.get(), buffer, videoFrame.size);
76.                                 }
77.                                
79.                                
80.                                 videoFrame.type = IsKeyFrame(buffer, size) ? xop::VIDEO_FRAME_I : xop::VIDEO_FRAME_P;
81.                                 // videoFrame.type = 0; // 建议确定帧类型。I帧(xop::VIDEO_FRAME_I) P帧(xop::VIDEO_FRAME_P)
83.                                 videoFrame.timestamp = xop::H264Source::GetTimestamp(); // 时间戳, 建议使用编码器提供的时间戳
84.                                                        
85.                                 // writeCharPointerToFile((char *)videoFrame.buffer.get(), videoFrame.size,  "filename.txt");               
86.                                 rtsp_server->PushFrame(session_id, xop::channel_0, videoFrame); //送到服务器进行转发, 接口线程安全
87.                                 /*
88.                                 //获取一帧 H264, 打包
89.                                 xop::AVFrame videoFrame = {0};
90.                                 videoFrame.type = 0; // 建议确定帧类型。I帧(xop::VIDEO_FRAME_I) P帧(xop::VIDEO_FRAME_P)
91.                                 videoFrame.size = video frame size;  // 视频帧大小
92.                                 videoFrame.timestamp = xop::H264Source::GetTimestamp(); // 时间戳, 建议使用编码器提供的时间戳
93.                                 videoFrame.buffer.reset(new uint8_t[videoFrame.size]);                    
94.                                 memcpy(videoFrame.buffer.get(), video frame data, videoFrame.size);                                       
95.                   
96.                                 rtsp_server->PushFrame(session_id, xop::channel_0, videoFrame); //送到服务器进行转发, 接口线程安全
97.                                 */
98.                         }
99.                     
100.                         {                               
101.                                 /*
102.                                 //获取一帧 AAC, 打包
103.                                 xop::AVFrame audioFrame = {0};
104.                                 audioFrame.type = xop::AUDIO_FRAME;
105.                                 audioFrame.size = audio frame size;  /* 音频帧大小
106.                                 audioFrame.timestamp = xop::AACSource::GetTimestamp(44100); // 时间戳
107.                                 audioFrame.buffer.reset(new uint8_t[audioFrame.size]);                    
108.                                 memcpy(audioFrame.buffer.get(), audio frame data, audioFrame.size);
110.                                 rtsp_server->PushFrame(session_id, xop::channel_1, audioFrame); // 送到服务器进行转发, 接口线程安全
111.                                 */
112.                         }               
113.                 }
114.                 // xop::Timer::Sleep(20);  /* 实际使用需要根据帧率计算延时!  我这里处理延时很大，就不人工延迟了*/
115.         }
116.         videocapture->release();
117.         e.deinit((MPP_RET)0);
118.         yolo5.deinit();
120. }

复制代码

rk3588编码

这方面网上的文章不太多，但是官方给了demo，都是中文，认真看看，功能都是能用的。
主要参考他的mpp-develop/test/mpi_enc_test 以及Rk3588-linux-v002\linux\docs\Linux\Multimedia\Rockchip_Developer_Guide_MPP_CN.pdf进行配置和使用。这相关的东西我之后再另开一个文章单独说，总之参考这部门可以做一个BGR888转成264存储的demo。
这里重点说一个概念，I、P、B帧
这个东西是264流编码的一个概念，正常你每一帧的图像都很大，比如一个1920*1080，每个像素点存一个BGR888的话，就是1920*1080*3 Byte =6220800 Byte ≈ 6M ，然后一秒30帧的话，一秒就要传180M，局域网或许勉强可以，但是对带宽压力也很大。以是这里就涉及到了压缩，264、265就是压缩标准，压缩中需要做两种压缩 帧内压缩和 帧间压缩。

• 帧内压缩：使用一定方法使用只管小的空间存一帧数据。
  
• 帧间压缩：利用帧和前后帧的关联来进一步的压缩视频。
  

这里我们重点关注帧间压缩。给一个参考文献
https://zhuanlan.zhihu.com/p/409527359
说的挺透彻的,这里我大略说一下，看下面这个图

I帧 ，是帧间压缩里面的一帧完备图像，P帧是前向预测帧，B帧是双向预测帧
IDR帧是特别的I帧，在编解码时候P、B帧可以参考I帧前面的帧进行复原，但是不能参考IDR帧前面的帧进行复原
而一个上面如许的循环，被编码成一组，我们指定了h264的gop大小，就确定了多少帧中有一个I帧
而我们在做直播，就导致为了低延时，不要B帧，gop 也要只管的不要太大，假如要解码P帧，前面就一定要缓存I帧，
监测工具

wireshark， 这个感觉还是蛮必要的，至少你能瞥见客户端和服务器之间说没语言。假如你有耐心开RTSP 或者网络协议握手说明的话，你甚至能看到他们之间的握手流程。
杂记

中间碰到了一个题目，由于我这个地方没有公网，以是只能自己给开一个热点给电脑，PC和RK3588之间通过路由器连接，然后使用前面的某个demo的时候碰到的，主机向服务器（RK3588）发出视频哀求时，服务器并没有直接给客户端发rtcp包，而是给一个200多的地址发包，而这个包在客户端收不到，但是他能收到rtp的协议包，以是vlc这边也不提示打不开，就是没有图像显示。
后来使用的方法是，和板子通过路由器网线连接，然后电脑PC wifi 连接路由器，然后路由器没有公网，再使用一个手机usb给电脑共享网络，让我的调试环境稳固可以接受到3588的流，和路由器网线连接的时候接受不到包，感觉是由于路由器没有网，使用网线连接时候被屏蔽了服务器功能，以是交给路由器的包转发哀求没有被PC识别到，但是wifi连接的话，就算他没有网，也是不能忽略的。 目前是如许理解的。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。