整合營銷服務(wù)商
電腦端+手機(jī)端+微信端=數(shù)據(jù)同步管理
免費(fèi)咨詢熱線：
電腦端+手機(jī)端+微信端=數(shù)據(jù)同步管理
免費(fèi)咨詢熱線：
國乒乓球隊(duì)的男女團(tuán)將參加半決賽，女團(tuán)將面對德國，男團(tuán)將面臨韓國的挑戰(zhàn)。CCTV-5中央電視臺(tái)體育頻道將于上午9:00直播中國VS德國女團(tuán)半決賽，下午13:30直播中國VS韓國男團(tuán)半決賽。此外，晚上18:30日本VS德國男團(tuán)半決賽將在CCTV-5直播。
13:30 男團(tuán)半決賽：中國VS韓國(CCTV-5現(xiàn)場直播)
https://www.miguvideo.com/mgs/website/prd/sportLive.html?mgdbId=120000169257&channelId=0132_CAAAB000902014800000000&pwId=3d21c7db29cd4911853ecc4b814bd9a3
中國：馬龍、許昕、樊振東
韓國：鄭榮植、張禹珍、李尚洙
韓國男團(tuán)面對中國隊(duì)并沒有氣餒，而是憋著勁要挑戰(zhàn)強(qiáng)大的中國隊(duì)。韓國選手李尚洙對韓聯(lián)社說：“我們來東京就是為了奪取金牌，我認(rèn)為世界上沒有一支球隊(duì)是我們無法擊敗的。”張宇鎮(zhèn)說：“中國選手處在被挑戰(zhàn)位置，負(fù)擔(dān)會(huì)更大。”鄭榮植則說：“中國選手是人，不是長城。”
所以中國男團(tuán)馬龍、許昕和樊振東還真不能掉以輕心，首先要在第一盤雙打確保拿下，接下來一場一場去拼。冠軍從來都是拼出來的，保守沒有希望。相信中國男團(tuán)能順利過關(guān)。
18:30 男團(tuán)半決賽：日本VS德國(CCTV-5+現(xiàn)場直播)
日本：張本智和、丹羽孝希、水谷隼
德國：波爾、奧恰洛夫、弗朗西斯卡
來源：多特軟件網(wǎng)
近兩年時(shí)間，視頻直播可謂大火。在視頻直播領(lǐng)域，有不同的商家提供各種的商業(yè)解決方案，包括軟硬件設(shè)備，攝像機(jī)，編碼器，流媒體服務(wù)器等。本文要講解的是如何使用一系列免費(fèi)工具，打造一套視頻直播方案。
視頻直播流程
視頻直播的流程可以分為如下幾步：
采集 —>處理—>編碼和封裝—>推流到服務(wù)器—>服務(wù)器流分發(fā)—>播放器流播放
一般情況下我們把流程的前四步稱為第一部分，即視頻主播端的操作。視頻采集處理后推流到流媒體服務(wù)器，第一部分功能完成。第二部分就是流媒體服務(wù)器，負(fù)責(zé)把從第一部分接收到的流進(jìn)行處理并分發(fā)給觀眾。第三部分就是觀眾啦，只需要擁有支持流傳輸協(xié)議的播放器即可。
一、采集
采集是整個(gè)視頻推流過程中的第一個(gè)環(huán)節(jié)，它從系統(tǒng)的采集設(shè)備中獲取原始視頻數(shù)據(jù)，將其輸出到下一個(gè)環(huán)節(jié)。視頻的采集涉及兩方面數(shù)據(jù)的采集：音頻采集和圖像采集，它們分別對應(yīng)兩種完全不同的輸入源和數(shù)據(jù)格式。
1.1-音頻采集
1.2-圖像采集
視頻采集的采集源主要有 攝像頭采集、屏幕錄制和從視頻文件推流。
二、處理
視頻或者音頻完成采集之后得到原始數(shù)據(jù)，為了增強(qiáng)一些現(xiàn)場效果或者加上一些額外的效果，我們一般會(huì)在將其編碼壓縮前進(jìn)行處理，比如打上時(shí)間戳或者公司 Logo 的水印，祛斑美顏和聲音混淆等處理。在主播和觀眾連麥場景中，主播需要和某個(gè)或者多個(gè)觀眾進(jìn)行對話，并將對話結(jié)果實(shí)時(shí)分享給其他所有觀眾，連麥的處理也有部分工作在推流端完成。
如上圖所示，處理環(huán)節(jié)中分為音頻和視頻處理，音頻處理中具體包含混音、降噪和聲音特效等處理，視頻處理中包含美顏、水印、以及各種自定義濾鏡等處理。
三、編碼和封裝
3.1-編碼
⑴.基本原理
⑵.編碼器的選擇
注：音頻編碼器有Mp3, AAC等。
3.2-封裝
目前，我們在流媒體傳輸，尤其是直播中主要采用的就是 FLV 和 MPEG2-TS 格式，分別用于 RTMP/HTTP-FLV 和 HLS 協(xié)議。
四、推流到服務(wù)器
推流是直播的第一公里，直播的推流對這個(gè)直播鏈路影響非常大，如果推流的網(wǎng)絡(luò)不穩(wěn)定，無論我們?nèi)绾巫鰞?yōu)化，觀眾的體驗(yàn)都會(huì)很糟糕。所以也是我們排查問題的第一步，如何系統(tǒng)地解決這類問題需要我們對相關(guān)理論有基礎(chǔ)的認(rèn)識(shí)。
推送協(xié)議主要有三種：
RTMP協(xié)議基于 TCP，是一種設(shè)計(jì)用來進(jìn)行實(shí)時(shí)數(shù)據(jù)通信的網(wǎng)絡(luò)協(xié)議，主要用來在 flash/AIR 平臺(tái)和支持 RTMP 協(xié)議的流媒體/交互服務(wù)器之間進(jìn)行音視頻和數(shù)據(jù)通信。支持該協(xié)議的軟件包括 Adobe Media Server/Ultrant Media Server/red5 等。
它有三種變種：
RTMP 是目前主流的流媒體傳輸協(xié)議，廣泛用于直播領(lǐng)域，可以說市面上絕大多數(shù)的直播產(chǎn)品都采用了這個(gè)協(xié)議。
RTMP協(xié)議就像一個(gè)用來裝數(shù)據(jù)包的容器，這些數(shù)據(jù)可以是AMF格式的數(shù)據(jù),也可以是FLV中的視/音頻數(shù)據(jù)。一個(gè)單一的連接可以通過不同的通道傳輸多路網(wǎng)絡(luò)流。這些通道中的包都是按照固定大小的包傳輸?shù)摹?
五、服務(wù)器流分發(fā)
流媒體服務(wù)器的作用是負(fù)責(zé)直播流的發(fā)布和轉(zhuǎn)播分發(fā)功能。
流媒體服務(wù)器有諸多選擇，如商業(yè)版的Wowza。但我選擇的是Nginx，它是一款優(yōu)秀的免費(fèi)Web服務(wù)器，后面我會(huì)詳細(xì)介紹如何搭建Nginx服務(wù)器。
六、播放器流播放
主要是實(shí)現(xiàn)直播節(jié)目在終端上的展現(xiàn)。因?yàn)槲疫@里使用的傳輸協(xié)議是RTMP， 所以只要支持 RTMP 流協(xié)議的播放器都可以使用，譬如：
目前市面上集視頻采集、編碼、封裝和推流于一體的SDK已經(jīng)有很多了，例如商業(yè)版的NodeMedia，但NodeMedia SDK按包名授權(quán)，未授權(quán)包名應(yīng)用使用有版權(quán)提示信息。
我這里使用的是別人分享在github上的一個(gè)免費(fèi)SDK。因頭條發(fā)文規(guī)則不允許插入外部鏈接，文章下評論+私信我獲取！
下面我就代碼分析一下直播推流的過程吧：
先看入口界面：
很簡單，一個(gè)輸入框讓你填寫服務(wù)器的推流地址，另外一個(gè)按鈕開啟推流。
public class StartActivity extends Activity {
public static final String RTMPURL_MESSAGE="rtmppush.hx.com.rtmppush.rtm purl";
private Button _startRtmpPushButton=null;
private EditText _rtmpUrlEditText=null;
private View.OnClickListener _startRtmpPushOnClickedEvent=new View.OnClickListener() {
@Override
public void onClick(View arg0) {
Intent i=new Intent(StartActivity.this, MainActivity.class);
String rtmpUrl=_rtmpUrlEditText.getText().toString();
i.putExtra(StartActivity.RTMPURL_MESSAGE, rtmpUrl);
StartActivity.this.startActivity(i);
}
};
private void InitUI(){
_rtmpUrlEditText=(EditText)findViewById(R.id.rtmpUrleditText);
_startRtmpPushButton=(Button)findViewById(R.id.startRtmpButton);
_rtmpUrlEditText.setText("rtmp://192.168.1.104:1935ve/12345");
_startRtmpPushButton.setOnClickListener(_startRtmpPushOnClickedEvent);
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_start);
InitUI();
}
}
主要的推流過程在MainActivity里面，同樣，先看界面：
布局文件：
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:id="@+id/cameraRelative" android:layout_width="match_parent" android:layout_height="match_parent" android:paddingBottom="@dimen/activity_vertical_margin" android:paddingLeft="@dimen/activity_horizontal_margin" android:paddingRight="@dimen/activity_horizontal_margin" android:paddingTop="@dimen/activity_vertical_margin" android:theme="@android:style/Theme.NoTitleBar.Fullscreen"> <SurfaceView android:id="@+id/surfaceViewEx" android:layout_width="match_parent" android:layout_height="match_parent"/> <Button android:id="@+id/SwitchCamerabutton" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_alignBottom="@+id/surfaceViewEx" android:text="@string/SwitchCamera" /> </RelativeLayout>
其實(shí)就是用一個(gè)SurfaceView顯示攝像頭拍攝畫面，并提供了一個(gè)按鈕切換前置和后置攝像頭。從入口函數(shù)看起：
@Override
protected void onCreate(Bundle savedInstanceState) {
requestWindowFeature(Window.FEATURE_NO_TITLE);
getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,
WindowManager.LayoutParams.FLAG_FULLSCREEN);
this.getWindow().setFlags(WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON, WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON);
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_PORTRAIT);
Intent intent=getIntent();
_rtmpUrl=intent.getStringExtra(StartActivity.RTMPURL_MESSAGE);
InitAll();
PowerManager pm=(PowerManager) getSystemService(Context.POWER_SERVICE);
_wakeLock=pm.newWakeLock(PowerManager.SCREEN_DIM_WAKE_LOCK, "My Tag");
}
首先設(shè)置全屏顯示，常亮，豎屏，獲取服務(wù)器的推流url，再初始化所有東西。
private void InitAll() {
WindowManager wm=this.getWindowManager();
int width=wm.getDefaultDisplay().getWidth();
int height=wm.getDefaultDisplay().getHeight();
int iNewWidth=(int) (height * 3.0 / 4.0);
RelativeLayout rCameraLayout=(RelativeLayout) findViewById(R.id.cameraRelative);
RelativeLayout.LayoutParams layoutParams=new RelativeLayout.LayoutParams(RelativeLayout.LayoutParams.MATCH_PARENT,
RelativeLayout.LayoutParams.MATCH_PARENT);
int iPos=width - iNewWidth;
layoutParams.setMargins(iPos, 0, 0, 0);
_mSurfaceView=(SurfaceView) this.findViewById(R.id.surfaceViewEx);
_mSurfaceView.getHolder().setFixedSize(HEIGHT_DEF, WIDTH_DEF);
_mSurfaceView.getHolder().setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS);
_mSurfaceView.getHolder().setKeepScreenOn(true);
_mSurfaceView.getHolder().addCallback(new SurceCallBack());
_mSurfaceView.setLayoutParams(layoutParams);
InitAudioRecord();
_SwitchCameraBtn=(Button) findViewById(R.id.SwitchCamerabutton);
_SwitchCameraBtn.setOnClickListener(_switchCameraOnClickedEvent);
RtmpStartMessage();//開始推流
}
首先設(shè)置屏幕比例3:4顯示，給SurfaceView設(shè)置一些參數(shù)并添加回調(diào)，再初始化AudioRecord，最后執(zhí)行開始推流。音頻在這里初始化了，那么相機(jī)在哪里初始化呢？其實(shí)在SurfaceView的回調(diào)函數(shù)里。
@Override
public void surfaceCreated(SurfaceHolder holder) {
_iDegrees=getDisplayOritation(getDispalyRotation(), 0);
if (_mCamera !=null) {
InitCamera(); //初始化相機(jī)
return;
}
//華為i7前后共用攝像頭
if (Camera.getNumberOfCameras()==1) {
_bIsFront=false;
_mCamera=Camera.open(Camera.CameraInfo.CAMERA_FACING_BACK);
} else {
_mCamera=Camera.open(Camera.CameraInfo.CAMERA_FACING_FRONT);
}
InitCamera();
}
@Override
public void surfaceDestroyed(SurfaceHolder holder) {
}
}
相機(jī)的初始化就在這里啦：
public void InitCamera() {
Camera.Parameters p=_mCamera.getParameters();
Size prevewSize=p.getPreviewSize();
showlog("Original Width:" + prevewSize.width + ", height:" + prevewSize.height);
List<Size> PreviewSizeList=p.getSupportedPreviewSizes();
List<Integer> PreviewFormats=p.getSupportedPreviewFormats();
showlog("Listing all supported preview sizes");
for (Camera.Size size : PreviewSizeList) {
showlog(" w: " + size.width + ", h: " + size.height);
}
showlog("Listing all supported preview formats");
Integer iNV21Flag=0;
Integer iYV12Flag=0;
for (Integer yuvFormat : PreviewFormats) {
showlog("preview formats:" + yuvFormat);
if (yuvFormat==android.graphics.ImageFormat.YV12) {
iYV12Flag=android.graphics.ImageFormat.YV12;
}
if (yuvFormat==android.graphics.ImageFormat.NV21) {
iNV21Flag=android.graphics.ImageFormat.NV21;
}
}
if (iNV21Flag !=0) {
_iCameraCodecType=iNV21Flag;
} else if (iYV12Flag !=0) {
_iCameraCodecType=iYV12Flag;
}
p.setPreviewSize(HEIGHT_DEF, WIDTH_DEF);
p.setPreviewFormat(_iCameraCodecType);
p.setPreviewFrameRate(FRAMERATE_DEF);
showlog("_iDegrees="+_iDegrees);
_mCamera.setDisplayOrientation(_iDegrees);
p.setRotation(_iDegrees);
_mCamera.setPreviewCallback(_previewCallback);
_mCamera.setParameters(p);
try {
_mCamera.setPreviewDisplay(_mSurfaceView.getHolder());
} catch (Exception e) {
return;
}
_mCamera.cancelAutoFocus();//只有加上了這一句，才會(huì)自動(dòng)對焦。
_mCamera.startPreview();
}
還記得之前初始化完成之后開始推流函數(shù)嗎？
private void RtmpStartMessage() {
Message msg=new Message();
msg.what=ID_RTMP_PUSH_START;
Bundle b=new Bundle();
b.putInt("ret", 0);
msg.setData(b);
mHandler.sendMessage(msg);
}
Handler處理：
public Handler mHandler=new Handler() {
public void handleMessage(android.os.Message msg) {
Bundle b=msg.getData();
int ret;
switch (msg.what) {
case ID_RTMP_PUSH_START: {
Start();
break;
}
}
}
};
真正的推流實(shí)現(xiàn)原來在這里：
private void Start() {
if (DEBUG_ENABLE) {
File saveDir=Environment.getExternalStorageDirectory();
String strFilename=saveDir + "/aaa.h264";
try {
if (!new File(strFilename).exists()) {
new File(strFilename).createNewFile();
}
_outputStream=new DataOutputStream(new FileOutputStream(strFilename));
} catch (Exception e) {
e.printStackTrace();
}
}
//_rtmpSessionMgr.Start("rtmp://192.168.0.110ve/12345678");
_rtmpSessionMgr=new RtmpSessionManager();
_rtmpSessionMgr.Start(_rtmpUrl); //------point 1
int iFormat=_iCameraCodecType;
_swEncH264=new SWVideoEncoder(WIDTH_DEF, HEIGHT_DEF, FRAMERATE_DEF, BITRATE_DEF);
_swEncH264.start(iFormat); //------point 2
_bStartFlag=true;
_h264EncoderThread=new Thread(_h264Runnable);
_h264EncoderThread.setPriority(Thread.MAX_PRIORITY);
_h264EncoderThread.start(); //------point 3
_AudioRecorder.startRecording();
_AacEncoderThread=new Thread(_aacEncoderRunnable);
_AacEncoderThread.setPriority(Thread.MAX_PRIORITY);
_AacEncoderThread.start(); //------point 4
}
里面主要的函數(shù)有四個(gè)，我分別標(biāo)出來了，現(xiàn)在我們逐一看一下。首先是point 1，這已經(jīng)走到SDK里面了
public int Start(String rtmpUrl){
int iRet=0;
_rtmpUrl=rtmpUrl;
_rtmpSession=new RtmpSession();
_bStartFlag=true;
_h264EncoderThread.setPriority(Thread.MAX_PRIORITY);
_h264EncoderThread.start();
return iRet;
}
其實(shí)就是啟動(dòng)了一個(gè)線程，這個(gè)線程稍微有點(diǎn)復(fù)雜
private Thread _h264EncoderThread=new Thread(new Runnable() {
private Boolean WaitforReConnect(){
for(int i=0; i < 500; i++){
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
if(_h264EncoderThread.interrupted() || (!_bStartFlag)){
return false;
}
}
return true;
}
@Override
public void run() {
while (!_h264EncoderThread.interrupted() && (_bStartFlag)) {
if(_rtmpHandle==0) {
_rtmpHandle=_rtmpSession.RtmpConnect(_rtmpUrl);
if(_rtmpHandle==0){
if(!WaitforReConnect()){
break;
}
continue;
}
}else{
if(_rtmpSession.RtmpIsConnect(_rtmpHandle)==0){
_rtmpHandle=_rtmpSession.RtmpConnect(_rtmpUrl);
if(_rtmpHandle==0){
if(!WaitforReConnect()){
break;
}
continue;
}
}
}
if((_videoDataQueue.size()==0) && (_audioDataQueue.size()==0)){
try {
Thread.sleep(30);
} catch (InterruptedException e) {
e.printStackTrace();
}
continue;
}
//Log.i(TAG, "VideoQueue length="+_videoDataQueue.size()+", AudioQueue length="+_audioDataQueue.size());
for(int i=0; i < 100; i++){
byte[] audioData=GetAndReleaseAudioQueue();
if(audioData==null){
break;
}
//Log.i(TAG, "###RtmpSendAudioData:"+audioData.length);
_rtmpSession.RtmpSendAudioData(_rtmpHandle, audioData, audioData.length);
}
byte[] videoData=GetAndReleaseVideoQueue();
if(videoData !=null){
//Log.i(TAG, "$$$RtmpSendVideoData:"+videoData.length);
_rtmpSession.RtmpSendVideoData(_rtmpHandle, videoData, videoData.length);
}
try {
Thread.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
_videoDataQueueLock.lock();
_videoDataQueue.clear();
_videoDataQueueLock.unlock();
_audioDataQueueLock.lock();
_audioDataQueue.clear();
_audioDataQueueLock.unlock();
if((_rtmpHandle !=0) && (_rtmpSession !=null)){
_rtmpSession.RtmpDisconnect(_rtmpHandle);
}
_rtmpHandle=0;
_rtmpSession=null;
}
});
看18行，主要就是一個(gè)while循環(huán)，每隔一段時(shí)間去_audioDataQueue和_videoDataQueue兩個(gè)緩沖數(shù)組中取數(shù)據(jù)發(fā)送給服務(wù)器，發(fā)送方法_rtmpSession.RtmpSendAudioData和_rtmpSession.RtmpSendVideoData都是Native方法，通過jni調(diào)用so庫文件的內(nèi)容，每隔一段時(shí)間，這個(gè)時(shí)間是多少呢？看第4行，原來是5秒鐘，也就是說我們的視頻數(shù)據(jù)會(huì)在緩沖中存放5秒才被取出來發(fā)給服務(wù)器，所有直播會(huì)有5秒的延時(shí)，我們可以修改這塊來控制直播延時(shí)。
上面說了我們會(huì)從_audioDataQueue和_videoDataQueue兩個(gè)Buffer里面取數(shù)據(jù)，那么數(shù)據(jù)是何時(shí)放進(jìn)去的呢？看上面的point 2,3,4。首先是point 2，同樣走進(jìn)了SDK：
public boolean start(int iFormateType){
int iType=OpenH264Encoder.YUV420_TYPE;
if(iFormateType==android.graphics.ImageFormat.YV12){
iType=OpenH264Encoder.YUV12_TYPE;
}else{
iType=OpenH264Encoder.YUV420_TYPE;
}
_OpenH264Encoder=new OpenH264Encoder();
_iHandle=_OpenH264Encoder.InitEncode(_iWidth, _iHeight, _iBitRate, _iFrameRate, iType);
if(_iHandle==0){
return false;
}
_iFormatType=iFormateType;
return true;
}
其實(shí)這是初始化編碼器，具體的初始化過程也在so文件，jni調(diào)用。point 3,4其實(shí)就是開啟兩個(gè)線程，那我們看看線程中具體實(shí)現(xiàn)吧。
private Thread _h264EncoderThread=null;
private Runnable _h264Runnable=new Runnable() {
@Override
public void run() {
while (!_h264EncoderThread.interrupted() && _bStartFlag) {
int iSize=_YUVQueue.size();
if (iSize > 0) {
_yuvQueueLock.lock();
byte[] yuvData=_YUVQueue.poll();
if (iSize > 9) {
Log.i(LOG_TAG, "###YUV Queue len=" + _YUVQueue.size() + ", YUV length=" + yuvData.length);
}
_yuvQueueLock.unlock();
if (yuvData==null) {
continue;
}
if (_bIsFront) {
_yuvEdit=_swEncH264.YUV420pRotate270(yuvData, HEIGHT_DEF, WIDTH_DEF);
} else {
_yuvEdit=_swEncH264.YUV420pRotate90(yuvData, HEIGHT_DEF, WIDTH_DEF);
}
byte[] h264Data=_swEncH264.EncoderH264(_yuvEdit);
if (h264Data !=null) {
_rtmpSessionMgr.InsertVideoData(h264Data);
if (DEBUG_ENABLE) {
try {
_outputStream.write(h264Data);
int iH264Len=h264Data.length;
//Log.i(LOG_TAG, "Encode H264 len="+iH264Len);
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
try {
Thread.sleep(1);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
_YUVQueue.clear();
}
};
也是一個(gè)循環(huán)線程，第9行，從_YUVQueue中取出攝像頭獲取的數(shù)據(jù)，然后進(jìn)行視頻旋轉(zhuǎn)，第24行，對數(shù)據(jù)進(jìn)行編碼，然后執(zhí)行26行，InsertVideoData：
public void InsertVideoData(byte[] videoData){
if(!_bStartFlag){
return;
}
_videoDataQueueLock.lock();
if(_videoDataQueue.size() > 50){
_videoDataQueue.clear();
}
_videoDataQueue.offer(videoData);
_videoDataQueueLock.unlock();
}
果然就是插入之前提到的_videoDataQueue的Buffer。這里插入的是視頻數(shù)據(jù)，那么音頻數(shù)據(jù)呢？在另外一個(gè)線程，內(nèi)容大致相同
private Runnable _aacEncoderRunnable=new Runnable() {
@Override
public void run() {
DataOutputStream outputStream=null;
if (DEBUG_ENABLE) {
File saveDir=Environment.getExternalStorageDirectory();
String strFilename=saveDir + "/aaa.aac";
try {
if (!new File(strFilename).exists()) {
new File(strFilename).createNewFile();
}
outputStream=new DataOutputStream(new FileOutputStream(strFilename));
} catch (Exception e1) {
e1.printStackTrace();
}
}
long lSleepTime=SAMPLE_RATE_DEF * 16 * 2 / _RecorderBuffer.length;
while (!_AacEncoderThread.interrupted() && _bStartFlag) {
int iPCMLen=_AudioRecorder.read(_RecorderBuffer, 0, _RecorderBuffer.length); // Fill buffer
if ((iPCMLen !=_AudioRecorder.ERROR_BAD_VALUE) && (iPCMLen !=0)) {
if (_fdkaacHandle !=0) {
byte[] aacBuffer=_fdkaacEnc.FdkAacEncode(_fdkaacHandle, _RecorderBuffer);
if (aacBuffer !=null) {
long lLen=aacBuffer.length;
_rtmpSessionMgr.InsertAudioData(aacBuffer);
//Log.i(LOG_TAG, "fdk aac length="+lLen+" from pcm="+iPCMLen);
if (DEBUG_ENABLE) {
try {
outputStream.write(aacBuffer);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
} else {
Log.i(LOG_TAG, "######fail to get PCM data");
}
try {
Thread.sleep(lSleepTime / 10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Log.i(LOG_TAG, "AAC Encoder Thread ended ......");
}
};
private Thread _AacEncoderThread=null;
這就是通過循環(huán)將音頻數(shù)據(jù)插入_audioDataQueue這個(gè)Buffer。
以上就是視頻采集和推流的代碼分析，Demo中并沒有對視頻進(jìn)行任何處理，只是攝像頭采集，編碼后推流到服務(wù)器端。
流媒體服務(wù)器有諸多選擇，如商業(yè)版的Wowza。但我選擇的是免費(fèi)的Nginx（nginx-rtmp-module）。Nginx本身是一個(gè)非常出色的HTTP服務(wù)器，它通過nginx的模塊nginx-rtmp-module可以搭建一個(gè)功能相對比較完善的流媒體服務(wù)器。這個(gè)流媒體服務(wù)器可以支持RTMP和HLS。
Nginx配合SDK做流媒體服務(wù)器的原理是: Nginx通過rtmp模塊提供rtmp服務(wù), SDK推送一個(gè)rtmp流到Nginx, 然后客戶端通過訪問Nginx來收看實(shí)時(shí)視頻流。 HLS也是差不多的原理,只是最終客戶端是通過HTTP協(xié)議來訪問的,但是SDK推送流仍然是rtmp的。
集成rtmp模塊的windows版本的Nginx。下載后，即可直接使用，因頭條發(fā)文規(guī)則不允許插入外部鏈接，文章下評論+私信我獲取！
1、rtmp端口配置
配置文件在/conf/nginx.conf
RTMP監(jiān)聽 1935 端口，啟用live 和hls 兩個(gè)application
所以你的流媒體服務(wù)器url可以寫成：rtmp://（服務(wù)器IP地址）:1935/live/xxx 或 rtmp://（服務(wù)器IP地址）:1935/hls/xxx
例如我們上面寫的 rtmp://192.168.1.104:1935/live/12345
HTTP監(jiān)聽 8080 端口，
2、啟動(dòng)nginx服務(wù)
雙擊nginx.exe文件或者在dos窗口下運(yùn)行nginx.exe，即可啟動(dòng)nginx服務(wù)：
1）啟動(dòng)任務(wù)管理器，可以看到nginx.exe進(jìn)程
2）打開網(wǎng)頁輸入http://localhot:8080,出現(xiàn)如下畫面：
顯示以上界面說明啟動(dòng)成功。
主播界面：
上面說過了只要支持RTMP流傳輸協(xié)議的播放器都可以收看到我們的直播。下面舉兩個(gè)例子吧：
（1）window端播放器VLC
（2）android端播放器ijkplayer
private void initPlayer() {
player=new PlayerManager(this);
player.setFullScreenOnly(true);
player.setScaleType(PlayerManager.SCALETYPE_FILLPARENT);
player.playInFullScreen(true);
player.setPlayerStateListener(this);
player.play("rtmp://192.168.1.104:1935ve/12345");
}
到這里整個(gè)基于RTMP推流實(shí)現(xiàn)Android視頻直播的項(xiàng)目已經(jīng)完成了，如有你有更好的想法可以在文章下方評論留言或私信我！另外前文中第二部分提到的推流SDK以及第三部分提到的已經(jīng)集成rtmp模塊的windows版本的Nginx下載地址由于頭條發(fā)文規(guī)則不允許插入外部鏈接，如有需要的可以再文章下留言評論后私信我回復(fù)【下載地址】獲取！
ffmpeg音視頻編解碼
ffplay音視頻播放工具
準(zhǔn)備流媒體服務(wù)器linux
準(zhǔn)備并安裝Nginx服務(wù)
配置RTMP并啟動(dòng)Nginx服務(wù)
sudo apt-get install build-essential libpcre3 libpcre3-dev libssl-dev
mkdir ~/working
cd ~/working
wget http://nginx.org/download/nginx-1.7.5.tar.gz
wget https://github.com/arut/nginx-rtmp-module/archive/master.zip
sudo apt-get install unzip
tar -zxvf nginx-1.7.5.tar.gz
unzip master.zip
cd nginx-1.7.5
./configure --with-http_ssl_module --add-module=../nginx-rtmp-module-master
make
sudo make install
sudo wget https://raw.github.com/JasonGiedymin/nginx-init-ubuntu/master/nginx -O /etc/init.d/nginx
sudo chmod +x /etc/init.d/nginx
sudo update-rc.d nginx defaults
sudo service nginx start
sudo service nginx stop
sudo apt-add-repository ppa:jon-severinsson/ffmpeg
sudo apt-get update
sudo apt-get install ffmpeg
原文PPA不可用，源碼安裝參見
http://blog.csdn.net/redstarofsleep/article/details/45092145
打開 /usr/local/nginx/conf/nginx.conf
在末尾添加如下 配置
rtmp {
server {
listen 1935; #監(jiān)聽的端口
chunk_size 4000;
application hls { #rtmp推流請求路徑
live on;
hls on;
hls_path /usr/local/nginx/html/hls;
hls_fragment 5s;
}
}
}
sudo service nginx restart
用netstat -an | grep 1935
出現(xiàn)以下信息代表則代表啟動(dòng)nginx/rtmp成功
netstat -an| grep 1935
tcp 0 0 0.0.0.0:1935 0.0.0.0:* LISTEN
16: 使用 客戶端，使用 rtmp協(xié)議進(jìn)行視頻實(shí)時(shí)采集
ffmpeg直播命令：
推流：ffmpeg -re -i 1.mp4 -c copy -f flv rtmp://xxx.xxx.xxx.xxx:1935/hls/1.mp4
拉流：ffmpeg -i rtmp://xxx.xxx.xxx.xxx/1.mp4 -c copy dump.flv
播放音視頻：ffplay rtmp://xxx.xxx.xxx.xxx/hls
ffplay rtmp://xxx.xxx.xxx.xxx/hls
18: 關(guān)于 nginx-rtmp 更多配置
https://github.com/arut/nginx-rtmp-module/wiki/Directives
flashplay播放器地址
http://bbs.chinaffmpeg.com/1.swf
*請認(rèn)真填寫需求信息，我們會(huì)在24小時(shí)內(nèi)與您取得聯(lián)系。
