SRT库介绍

2024-09-07 04:28
文章标签 介绍 srt

本文主要是介绍SRT库介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 简介
  • SRT协议介绍
  • FFmpeg+SRS推拉流测试
  • SRT库介绍
    • apps示例程序
      • srt-file-transmit
      • srt-live-transmit
      • srt-test-multiplex
      • srt-test-relay
      • srt-tunnel
  • docs/build
    • srtcore
    • examples
    • 编译 安装
    • 错误处理
  • API说明
    • 初始化、回收
    • 创建配置套接字
    • 连接
    • 管理Socket Group
    • 属性设置
    • 传输
    • 数据统计/性能跟踪
    • 异步操作
    • 日志操作
    • 时间
    • 异常和错误码
  • 测试

简介

SRT（Secure Reliable Transport，安全可靠的传输）是一种由Haivision开发的开源、低延迟、高带宽的网络流媒体传输协议。它旨在通过互联网提供安全、高质量的视频流，特别适用于直播、视频会议、监控等领域。SRT协议建立在UDT（基于UDP的数据传输协议）之上，继承了UDP速度快、开销低的优点，并增加了可靠性、安全性和低延迟等特性。

SRT协议介绍

参照 SRT协议介绍

https://blog.csdn.net/zhangdonghuirjdd/article/details/141900896

FFmpeg+SRS推拉流测试

详情参照 SRT推拉流环境搭建以及测试

https://blog.csdn.net/zhangdonghuirjdd/article/details/141951777

SRT库介绍

源码下载地址

https://github.com/Haivision/srt/

解压后
在这里插入图片描述

apps示例程序

其中 apps中的工具（示例程序）源码包括
在这里插入图片描述

srt-file-transmit

通过srt传输文件的工具

srt-live-transmit

是一个示例应用程序 ，一种通用的数据传输工具，用于在srt和其他程序之间传输数据。

srt-test-multiplex

示例程序 演示一个通道中发送多路流（多路流复用）

           +--                                                   --+|   id=1                                         id=1   ||  ------                                      -------  ||         \               ----->              /         ||   id=2   \  ----------------------------   /   id=2   |
port=5555 -|  --------- (   multiplexed UDP stream   ) ----------  |- port=2000|          /  ----------------------------   \          ||   id=3  /                                   \  id=3   ||  ------                                       ------  |+--                                                   --+

srt-test-relay

示例程序 流中继/转发

srt-tunnel

srt-tunnel 命令测试 作用是将srt协议用作tcp协议的隧道，文档见于doc/srt-tunnel.md

 <TCP client> --> <Tunnel: TCP->SRT> --> .......(远距离)....--> <Tunnel: SRT->TCP> --> <TCP server>

docs/build

本库在各个系统下的编译说明
在这里插入图片描述

srtcore

协议栈核心代码
在这里插入图片描述

examples

一些常用方法调用例子 ，包括数据、文件的发送接受，客户端、服务器调用例子

在这里插入图片描述

编译 安装

./configure
make

注意 如果要选择编译器 configure 需要加 “–with-compiler-prefix”则是编译器的路径

错误处理

如果出现

error: ‘for’ loop initial declarations are only allowed in C99 mode
for (size_t i = 0; i < sizeof(aad) / 4; ++i)

修改代码 变量定义放在for 循环之外
编译完成
在这里插入图片描述

API说明

初始化、回收

int srt_startup(void);
int srt_cleanup(void);

创建配置套接字

SRTSOCKET srt_socket(int af, int type, int protocol);
SRTSOCKET srt_create_socket();
int srt_bind(SRTSOCKET u, const struct sockaddr* name, int namelen);
int srt_bind_acquire(SRTSOCKET u, UDPSOCKET udpsock);
SRT_SOCKSTATUS srt_getsockstate(SRTSOCKET u);
int srt_getsndbuffer(SRTSOCKET sock, size_t* blocks, size_t* bytes);
int srt_close(SRTSOCKET u);

连接

int srt_listen(SRTSOCKET u, int backlog);
SRTSOCKET srt_accept(SRTSOCKET lsn, struct sockaddr* addr, int* addrlen);
SRTSOCKET srt_accept_bond(const SRTSOCKET listeners[], int nlisteners, int msTimeOut);
int srt_listen_callback(SRTSOCKET lsn, srt_listen_callback_fn* hook_fn, void* hook_opaque);
int srt_connect(SRTSOCKET u, const struct sockaddr* name, int namelen);
int srt_connect_bind(SRTSOCKET u, const struct sockaddr* source,const struct sockaddr* target, int len);
int srt_connect_debug(SRTSOCKET u, const struct sockaddr* name, int namelen, int forced_isn);  
int srt_rendezvous(SRTSOCKET u, const struct sockaddr* local_name, int local_namelen,const struct sockaddr* remote_name, int remote_namelen);      int srt_connect_callback(SRTSOCKET u, srt_connect_callback_fn* hook_fn, void* hook_opaque);

