让FFMPEG支持实时流“伴随”转码

FROM：http://blog.csdn.net/rcfalcon/article/details/6863119

FFMPEG命令行工具目前无法针对视频实时流进行转码，而我们可以用它的新版本提供的支持TCP SERVER的特性来实现这一功能。实现边录边用FFMPEG提供的命令行工具进行转码。（实践证明，FFMPEG 的SDK针对实时流开发比较繁琐，命令行工具相对来说稳定）

我们将实时流录制成正在增长的文件，这样问题就变成了FFMPEG如何针对正在增长的视频文件转码。（首先我们保证视频格式是可以支持正在增长文件解码，这不在本文的讨论范畴）

而我们如果直接使用它对正在增长的文件转码，我们会发现FFMPEG转码到文件末尾（转码速度比录制速度快）就会退出。我们要做的就是在FFMPEG转码到末尾时如何将其挂起。若直接修改FFMPEG的源代码则比较繁琐，我们搭建一个TCP的FILE SERVER，来控制给FFMPEG发送数据的速度，而FFMPEG使用TCP的方式来获取视频流，即可实现这个功能。

以下是代码，我们用python来实现：

FFMPEG version:N-32611-gd55b06b

[python] view plaincopy

#encoding=utf8
'''''
Created on 2011-9-25
@author: chenggong
ffmpeg扩展工具
'''
import SocketServer
import os
import threading
import time
BIN_DIR = "bin\\"
BLOCK_SIZE = 188*1024
FRONTOFFSET = 1024 * 1024 * 1
gparam={'output':'','source':'','port':9333,
'start':0,'length':0,'ffmpeg_argvs':'',
'ffmpegsema':None,'tcpserversema':None}
class MyFfmpegThread(threading.Thread):
def run(self):
if os.path.exists(gparam['output']):
os.remove(gparam['output'])
argvs = gparam['ffmpeg_argvs'].replace("[filelocate]","tcp://127.0.0.1:%d"%gparam['port']) + " " + gparam['output']
cmd = "%s\\avconv %s"%(BIN_DIR,argvs)
os.system(cmd)
gparam['ffmpegsema'].release()
class MyTcpServerThread(threading.Thread):
def run(self):
while True:
try:
ADDR = ("127.0.0.1", gparam['port'])
self.tcpServ = SocketServer.ThreadingTCPServer(ADDR, MyRequestHandler)
break
except Exception,e:
print str(e)
print "port:%d 被占用..更换"%gparam['port']
gparam['port']+=1
self.tcpServ.serve_forever()
def close(self):
self.tcpServ.shutdown()
self.tcpServ.server_close()
class MyRequestHandler(SocketServer.BaseRequestHandler):
def handle(self):
print 'connected from:', self.client_address
file = open(gparam['source'],"rb")
startoffset = gparam['start']
if startoffset<0:startoffset=0
print "start offset="+str(startoffset)
file.seek(startoffset)
left = gparam['length']
while(True):
try:
if(left<BLOCK_SIZE and left!=-1):
buffer_size = left
else:
buffer_size = BLOCK_SIZE
data=file.read(buffer_size)
#print "read data,size="+str(len(data))
#if(left!=-1): print "left size=%d"%left
if not data:
print "data empty! read to file_end,wait.."
finish_filename=gparam['source'].replace(os.path.splitext(gparam['source'])[1],".finish")
if(os.path.exists(finish_filename)):
print ".finish file founded"
break
time.sleep(1)
continue
self.request.sendall(data)
if(left!=-1):
left -= buffer_size
if(left<=0):
print "transfer finished"
break
if(len(data)<buffer_size):
finish_filename=gparam['source'].replace(os.path.splitext(gparam['source'])[1],".finish")
if(os.path.exists(finish_filename)):
print ".finish file founded"
break
else:
print "read to file_end,wait.."
time.sleep(1)
except:
print "exception occured,client stopped"
break
print "work finished"
file.close()
gparam['tcpserversema'].release()
def ffmpegex(source,output,start,length,ffmpeg_argvs):
gparam['source']=source
gparam['output']=output
gparam['start']=start
gparam['length']=length
gparam['ffmpeg_argvs']=ffmpeg_argvs
try:
while True:
gparam['ffmpegsema']=threading.Semaphore(0)
gparam['tcpserversema']=threading.Semaphore(0)
tcpServerThread = MyTcpServerThread()
tcpServerThread.start()
MyFfmpegThread().start()
gparam['ffmpegsema'].acquire()
gparam['tcpserversema'].acquire()
tcpServerThread.close()
filesize = os.path.getsize(gparam['output'])
if(filesize<length/10): #生成失败,将start提前，重做任务
if gparam['start']==0: return False
if gparam['start']-FRONTOFFSET>=0:
gparam['start']-=FRONTOFFSET
else:
gparam['start']=0
else:
return True
except:
return False
if __name__ == "__main__":
for i in range(0,100):
import random
start = random.randrange(0,1024*1024*1024)
print ffmpegex('C:\\16942.ts','C:\\test2\\%d-%d.wmv'%(i,start),start,1024*1024*5,\
"-i [filelocate] -acodec wmav2 -vcodec wmv2 -qscale 1 -ab 256k -r 25")

