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。

相关文章

Python中win32包的安装及常见用途介绍

Python中win32包的安装及常见用途介绍

《Python中win32包的安装及常见用途介绍》在Windows环境下,PythonWin32模块通常随Python安装包一起安装,：本文主要介绍Python中win32包的安装及常见用途的相关... 目录前言主要组件安装方法常见用途1. 操作Windows注册表2. 操作Windows服务3. 窗口操作
阅读更多...
c++中的set容器介绍及操作大全

c++中的set容器介绍及操作大全

《c++中的set容器介绍及操作大全》：本文主要介绍c++中的set容器介绍及操作大全,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录​​一、核心特性​​️ ​​二、基本操作​​​​1. 初始化与赋值​​​​2. 增删查操作​​​​3. 遍历方
阅读更多...
HTML img标签和超链接标签详细介绍

HTML img标签和超链接标签详细介绍

《HTMLimg标签和超链接标签详细介绍》：本文主要介绍了HTML中img标签的使用，包括src属性（指定图片路径）、相对/绝对路径区别、alt替代文本、title提示、宽高控制及边框设置等，详细内容请阅读本文，希望能对你有所帮助... 目录img 标签src 属性alt 属性title 属性width/h
阅读更多...
MybatisPlus service接口功能介绍

MybatisPlus service接口功能介绍

《MybatisPlusservice接口功能介绍》：本文主要介绍MybatisPlusservice接口功能介绍,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友... 目录Service接口基本用法进阶用法总结：Lambda方法Service接口基本用法MyBATisP
阅读更多...
MySQL复杂SQL之多表联查/子查询详细介绍(最新整理)

MySQL复杂SQL之多表联查/子查询详细介绍(最新整理)

《MySQL复杂SQL之多表联查/子查询详细介绍(最新整理)》掌握多表联查(INNERJOIN,LEFTJOIN,RIGHTJOIN,FULLJOIN)和子查询（标量、列、行、表子查询、相关/非相关、... 目录第一部分：多表联查 (JOIN Operations)1. 连接的类型 (JOIN Types)
阅读更多...
java中BigDecimal里面的subtract函数介绍及实现方法

java中BigDecimal里面的subtract函数介绍及实现方法

《java中BigDecimal里面的subtract函数介绍及实现方法》在Java中实现减法操作需要根据数据类型选择不同方法,主要分为数值型减法和字符串减法两种场景,本文给大家介绍java中BigD... 目录Java中BigDecimal里面的subtract函数的意思？一、数值型减法（高精度计算）1.
阅读更多...
Pytorch介绍与安装过程

Pytorch介绍与安装过程

《Pytorch介绍与安装过程》PyTorch因其直观的设计、卓越的灵活性以及强大的动态计算图功能,迅速在学术界和工业界获得了广泛认可,成为当前深度学习研究和开发的主流工具之一,本文给大家介绍Pyto... 目录1、Pytorch介绍1.1、核心理念1.2、核心组件与功能1.3、适用场景与优势总结1.4、优
阅读更多...
Java实现本地缓存的常用方案介绍

Java实现本地缓存的常用方案介绍

《Java实现本地缓存的常用方案介绍》本地缓存的代表技术主要有HashMap,GuavaCache,Caffeine和Encahche,这篇文章主要来和大家聊聊java利用这些技术分别实现本地缓存的方... 目录本地缓存实现方式HashMapConcurrentHashMapGuava CacheCaffe
阅读更多...
Spring Security介绍及配置实现代码

Spring Security介绍及配置实现代码

《SpringSecurity介绍及配置实现代码》SpringSecurity是一个功能强大的Java安全框架,它提供了全面的安全认证(Authentication)和授权(Authorizatio... 目录简介Spring Security配置配置实现代码简介Spring Security是一个功能强
阅读更多...
JSR-107缓存规范介绍

JSR-107缓存规范介绍

《JSR-107缓存规范介绍》JSR是JavaSpecificationRequests的缩写,意思是Java规范提案,下面给大家介绍JSR-107缓存规范的相关知识,感兴趣的朋友一起看看吧... 目录1.什么是jsR-1072.应用调用缓存图示3.JSR-107规范使用4.Spring 缓存机制缓存是每一
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2