管理Socket Group

typedef struct SRT_SocketGroupData_
{SRTSOCKET id;struct sockaddr_storage peeraddr;SRT_SOCKSTATUS sockstate;uint16_t weight;SRT_MEMBERSTATUS memberstate;int result;int token;
} SRT_SOCKGROUPDATA;
SRTSOCKET srt_create_group(SRT_GROUP_TYPE type);
int srt_group_data(SRTSOCKET socketgroup, SRT_SOCKGROUPDATA output[], size_t* inoutlen);
int srt_connect_group(SRTSOCKET group,SRT_SOCKGROUPCONFIG name [], int arraysize);
SRT_SOCKGROUPCONFIG srt_prepare_endpoint(const struct sockaddr* src /*nullable*/,const struct sockaddr* dst, int namelen);
SRT_SOCKOPT_CONFIG* srt_create_config();    
void srt_delete_config(SRT_SOCKOPT_CONFIG* c);
int srt_config_add(SRT_SOCKOPT_CONFIG* c, SRT_SOCKOPT opt, void* val, int len);

属性设置

int srt_getpeername(SRTSOCKET u, struct sockaddr* name, int* namelen);
int srt_getsockname(SRTSOCKET u, struct sockaddr* name, int* namelen);
int srt_getsockopt(SRTSOCKET u, int level /*ignored*/, SRT_SOCKOPT opt, void* optval, int* optlen);
int srt_getsockflag(SRTSOCKET u, SRT_SOCKOPT opt, void* optval, int* optlen);
uint32_t srt_getversion();

传输

int srt_send(SRTSOCKET u, const char* buf, int len);
int srt_sendmsg(SRTSOCKET u, const char* buf, int len, int ttl/* = -1*/, int inorder/* = false*/);
int srt_sendmsg2(SRTSOCKET u, const char* buf, int len, SRT_MSGCTRL *mctrl);int srt_recv(SRTSOCKET u, char* buf, int len);
int srt_recvmsg(SRTSOCKET u, char* buf, int len);
int srt_recvmsg2(SRTSOCKET u, char *buf, int len, SRT_MSGCTRL *mctrl);
int64_t srt_sendfile(SRTSOCKET u, const char* path, int64_t* offset, int64_t size, int block);
int64_t srt_recvfile(SRTSOCKET u, const char* path, int64_t* offset, int64_t size, int block);

数据统计/性能跟踪

// Performance monitor with Byte counters for better bitrate estimation.
int srt_bstats(SRTSOCKET u, SRT_TRACEBSTATS * perf, int clear);// Performance monitor with Byte counters and instantaneous stats instead of moving averages for Snd/Rcvbuffer sizes.
int srt_bistats(SRTSOCKET u, SRT_TRACEBSTATS * perf, int clear, int instantaneous);

异步操作

int srt_epoll_create(void);
int srt_epoll_add_usock(int eid, SRTSOCKET u, const int* events);
int srt_epoll_add_ssock(int eid, SYSSOCKET s, const int* events);
int srt_epoll_update_usock(int eid, SRTSOCKET u, const int* events);
int srt_epoll_update_ssock(int eid, SYSSOCKET s, const int* events);int srt_epoll_remove_usock(int eid, SRTSOCKET u);
int srt_epoll_remove_ssock(int eid, SYSSOCKET s);int srt_epoll_wait(int eid, SRTSOCKET* readfds, int* rnum, SRTSOCKET* writefds, int* wnum, int64_t msTimeOut,SYSSOCKET* lrfds, int* lrnum, SYSSOCKET* lwfds, int* lwnum);
int srt_epoll_uwait(int eid, SRT_EPOLL_EVENT* fdsSet, int fdsSize, int64_t msTimeOut);
int srt_epoll_clear_usocks(int eid);
int32_t srt_epoll_set(int eid, int32_t flags);
int srt_epoll_release(int eid);

日志操作

void srt_setloglevel(int ll);
void srt_addlogfa(int fa);
void srt_dellogfa(int fa);
void srt_resetlogfa(const int* fara, size_t fara_size);
void srt_setloghandler(void* opaque, SRT_LOG_HANDLER_FN* handler);
typedef void SRT_LOG_HANDLER_FN(void* opaque, int level, const char* file, int line, const char* area, const char* message);
void srt_setlogflags(int flags);