让FFMPEG支持实时流“伴随”转码相关推荐

pyqt5+opencv实现视频播放组件，支持实时流播放
pyqt5+opencv实现视频播放详细源码链接为:https://github.com/2500284064/pyqt5-opencv-video 基本原理是通过 VideoCapture 类读取 ...
视频流异步转码和实时流式转码是什么意思？有什么区别？
随着互联网带宽的不断提升,视频内容的分发与播放在新闻娱乐.在线教育.社交网络和自媒体场景下越来越普遍,EasyDSS这样的平台作为视频直播点播平台,在越来越多的项目中得到了应用,比如校园课堂.酒店智能 ...
如何让ffplay或者ffmpeg支持H265编码的rtmp/http-flv 实时直播流
很多初学者不知道ffplay或者ffmpeg是不支持flv封装的rtmp/http-flv流的,其原因是flv不支持H265编码payload的,因为当时制定flv封装协议的时候,H265还没出来,现 ...
Apache Storm 实时流处理系统通信机制源码分析
我们今天就来仔细研究一下Apache Storm 2.0.0-SNAPSHOT的通信机制.下面我将从大致思想以及源码分析,然后我们细致分析实时流处理系统中源码通信机制研究. 1. 简介 Worker间 ...
H.264 媒体流 AnnexB 和 AVCC 格式分析及 FFmpeg 解析mp4的H.264码流方法
H264码流分两种组织方式,一种是AnnexB格式,一种是AVCC格式. 作者:码农小明来源:https://blog.csdn.net/shaosunrise/article/details/12 ...
在已实现spp程序基础上改rtk，附C++源码（事后和实时流）
原文地址:在已实现spp程序基础上改rtk,附C++源码(事后和实时流) 上面这个链接现在可以下载啦- 换了地址- 因为报告我已经搞丢了所以只分享我的事后处理以及实时流的计算程序给大家. 事先说明
android flv 编码器,Android 音视频深入十七 FFmpeg 获取 RTMP 流保存为 flv (附源码下载)...
Android 音视频深入十七 FFmpeg 获取 RTMP 流保存为 flv (附源码下载) 项目地址 https://github.com/979451341/RtmpSave 这个项目主要代码 ...
利用ffmpeg录制rtsp流的方法总结（一)
致敬雷霄骅(已逝):https://blog.csdn.net/leixiaohua1020/article/details/18893769 音频编码编码技术算法编码标准码率(kbit/s) ...
Nginx-rtmp 直播媒体实时流实现
0. 前言这段时间在搭建一个IPCamera项目服务器.视频点对点通话,客户端会查看设备端的音视频实时流.为了省流量,是通过P2P进行穿透.但是由于NAT设备的原因和IPV4的枯竭.有些设备是无法进 ...

让FFMPEG支持实时流“伴随”转码

让FFMPEG支持实时流“伴随”转码相关推荐

最新文章

热门文章