上一篇文章我們簡(jiǎn)單地了解了ijkplayer的使用方法，本文準(zhǔn)備分析一下ijkplayer初始化的流程。

在這里我還是建議大家clone下來(lái)源碼同步分析，因?yàn)閕jkplayer文件太多，我開(kāi)始看的時(shí)候是越看越亂，到最后重新看一點(diǎn)，然后用筆記記一點(diǎn)，才有了頭緒。

我們上一篇文章有一個(gè)示例代碼，為了方便，我再貼一下：

        // init player
        IjkMediaPlayer.loadLibrariesOnce(null);
        IjkMediaPlayer.native_profileBegin("libijkplayer.so");
        videoView.setVideoURI(Uri.parse("http://106.36.45.36/live.aishang.ctlcdn.com/00000110240001_1/encoder/1/playlist.m3u8"));

        videoView.setOnPreparedListener(new IMediaPlayer.OnPreparedListener() {
            @Override
            public void onPrepared(IMediaPlayer mp) {
                videoView.start();
            }
        });

OK,現(xiàn)在我們就從初始化的第一句分析起，在loadLibrariesOnce（null）中加載了我們編譯出來(lái)的幾個(gè)so文件，如下：

libLoader.loadLibrary("ijkffmpeg");
libLoader.loadLibrary("ijksdl");
libLoader.loadLibrary("ijkplayer");

這里直接把libLoader看成System.loadLibrary(libname)就行,雖然看起來(lái)沒(méi)什么，挺正常的，但是分析到后面發(fā)現(xiàn)，java層調(diào)用的函數(shù)在c層找不到0.0。之后google了下發(fā)現(xiàn):

JNI在加載時(shí)，會(huì)調(diào)用JNI_OnLoad()，而卸載時(shí)會(huì)調(diào)用JNI_UnLoad()，我們可以利用這兩個(gè)方法來(lái)動(dòng)態(tài)方式實(shí)現(xiàn)JNI。

然后趕快找找C代碼中有沒(méi)有JNI_OnLoad()方法。

果然，在ijkplayer_jni.c中找到了JNI_OnLoad()方法：

JNIEXPORT jint JNI_OnLoad(JavaVM *vm, void *reserved)
{
    JNIEnv* env = NULL;

    g_jvm = vm;
    if ((*vm)->GetEnv(vm, (void**) &env, JNI_VERSION_1_4) != JNI_OK) {
        return -1;
    }
    assert(env != NULL);

    pthread_mutex_init(&g_clazz.mutex, NULL );

    // FindClass returns LocalReference
    IJK_FIND_JAVA_CLASS(env, g_clazz.clazz, JNI_CLASS_IJKPLAYER);
    (*env)->RegisterNatives(env, g_clazz.clazz, g_methods, NELEM(g_methods) );

    ijkmp_global_init();
    ijkmp_global_set_inject_callback(inject_callback);

    FFmpegApi_global_init(env);

    return JNI_VERSION_1_4;
}

這個(gè)方法里面，初始化了很多內(nèi)容，首先RegisterNatives注冊(cè)g_methods中的native方法，其中包括：

static JNINativeMethod g_methods[] = {
    {
        "_setDataSource",
        "(Ljava/lang/String;[Ljava/lang/String;[Ljava/lang/String;)V",
        (void *) IjkMediaPlayer_setDataSourceAndHeaders
    },
    { "_setDataSourceFd",       "(I)V",     (void *) IjkMediaPlayer_setDataSourceFd },
    { "_setDataSource",         "(Ltv/danmaku/ijk/media/player/misc/IMediaDataSource;)V", (void *)IjkMediaPlayer_setDataSourceCallback },
//...
    { "_setVideoSurface",       "(Landroid/view/Surface;)V", (void *) IjkMediaPlayer_setVideoSurface },
    { "_prepareAsync",          "()V",      (void *) IjkMediaPlayer_prepareAsync },
    { "_start",                 "()V",      (void *) IjkMediaPlayer_start },
    { "_stop",                  "()V",      (void *) IjkMediaPlayer_stop },
    { "seekTo",                 "(J)V",     (void *) IjkMediaPlayer_seekTo },
    { "_pause",                 "()V",      (void *) IjkMediaPlayer_pause },
    { "isPlaying",              "()Z",      (void *) IjkMediaPlayer_isPlaying },
    { "getAudioSessionId",      "()I",      (void *) IjkMediaPlayer_getAudioSessionId },
    { "native_init",            "()V",      (void *) IjkMediaPlayer_native_init },
    { "native_setup",           "(Ljava/lang/Object;)V", (void *) IjkMediaPlayer_native_setup },
//......
    { "native_profileBegin",    "(Ljava/lang/String;)V",    (void *) IjkMediaPlayer_native_profileBegin },
    { "native_profileEnd",      "()V",                      (void *) IjkMediaPlayer_native_profileEnd },
};

