网站备案查询不出来,软件管理工程师,做网站平方根怎么表示,外贸公司英文网站建设1#xff1a;功能介绍 在视频这类大文件的传输过程中#xff0c;经常会因为文件太大而受到网络带宽的限制。比如在实现视频预览功能时#xff0c;常常会出现长时间加载、缓存卡顿的问题。我在项目中也遇到了类似的情况#xff0c;于是采用了这个解决方案。 我们可以利用 FF…1功能介绍 在视频这类大文件的传输过程中经常会因为文件太大而受到网络带宽的限制。比如在实现视频预览功能时常常会出现长时间加载、缓存卡顿的问题。我在项目中也遇到了类似的情况于是采用了这个解决方案。 我们可以利用 FFmpeg 这个强大的工具把体积较大的 MP4 视频文件转换成 HLS 格式。HLS 会将视频切分成多个小片段一个个 .ts 文件同时生成一个 .m3u8 播放列表文件。 你可以把 .m3u8 文件理解成一个“目录”它告诉播放器一共有多少个视频片段、按什么顺序播放。而 .ts 文件就是按固定时长比如每10秒一段切出来的视频小片段。 播放时客户端不再需要一次性加载整个视频而是根据 .m3u8 目录一个片段一个片段地按需加载。这样即使网络带宽有限也能快速开始播放边下边播大大减少了等待缓存的时间显著提升了用户体验。 这个方案特别适合用于在线视频播放、课程平台、监控回放等需要快速预览大视频的场景。
优点 渐进式加载客户端按需加载小片段无需等待整个文件下载 自适应码率支持不同网络条件下的流畅播放 断点续传客户端可以从中断处继续播放 CDN 友好便于内容分发网络缓存
2使用FFmpeg实现格式转换
将 MP4 转换为 HLS 格式转换指令
ffmpeg -i input.mp4 \-c:v copy -c:a copy \ # 保持原始编码-hls_time 10 \ # 每个切片10秒-hls_list_size 0 \ # 播放列表包含所有分段-hls_segment_filename output_%03d.ts \ # 分段文件名output.m3u8 # 播放列表
程序实现转换功能
int convert_to_hls(const char *mp4_path) {// 直接从完整路径提取文件名不含路径和扩展名const char *base_name strrchr(mp4_path, /);base_name base_name ? base_name 1 : mp4_path;char file_name[256];strncpy(file_name, base_name, sizeof(file_name)-1);file_name[sizeof(file_name)-1] \0;// 移除扩展名char *ext strrchr(file_name, .);if (ext) *ext \0;// 确保HLS目录存在ensure_directory(HLS_DIR);char playlist_path[512];snprintf(playlist_path, sizeof(playlist_path), %s/%s.m3u8, HLS_DIR, file_name);// 检查是否已转换struct stat st;if (stat(playlist_path, st) 0) {printf(HLS already exists: %s\n, playlist_path);return 0;}// 获取文件大小if (stat(mp4_path, st)) {perror(Failed to get file size);return -1;}off_t file_size st.st_size;// 动态计算切片时间int segment_time 10; // 默认10秒if (file_size 100 * 1024 * 1024) { // 100MBsegment_time 20;}if (file_size 500 * 1024 * 1024) { // 500MBsegment_time 30;}if (file_size 1024 * 1024 * 1024) { // 1GBsegment_time 60;}printf(File size: %.2f MB, using segment time: %d seconds\n, (double)file_size/(1024*1024), segment_time);char command[4096];snprintf(command, sizeof(command),%s -i %s -c:v copy -c:a copy -hls_time %d -hls_list_size 0 -threads 4 // 使用4个线程加速转换-hls_segment_filename %s/%s_%%03d.ts %s/%s.m3u8, FFMPEG_PATH, mp4_path, segment_time, HLS_DIR, file_name, HLS_DIR, file_name);printf(Converting to HLS: %s\n, command);int ret system(command);if (ret ! 0) {fprintf(stderr, FFmpeg conversion failed with code %d\n, ret);return -1;}return 0;
}
其中采用动态的切片操作根据要传输的文件大小来选择执行对应的切片大小这样可以优化一点由于视频文件过长而导致切片过多的现象。
3构建嵌入式http服务器
http协议属于应用层协议其中使用的传输层是基于TCP协议进行传输在c语言中创建TCP服务器采用的是socket编程。其中相关的协议就不过多介绍附上源码。
#include stdio.h
#include stdlib.h
#include string.h
#include sys/types.h
#include sys/stat.h
#include unistd.h
#include fcntl.h
#include sys/wait.h
#include pthread.h
#include sys/socket.h
#include netinet/in.h
#include arpa/inet.h
#include netdb.h
#include poll.h
#include stdarg.h
#include dirent.h
#include errno.h
#include signal.h
#include sched.h
#include Function.h
#include record_management_app.h#define OPEN_MAX 512
#define SERVER_PORT 1001typedef struct ClientInfo {struct pollfd client_fds[OPEN_MAX];
} ClientInfo; //定义客户端总结构体ClientInfo client_info;volatile sig_atomic_t keep_running 1;void signal_handler(int signal) {if (signal SIGINT || signal SIGTERM) {printf(Caught signal %d, shutting down gracefully...\n, signal);keep_running 0;}
}void handle_connection(int num, struct sockaddr_in *client);int main(int argc, char const *argv[])
{int ret; int socket_fd; int client_fd;struct sockaddr_in server;struct sockaddr_in client;socklen_t client_len sizeof(client);// 设置退出信号处理器struct sigaction term_sa;memset(term_sa, 0, sizeof(term_sa));term_sa.sa_handler signal_handler;sigemptyset(term_sa.sa_mask);term_sa.sa_flags 0; // 关键不自动重启系统调用if (sigaction(SIGINT, term_sa, NULL) -1) {perror(sigaction(SIGINT) failed);exit(EXIT_FAILURE);}if (sigaction(SIGTERM, term_sa, NULL) -1) {perror(sigaction(SIGTERM) failed);exit(EXIT_FAILURE);}// 设置 SIGCHLD 信号处理器struct sigaction sa;memset(sa, 0, sizeof(sa));sa.sa_handler sigchld_handler;sigemptyset(sa.sa_mask);sa.sa_flags SA_RESTART;sigaction(SIGTERM, sa, NULL); // kill 命令或系统关机信号if (sigaction(SIGCHLD, sa, NULL) -1) {perror(sigaction failed);exit(EXIT_FAILURE);}// 创建socket 对象socket_fd socket(AF_INET, SOCK_STREAM, 0);if (socket_fd 0) {perror(socket);return -1;}printf(create socket success, socket %d\n, socket_fd);//端口复用int optval 1;if (setsockopt(socket_fd, SOL_SOCKET, SO_REUSEADDR, optval, sizeof(optval)) 0) {perror(setsockopt(SO_REUSEADDR) failed);exit(EXIT_FAILURE);}// 给服务器绑定 net_info.ipmemset(server, 0, sizeof(server));server.sin_family AF_INET;server.sin_port htons(SERVER_PORT);server.sin_addr.s_addr INADDR_ANY;printf(Port: %d\n, SERVER_PORT);ret bind(socket_fd, (struct sockaddr *)server, sizeof(server));if (ret 0) {perror(bind);return -1;}printf(bind success\n);// 创建最大连接数量ret listen(socket_fd, 10);if (ret 0) {perror(listen);}//添加监听描述符client_info.client_fds[0].fd socket_fd;client_info.client_fds[0].events POLLIN; // 监听读事件//初始化客户连接描述符for (int i 1; i OPEN_MAX; i) {client_info.client_fds[i].fd -1;}int nready 0; // 可以描述符个数int i 1; // 存储下一个要添加的描述符的下标// 主循环监听并处理客户端的连接while (keep_running) {//获取可用描述符的个数nready poll(client_info.client_fds, OPEN_MAX, 1000); if (nready -1) {if (errno EINTR) {// 如果是被信号中断则继续循环continue;} else {perror(poll error:);continue; // 继续循环而不是退出}}//测试监听描述符是否准备好if (client_info.client_fds[0].revents POLLIN){client_fd accept(socket_fd, (struct sockaddr *)client, client_len);if (client_fd -1){perror(accept error:);exit(1);} printf(one client coming, net_info.ip %s\n, inet_ntoa(client.sin_addr));//将新的连接描述符添加到数组中for (i 0; i OPEN_MAX; i){if (client_info.client_fds[i].fd 0){client_info.client_fds[i].fd client_fd;break;}}if (i OPEN_MAX){printf(too many clients\n);exit(1);}//将新的描述符添加到读描述符集合中client_info.client_fds[i].events POLLIN;// 主线程不再监听新的连接if (--nready 0){continue;}}//处理客户连接handle_connection(OPEN_MAX, client);}return 0;
}
//接口处理函数
void handle_connection(int num, struct sockaddr_in *client)
{int i 0;size_t cnt 0;uint8_t rbuf[65535] {0}; // 增大缓冲区大小为64kbfor (i 0; i num; i){if (client_info.client_fds[i].fd 0) continue;//测试客户端描述符是否准备好if(client_info.client_fds[i].revents POLLIN){cnt read(client_info.client_fds[i].fd, rbuf, sizeof(rbuf));if (cnt 0){close(client_info.client_fds[i].fd);printf(client %s disconnect\n, inet_ntoa(client-sin_addr));client_info.client_fds[i].fd -1;continue;}if (cnt 0){if (errno EAGAIN || errno EWOULDBLOCK) continue; // 非阻塞模式下没有数据可读perror(read error:);continue;}printf(rbuf: \r%s\n, rbuf);ApiPath api_path {0};if (parse_api_path((char*)rbuf, api_path) ! 0) {printf(Invalid API path format\n);continue;}printf(Parsed Topic: %s, Method: %s\n, api_path.topic, api_path.method);if (strncmp((const char*)rbuf, GET, 3) 0) { if (strncmp(api_path.topic, record_management, 17) 0) {printf(进入视频预览功能\n);// 清理 method去掉空格之后的内容char *space strchr(api_path.method, );if (space) {*space \0;}char decoded_method[200];url_decode(api_path.method, decoded_method, sizeof(decoded_method));printf(Method: %s\n, decoded_method);// 处理HLS文件请求(.m3u8或.ts)if (strstr(decoded_method, .m3u8) || strstr(decoded_method, .ts)) {char file_path[512];// 直接定位到HLS目录snprintf(file_path, sizeof(file_path), %s/hls/%s, MOUNT_POINT, decoded_method);const char *content_type strstr(decoded_method, .m3u8) ? application/x-mpegURL : video/MP2T;send_file(client_info.client_fds[i].fd, file_path, content_type);continue;}// 启动HLS流char *video_name strdup(decoded_method);if (!video_name) {perror(strdup failed);continue;}// 移除可能的文件扩展名char *ext strrchr(video_name, .);if (ext) *ext \0;// 准备线程参数size_t arg_size sizeof(int) strlen(video_name) 1;void *thread_arg malloc(arg_size);if (!thread_arg) {perror(malloc for thread_arg failed);free(video_name);continue;}// 复制客户端文件描述符和视频名int client_fd client_info.client_fds[i].fd;memcpy(thread_arg, client_fd, sizeof(int));memcpy(thread_arg sizeof(int), video_name, strlen(video_name) 1);pthread_t hls_thread;pthread_create(hls_thread, NULL, send_hls_stream, thread_arg);pthread_detach(hls_thread);free(video_name);}}}}
}
4编译与运行
Makefile
# 设置SDK根目录
SYSROOT : /home/qingwu007/aarch64-buildroot-linux-gnu_sdk-buildroot# 设置工具链前缀
BUILD_TOOL_DIR : $(SYSROOT)
BUILD_TOOL_PREFIX : $(BUILD_TOOL_DIR)/bin/aarch64-buildroot-linux-gnu-# 定义工具链
CC : $(BUILD_TOOL_PREFIX)gcc
AR : $(BUILD_TOOL_PREFIX)ar
LD : $(BUILD_TOOL_PREFIX)gcc# 编译参数
CFLAGS : -g -Wall \--sysroot$(SYSROOT) \-I$(SYSROOT)/include \-I$(SYSROOT)/usr/include \-I$(SYSROOT)/cjson \-I$(SYSROOT)/usr/include/aarch64-buildroot-linux-gnu \-I./include# 链接参数
LDFLAGS : --sysroot$(SYSROOT) \-L$(SYSROOT)/lib64 \-L$(SYSROOT)/usr/lib64 \-Wl,-rpath-link,$(SYSROOT)/lib64 \-Wl,-rpath-link,$(SYSROOT)/usr/lib64 \-Wl,-rpath,/opt/app/bin # 添加这一行指定运行时库路径-Wl,--dynamic-linker/lib64/ld-linux-aarch64.so.1 \-fPIC# 需要链接的库
LIBS : -lavcodec -lavdevice -lavfilter -lavformat -lavutil -lc -lcjson -lpthread# 目标设置
TARGET : hettp_save# 源文件处理 - 自动查找src目录下的所有.c文件
SRC_DIR : src
SRCS : $(wildcard $(SRC_DIR)/*.c)
OBJS : $(patsubst $(SRC_DIR)/%.c,%.o,$(SRCS)).PHONY: all cleanall: $(TARGET)$(TARGET): $(OBJS)$(LD) -o $ $^ $(LDFLAGS) $(LIBS)# 模式规则编译源文件
%.o: $(SRC_DIR)/%.cecho Compiling $...$(CC) $(CFLAGS) -c $ -o $# 静态库目标示例
libexample.a: $(OBJS)$(AR) rcs $ $^clean:rm -f $(TARGET) $(OBJS) libexample.a# 安装目标
install: $(TARGET)cp $(TARGET) /usr/local/bin# 调试目标
debug: CFLAGS -DDEBUG -O0
debug: clean all.PHONY: install debug我在http服务器上面写的接口是
http://IP:port/_api/app/record_management/xxxxx
测试的接口根据自己的环境来确定。 我的视频文件是放在开发板里面的然后通过搭建的http服务器加上ffmpeg就可以实现本地视频的预览和播放了。
我使用VLC来进行测试
可以看到上面的请求数据就按照这个视频的一个个切片请求这样就可以实现大视频文件的预览传输。但是这样也会有一个问题当要传输的文件过于大的话要进行切片的时间也就越长但是相比较与直接进行视频文件的传输还是较为好用的。完整的程序放在了我的资源中有需要自取我是在rk3588上面跑的环境根据自己的环境跟换Makefile即可。 【免费】在rk3588上面基于FFmpeg和HLS的大文件分片传输方案以实现大视频文件高效预览效果资源-CSDN下载
