live555转发H264实时流实现直播的实现

本文介绍了在树莓派上通过live555实现了从树莓派的USB端口获取到的H264码流的实时直播的功能。

GitHub：https://github.com/SkyDreamcode/live555H264-V4l2LiveStreaming.git

live555实现直播的方式是以testProgs/testOnDemandRTSPServer.cpp文件为参照对象。但是查看这个源码文件实现的是直播个本地已经录制好的文件如：test.264。

并且只是将这个文件播放完后就停止了读取这个文件：

所以当前的任务需求，如果要将从usb中接收到的h264视频流，在远程的终端直播，只需要将usb中读取到的H264流写入到一个fifo中，然后在testOnDemandRTSPServer.cpp将直播的文件换做我们的fifo文件即可。并且需要不断的重复读取这个fifo文件。将上面提到的变量reuseFirstSource由false改为true。

重复读取fifo文件：

这样live555的视频流文件就准备好了。接下来就是准备往fifo文件中写入视频流的操作。

先在main函数的开头建立一个线程，这个线程的作用就是不断的读取usb中的h264数据然后写道fifo文件中。

线程的代码实现如下：

static pthread_t recv_from_usb_id;
//static int fd[2];
#define DATA_SIZE (5*1024)
const char *fifo_name = "/tmp/h264_fifo";static void *recv_from_usb_thread(void *arg)
{PORT port0;int r_cnt;int ret = 0;int w_cnt = 0;char buf0[DATA_SIZE];struct timeval begin, end, end1;//int pipe_fd = *((int*)arg);if(Usb_Init() < 0){printf("usb init err\n");        pthread_exit(NULL);;}	printf("usb init success\n");if(access(fifo_name, F_OK) == -1){printf ("Create the fifo pipe.\n");int res = mkfifo(fifo_name, 0777);if(res != 0){fprintf(stderr, "Could not create fifo %s\n", fifo_name);//exit(EXIT_FAILURE);}}printf("start open the fifo file\n");int	pipe_fd = open(fifo_name, O_WRONLY);if(pipe_fd != -1){printf("open fifo success\n");//return pipe_fd;}else{printf("pipe file open error %s\n", strerror(errno));//return -1;pthread_exit(NULL);}printf("thread recv_from_usb_thread, pipe_fd = %d\n", pipe_fd);Video_Port_Open(&port0,NULL);while(1){gettimeofday(&begin, NULL);r_cnt = Video_Port_Rec(port0,buf0,DATA_SIZE);if(r_cnt > 0){gettimeofday(&end1, NULL);long delta_time =  1000000l*(end1.tv_sec - begin.tv_sec) + (end1.tv_usec-begin.tv_usec);printf("recv from usb size:%d,end1 delta-time:%ld us\n", r_cnt, delta_time);ret = write(pipe_fd, buf0, r_cnt);}else if(r_cnt == 0){usleep(500);}usleep(100);}
}

live555的代码直接使用编译好的静态库文件：

所以加上相应的Makefile文件，以供参考：

INCLUDES 	 = -I./include/live555/usageEnvironment/ -I./include/live555/groupsock/ \-I./include/live555/liveMedia/ -I./include/live555/basicUsageEnvironment \-I./include/x264 -I./include/encoder -I./lib/artosyn_usb_lib/
LIVE555_LIBS =  ./lib/livelib/libliveMedia.a ./lib/livelib/libgroupsock.a \./lib/livelib/libBasicUsageEnvironment.a ./lib/livelib/libUsageEnvironment.aLIBS         =  $(LIVE555_LIBS)COMPILE_OPTS =      $(INCLUDES) -I. -O2 -DSOCKLEN_T=socklen_t -D_LARGEFILE_SOURCE=1 -D_FILE_OFFSET_BITS=64 -g
C 			 =         c
C_COMPILER   =        cc
C_FLAGS 	 =       $(COMPILE_OPTS) $(CPPFLAGS) $(CFLAGS)
CPP 		 =           cpp
CPLUSPLUS_COMPILER =    c++
CPLUSPLUS_FLAGS =   $(COMPILE_OPTS) -Wall -DBSD=1 $(CPPFLAGS) $(CXXFLAGS)
OBJ 		 =           o
LINK 		 =  c++ -o
LINK_OPTS    =  -ldl  -lm -lpthread -ldl -g
CONSOLE_LINK_OPTS = $(LINK_OPTS)
lib/artosyn_usb_lib/libar8020.o
LINK_OBJ	 =  testOnDemandRTSPServer.o lib/artosyn_usb_lib/libar8020.oAPP = live555_h264_app.$(C).$(OBJ):$(C_COMPILER) -c $(C_FLAGS) $<
.$(CPP).$(OBJ):$(CPLUSPLUS_COMPILER) -c $(CPLUSPLUS_FLAGS) $<$(APP): $(LINK_OBJ)$(LINK)$@  $(LINK_OBJ)  $(LIBS) $(CONSOLE_LINK_OPTS)clean:-rm -rf *.$(OBJ) $(APP) core *.core *~ include/*~