注冊(cè)后，相當(dāng)于java層聲明為native方法的函數(shù)與c層有一個(gè)映射關(guān)系；舉個(gè)栗子，當(dāng)我們java里面調(diào)用_start()方法的時(shí)候，其實(shí)調(diào)用的是c層中的IjkMediaPlayer_start()方法；對(duì)應(yīng)地，作者在java層聲明了一個(gè)修飾java方法的annotation，這些函數(shù)也會(huì)在這里注冊(cè)，實(shí)現(xiàn)后面在C層也能調(diào)用java層的函數(shù)。是不是很神奇？？

接著還調(diào)用了幾個(gè)init方法：
**ffp_global_init() **-->主要是ffmpeg的初始化工作, 前面說(shuō)過(guò)ijkplayer是基于ffmpeg的。
FFmpegApi_global_init(env)-->初始化FFmpegApi#av_base64_encode函數(shù)。

后面調(diào)用的IjkMediaPlayer.native_profileBegin("libijkplayer.so");發(fā)現(xiàn)并沒(méi)有什么作用的樣子，至少我注釋了還是能成功運(yùn)行?？磥?lái)這里要留坑了。

然后我們?cè)倏吹?code>videoView.setVideoURI()；,這里的url支持本地視頻和在線視頻，接著我們繼續(xù)看到它的實(shí)現(xiàn)：

 private void openVideo() {
        if (mUri == null || mSurfaceHolder == null) {
            // not ready for playback just yet, will try again later
            return;
        }
        // we shouldn't clear the target state, because somebody might have
        // called start() previously
        release(false);

        AudioManager am = (AudioManager) mAppContext.getSystemService(Context.AUDIO_SERVICE);
        am.requestAudioFocus(null, AudioManager.STREAM_MUSIC, AudioManager.AUDIOFOCUS_GAIN);

        try {
            mMediaPlayer = createPlayer(mSettings.getPlayer());
            mMediaPlayer.setOnPreparedListener(mPreparedListener);
            //這里省略一大波setListener......
            mCurrentBufferPercentage = 0;
            if (Build.VERSION.SDK_INT > Build.VERSION_CODES.ICE_CREAM_SANDWICH) {
                mMediaPlayer.setDataSource(mAppContext, mUri, mHeaders);
            } else {
                mMediaPlayer.setDataSource(mUri.toString());
            }
            bindSurfaceHolder(mMediaPlayer, mSurfaceHolder);
            mMediaPlayer.setAudioStreamType(AudioManager.STREAM_MUSIC);
            mMediaPlayer.setScreenOnWhilePlaying(true);
            mMediaPlayer.prepareAsync();
            if (mHudViewHolder != null)
                mHudViewHolder.setMediaPlayer(mMediaPlayer);

            // REMOVED: mPendingSubtitleTracks

            // we don't set the target state here either, but preserve the
            // target state that was there before.
            mCurrentState = STATE_PREPARING;
            attachMediaController();
        } catch (IOException ex) {
           ...
        } catch (IllegalArgumentException ex) {
          ...
        } finally {
            
        }
    }

在這里， 做了下面幾件事：

• 獲得AudioManager
• 通過(guò)setting獲取player的類型
• 初始化IMediaPlayer (createPlayer()函數(shù))
• 然后調(diào)用setDataSource(String)
• 屏幕常亮等
• 設(shè)置MediaController
• mMediaPlayer.prepareAsync()

初始化IMediaPlayer

這里只講一下IjkMediaPlayer，其實(shí)我們除了使用IjkMediaPlayer，還可以使用IjkExoMediaPlayer或者AndroidMediaPlayer。只需要修改一下createPlayer(int playerType)的參數(shù)就行了。