时间

int64_t srt_time_now();
int64_t srt_connection_time(SRTSOCKET sock);
int srt_clock_type(void);

异常和错误码

int srt_getlasterror(int* errno_loc);
const char* srt_strerror(int code, int errnoval);
const char* srt_getlasterror_str(void);
void srt_clearlasterror(void);
const char* srt_rejectreason_str(enum SRT_REJECT_REASON id);
int srt_setrejectreason(SRTSOCKET sock, int value);
int srt_getrejectreason(SRTSOCKET sock);

常见失败原因
在这里插入图片描述

错误码
在这里插入图片描述

测试

#ifndef _WIN32#include <cstdlib>#include <netdb.h>
#else#include <winsock2.h>#include <ws2tcpip.h>
#endif
#include <fstream>
#include <iostream>
#include <string>
#include <cstring>
#include <srt.h>using namespace std;#ifndef _WIN32
void* sendfile(void*);
#else
DWORD WINAPI sendfile(LPVOID);
#endifint main(int argc, char* argv[])
{if ((2 < argc) || ((2 == argc) && (0 == atoi(argv[1])))){cout << "usage: sendfile [server_port]" << endl;return 0;}// Initialize the SRT library.srt_startup();addrinfo hints;addrinfo* res;memset(&hints, 0, sizeof(struct addrinfo));hints.ai_flags = AI_PASSIVE;hints.ai_family = AF_INET;hints.ai_socktype = SOCK_DGRAM;string service("9000");if (2 == argc)service = argv[1];if (0 != getaddrinfo(NULL, service.c_str(), &hints, &res)){cout << "illegal port number or port is busy.\n" << endl;return 0;}SRTSOCKET serv = srt_create_socket();// SRT requires that third argument is always SOCK_DGRAM. The Stream API is set by an option,// although there's also lots of other options to be set, for which there's a convenience option,// SRTO_TRANSTYPE.SRT_TRANSTYPE tt = SRTT_FILE;srt_setsockopt(serv, 0, SRTO_TRANSTYPE, &tt, sizeof tt);// Windows UDP issue// For better performance, modify HKLM\System\CurrentControlSet\Services\Afd\Parameters\FastSendDatagramThreshold
#ifdef _WIN32int mss = 1052;srt_setsockopt(serv, 0, SRTO_MSS, &mss, sizeof(int));
#endifif (SRT_ERROR == srt_bind(serv, res->ai_addr, res->ai_addrlen)){cout << "bind: " << srt_getlasterror_str() << endl;return 0;}freeaddrinfo(res);cout << "server is ready at port: " << service << endl;srt_listen(serv, 10);sockaddr_storage clientaddr;int addrlen = sizeof(clientaddr);SRTSOCKET fhandle;// Accept multiple client connections.while (true){if (SRT_INVALID_SOCK == (fhandle = srt_accept(serv, (sockaddr*)&clientaddr, &addrlen))){cout << "accept: " << srt_getlasterror_str() << endl;return 0;}char clienthost[NI_MAXHOST];char clientservice[NI_MAXSERV];getnameinfo((sockaddr *)&clientaddr, addrlen, clienthost, sizeof(clienthost), clientservice, sizeof(clientservice), NI_NUMERICHOST|NI_NUMERICSERV);cout << "new connection: " << clienthost << ":" << clientservice << endl;#ifndef _WIN32pthread_t filethread;pthread_create(&filethread, NULL, sendfile, new SRTSOCKET(fhandle));pthread_detach(filethread);
#elseCreateThread(NULL, 0, sendfile, new SRTSOCKET(fhandle), 0, NULL);
#endif}srt_close(serv);// Signal to the SRT library to clean up all allocated sockets and resources.srt_cleanup();return 0;
}#ifndef _WIN32
void* sendfile(void* usocket)
#else
DWORD WINAPI sendfile(LPVOID usocket)
#endif
{SRTSOCKET fhandle = *(SRTSOCKET*)usocket;delete (SRTSOCKET*)usocket;// Acquiring file name information from client.char file[1024];int len;if (SRT_ERROR == srt_recv(fhandle, (char*)&len, sizeof(int))){cout << "recv: " << srt_getlasterror_str() << endl;return 0;}if (SRT_ERROR == srt_recv(fhandle, file, len)){cout << "recv: " << srt_getlasterror_str() << endl;return 0;}file[len] = '\0';// Open the file only to know its size.fstream ifs(file, ios::in | ios::binary);ifs.seekg(0, ios::end);const int64_t size = ifs.tellg();ifs.close();// Send file size.if (SRT_ERROR == srt_send(fhandle, (char*)&size, sizeof(int64_t))){cout << "send: " << srt_getlasterror_str() << endl;return 0;}SRT_TRACEBSTATS trace;srt_bstats(fhandle, &trace, true);// Send the file itself.int64_t offset = 0;if (SRT_ERROR == srt_sendfile(fhandle, file, &offset, size, SRT_DEFAULT_SENDFILE_BLOCK)){cout << "sendfile: " << srt_getlasterror_str() << endl;return 0;}srt_bstats(fhandle, &trace, true);cout << "speed = " << trace.mbpsSendRate << "Mbits/sec" << endl;const int64_t losspercent = 100 * trace.pktSndLossTotal / trace.pktSent;cout << "network loss = " << trace.pktSndLossTotal << "pkts (" << losspercent << "%)\n";srt_close(fhandle);#ifndef _WIN32return NULL;#elsereturn 0;#endif
}

这篇关于SRT库介绍的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1144048。

相关文章

性能测试介绍

性能测试介绍

性能测试是一种测试方法，旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试，可以确定系统是否能够满足预期的性能要求，找出性能瓶颈和潜在的问题，并进行优化和调整。 发现性能瓶颈：性能测试可以帮助发现系统的性能瓶颈，即系统在高负载或高并发情况下可能出现的问题
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...
Hadoop数据压缩使用介绍

Hadoop数据压缩使用介绍

一、压缩原则 （1）运算密集型的Job，少用压缩 （2）IO密集型的Job，多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1）为了支持多种压缩/解压缩算法，Hadoop引入了编码/解码器 2）要在Hadoop中启用压缩，可以配置如下参数
阅读更多...
图神经网络模型介绍（1）

图神经网络模型介绍（1）

我们将图神经网络分为基于谱域的模型和基于空域的模型，并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络：谱图卷积网络、切比雪夫网络和图卷积网络。 （1）谱图卷积网络 卷积定理：函数卷积的傅里叶变换是函数傅里叶变换的乘积，即F{f*g}
阅读更多...
C++——stack、queue的实现及deque的介绍

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现
阅读更多...
Mysql BLOB类型介绍

Mysql BLOB类型介绍

BLOB类型的字段用于存储二进制数据 在MySQL中，BLOB类型，包括：TinyBlob、Blob、MediumBlob、LongBlob，这几个类型之间的唯一区别是在存储的大小不同。 TinyBlob 最大 255 Blob 最大 65K MediumBlob 最大 16M LongBlob 最大 4G
阅读更多...
FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和移植STM32

FreeRTOS-基本介绍和STM32移植 一、裸机开发和操作系统开发介绍二、任务调度和任务状态介绍2.1 任务调度2.1.1 抢占式调度2.1.2 时间片调度 2.2 任务状态 三、FreeRTOS源码和移植STM323.1 FreeRTOS源码3.2 FreeRTOS移植STM323.2.1 代码移植3.2.2 时钟中断配置 一、裸机开发和操作系统开发介绍 裸机：前后台系
阅读更多...
nginx介绍及常用功能

nginx介绍及常用功能

什么是nginx nginx跟Apache一样，是一个web服务器（网站服务器），通过HTTP协议提供各种网络服务。 Apache：重量级的，不支持高并发的服务器。在Apache上运行数以万计的并发访问，会导致服务器消耗大量内存。操作系统对其进行进程或线程间的切换也消耗了大量的CPU资源，导致HTTP请求的平均响应速度降低。这些都决定了Apache不可能成为高性能WEB服务器  nginx：
阅读更多...
多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

多路转接之select(fd_set介绍,参数详细介绍),实现非阻塞式网络通信

目录 多路转接之select 引入 介绍 fd_set 函数原型 nfds readfds / writefds / exceptfds readfds  总结  fd_set操作接口  timeout timevalue 结构体 传入值 返回值 代码 注意点 -- 调用函数 select的参数填充  获取新连接 注意点 -- 通信时的调用函数 添加新fd到
阅读更多...
火语言RPA流程组件介绍--浏览网页

火语言RPA流程组件介绍--浏览网页

🚩【组件功能】：浏览器打开指定网址或本地html文件 配置预览 配置说明 网址URL 支持T或# 默认FLOW输入项 输入需要打开的网址URL 超时时间 支持T或# 打开网页超时时间 执行后后等待时间(ms) 支持T或# 当前组件执行完成后继续等待的时间 UserAgent 支持T或# User Agent中文名为用户代理，简称 UA，它是一个特殊字符串头，使得服务器
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2