在IjkMediaPlayer初始化過(guò)程中，做了好多好多事，我們來(lái)一一看一下：

 public IjkMediaPlayer(IjkLibLoader libLoader) {
        initPlayer(libLoader);
    }

    private void initPlayer(IjkLibLoader libLoader) {
        loadLibrariesOnce(libLoader);
        initNativeOnce();

        Looper looper;
        if ((looper = Looper.myLooper()) != null) {
            mEventHandler = new EventHandler(this, looper);
        } else if ((looper = Looper.getMainLooper()) != null) {
            mEventHandler = new EventHandler(this, looper);
        } else {
            mEventHandler = null;
        }

        /*
         * Native setup requires a weak reference to our object. It's easier to
         * create it here than in C++.
         */
        native_setup(new WeakReference<IjkMediaPlayer>(this));
    }

由于之前調(diào)用了一次loadLibrariesOnce(),所以這里并沒(méi)有什么用。

initNativeOnce()經(jīng)過(guò)幾次跳轉(zhuǎn)調(diào)用了native方法的native_init函數(shù)，這里跳轉(zhuǎn)到C代碼里面，對(duì)應(yīng)調(diào)用了IjkMediaPlayer_native_init()，不過(guò)看起來(lái)并沒(méi)有什么操作。接著初始化了一個(gè)handler，后面在c層通過(guò)調(diào)用java的方法來(lái)post message。

這里最后調(diào)用了native方法native_setup(new WeakReference<IjkMediaPlayer>(this));對(duì)應(yīng)C語(yǔ)言的IjkMediaPlayer_native_setup()方法，也在ijkplayer_jni.c文件里面：

static void
IjkMediaPlayer_native_setup(JNIEnv *env, jobject thiz, jobject weak_this)
{
    MPTRACE("%s\n", __func__);
    IjkMediaPlayer *mp = ijkmp_android_create(message_loop);
    JNI_CHECK_GOTO(mp, env, "java/lang/OutOfMemoryError", "mpjni: native_setup: ijkmp_create() failed", LABEL_RETURN);

    jni_set_media_player(env, thiz, mp);
    ijkmp_set_weak_thiz(mp, (*env)->NewGlobalRef(env, weak_this));
    ijkmp_set_inject_opaque(mp, ijkmp_get_weak_thiz(mp));
    ijkmp_android_set_mediacodec_select_callback(mp, mediacodec_select_callback, (*env)->NewGlobalRef(env, weak_this));

LABEL_RETURN:
    ijkmp_dec_ref_p(&mp);
}

先看ijkmp_android_create(message_loop);/ijkplayer_android.c:

IjkMediaPlayer *ijkmp_android_create(int(*msg_loop)(void*))
{
    IjkMediaPlayer *mp = ijkmp_create(msg_loop);
    if (!mp)
        goto fail;

    mp->ffplayer->vout = SDL_VoutAndroid_CreateForAndroidSurface(); //視頻輸出設(shè)備創(chuàng)建
    if (!mp->ffplayer->vout)
        goto fail;

    mp->ffplayer->pipeline = ffpipeline_create_from_android(mp->ffplayer);    
    if (!mp->ffplayer->pipeline)
        goto fail;

    ffpipeline_set_vout(mp->ffplayer->pipeline, mp->ffplayer- >vout);  

    return mp;

fail:
    ijkmp_dec_ref_p(&mp);
    return NULL;
}

首先創(chuàng)建一個(gè)IJKMediaPlayer類型的player吧，先貼出IJKPlayerMediaPlayer的結(jié)構(gòu):

struct IjkMediaPlayer {
    volatile int ref_count;
    pthread_mutex_t mutex;  //這是一個(gè)互斥鎖，因?yàn)楹竺嬗泻芏喽嗑€程操作，同步少不了
    FFPlayer *ffplayer;    //ffplayer

    int (*msg_loop)(void*);    //msg的一個(gè)處理函數(shù)
    SDL_Thread *msg_thread;
    SDL_Thread _msg_thread;

    int mp_state;
    char *data_source;    //數(shù)據(jù)源
    void *weak_thiz;

    int restart;
    int restart_from_beginning;
    int seek_req;
    long seek_msec;
};

在create_ijkplayer(ijkmp_create(msg_loop)函數(shù))的同時(shí)，也給它指定了msg的處理函數(shù)和ffplayer。

接下來(lái)就是對(duì)ijkplayer結(jié)構(gòu)體中的ffplayer進(jìn)行設(shè)置，剛剛通過(guò)SDL_VoutAndroid_CreateForAndroidSurface()創(chuàng)建了輸出設(shè)備vout，后面在ffpipeline_set_vout()里面：mp->ffplayer->opaque->weak_vout = vout。

然后再jni_set_media_player()，這里基本就結(jié)束了。

其實(shí)細(xì)細(xì)分析還有的地方?jīng)]有分析到，比如在SDL_VoutAndroid_CreateForAndroidSurface()創(chuàng)建視頻輸出設(shè)備的時(shí)候，跟蹤函數(shù)跳轉(zhuǎn)發(fā)現(xiàn)，硬解用的mediacidec，軟解用的ffmpeg:

static SDL_VoutOverlay *func_create_overlay_l(int width, int height, int frame_format, SDL_Vout *vout)
{
    switch (frame_format) {
    case IJK_AV_PIX_FMT__ANDROID_MEDIACODEC:
        return SDL_VoutAMediaCodec_CreateOverlay(width, height, vout);
    default:
        return SDL_VoutFFmpeg_CreateOverlay(width, height, frame_format, vout);
    }
}

還有渲染視頻設(shè)備用的ANativeWindow,對(duì)接surface等。還有一些地方是設(shè)置了函數(shù)指針，現(xiàn)在分析的話，后面可能會(huì)懵，這些放到后面再來(lái)分析。

OK，現(xiàn)在返回java層，剛剛分析到了IJKMediaPlayer的構(gòu)造函數(shù)，作者在構(gòu)造函數(shù)里面做了很多事情的樣子。

setDataSource(String)

接著我們?cè)O(shè)置了視頻源，在JNI層對(duì)應(yīng)IjkMediaPlayer_setDataSourceAndHeaders()/ijkplayer_jni.c。同樣代碼跟蹤到了ijkmp_set_data_source_l()：

   //...
    freep((void**)&mp->data_source);
    mp->data_source = strdup(url);
   //...
    ijkmp_change_state_l(mp, MP_STATE_INITIALIZED);
   //...

在ijkmp_change_state_l里面封裝了一個(gè)what為MP_STATE_INITIALIZED的AVMessage，最后把其放入ijkplayer->ffplayer->msg_queue中，然后調(diào)用：

int SDL_CondSignal(SDL_cond *cond)
{
    assert(cond);
    if (!cond)
        return -1;

    return pthread_cond_signal(&cond->id);
}

cond->id其實(shí)是ijkplayer->ffplayer->msg_queue->cond->id，類型為pthread_cond_t。

那么pthread_cond_signal這個(gè)函數(shù)是干嘛的呢？

其實(shí)在liunx里面,pthread_cond_signal函數(shù)的作用是發(fā)送一個(gè)信號(hào)給另外一個(gè)正在處于阻塞等待狀態(tài)的線程,使其脫離阻塞狀態(tài),繼續(xù)執(zhí)行，當(dāng)某個(gè)線程繼續(xù)執(zhí)行的時(shí)候發(fā)現(xiàn)msg_queue中有msg的時(shí)候會(huì)有相應(yīng)操作。到底這里把是發(fā)給誰(shuí)呢？請(qǐng)繼續(xù)往下面讀。

prepareAsync() 函數(shù)

其中調(diào)用了IjkMediaPlayer_prepareAsync/ijkplayer_jni.c，我們繼續(xù)看它做了哪些操作。

同樣，這個(gè)函數(shù)最終調(diào)用了ijkmp_prepare_async_l（）：

static int ijkmp_prepare_async_l(IjkMediaPlayer *mp)
{
    assert(mp);

   //...
    assert(mp->data_source);

    ijkmp_change_state_l(mp, MP_STATE_ASYNC_PREPARING);

    msg_queue_start(&mp->ffplayer->msg_queue);

    // released in msg_loop
    ijkmp_inc_ref(mp);
    mp->msg_thread = SDL_CreateThreadEx(&mp->_msg_thread, ijkmp_msg_loop, mp, "ff_msg_loop");
    // msg_thread is detached inside msg_loop
    // TODO: 9 release weak_thiz if pthread_create() failed;

    int retval = ffp_prepare_async_l(mp->ffplayer, mp->data_source);
    if (retval < 0) {
        ijkmp_change_state_l(mp, MP_STATE_ERROR);
        return retval;
    }

    return 0;
}

和上面一樣，ijkmp_change_state_l()向msg_queue發(fā)送一個(gè)FFP_MSG_PLAYBACK_STATE_CHANGED狀態(tài)

咦？這里又發(fā)送了一個(gè)狀態(tài)FFP_MSG_FLUSH，然而函數(shù)名是msg_queue_start(),這是什么意思呢？

然后接下來(lái)就創(chuàng)建了一個(gè)msg_loop的消息循環(huán)線程，線程入口為ijkmp_msg_loop。這里其實(shí)就是上面放進(jìn)msg_queue的message的處理線程。后面再具體分析各個(gè)線程做了什么。

在最后，這里繼續(xù)調(diào)用ffp_prepare_async_l().然而在這個(gè)函數(shù)里面:

int ffp_prepare_async_l(FFPlayer *ffp, const char *file_name)
{
//....

    av_log(NULL, AV_LOG_INFO, "===== versions =====\n");
    ffp_show_version_str(ffp, "FFmpeg",         av_version_info());
    ffp_show_version_int(ffp, "libavutil",      avutil_version());
    ffp_show_version_int(ffp, "libavcodec",     avcodec_version());
    ffp_show_version_int(ffp, "libavformat",    avformat_version());
    ffp_show_version_int(ffp, "libswscale",     swscale_version());
    ffp_show_version_int(ffp, "libswresample",  swresample_version());
    av_log(NULL, AV_LOG_INFO, "===== options =====\n");
    ffp_show_dict(ffp, "player-opts", ffp->player_opts);
    ffp_show_dict(ffp, "format-opts", ffp->format_opts);
    ffp_show_dict(ffp, "codec-opts ", ffp->codec_opts);
    ffp_show_dict(ffp, "sws-opts   ", ffp->sws_dict);
    ffp_show_dict(ffp, "swr-opts   ", ffp->swr_opts);
    av_log(NULL, AV_LOG_INFO, "===================\n");
//...
    VideoState *is = stream_open(ffp, file_name, NULL);
//...

    ffp->is = is;
    ffp->input_filename = av_strdup(file_name);
    return 0;
}

看到這一大波log信息沒(méi)有，要是大家運(yùn)行了上一篇的demo，會(huì)發(fā)現(xiàn)這不就是打印的log么？

然后繼續(xù)跟蹤代碼：

static VideoState *stream_open(FFPlayer *ffp, const char *filename, AVInputFormat *iformat)
{
  //...
    /* start video display */
    if (frame_queue_init(&is->pictq, &is->videoq, ffp->pictq_size, 1) < 0)
        goto fail;
//...
  
    is->video_refresh_tid = SDL_CreateThreadEx(&is->_video_refresh_tid, video_refresh_thread, ffp, "ff_vout");
//...
    is->read_tid = SDL_CreateThreadEx(&is->_read_tid, read_thread, ffp, "ff_read");
    //...
}

上面函數(shù)里面只留下了重要的代碼，這里創(chuàng)建了兩個(gè)線程，一個(gè)是以video_refresh_thread為入口的視頻顯示線程。還有一個(gè)是以read_thread為入口的網(wǎng)絡(luò)數(shù)據(jù)或者本地文件的數(shù)據(jù)讀取線程。

其實(shí)在read_thread里面還向msg_queue發(fā)送了一個(gè)消息，那就是ffp_notify_msg1(ffp, FFP_MSG_PREPARED);，消息循環(huán)線程收到這個(gè)消息后，會(huì)調(diào)用java層的函數(shù)，向handler發(fā)送個(gè)MEDIA_PREPARED消息，然后在handler的handleMessage函數(shù)里面會(huì)處理這個(gè)消息：

    case MEDIA_PREPARED:
                player.notifyOnPrepared();
                return;

最終會(huì)調(diào)用我們上一文設(shè)置的:

videoView.setOnPreparedListener(new IMediaPlayer.OnPreparedListener() {
            @Override
            public void onPrepared(IMediaPlayer mp) {
                videoView.start();
            }
        });

的onPrepared()函數(shù)，然后初始化好了，接下來(lái)就可以播放了。

** 如果大家還想了解ijkplayer的工作流程的話，可以關(guān)注下android下的ijkplayer。**