From e141eeb8b8d7b7570c0c90f55680aab8f49af705 Mon Sep 17 00:00:00 2001 From: xiongziliang <771730766@qq.com> Date: Sun, 26 Apr 2020 19:02:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E5=8F=96=E6=B6=88=E5=9B=9E?= =?UTF-8?q?=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/include/mk_player.h | 6 +- api/source/mk_player.cpp | 190 ++++++++++++++++++++++++++++----------- 2 files changed, 142 insertions(+), 54 deletions(-) diff --git a/api/include/mk_player.h b/api/include/mk_player.h index d93414e2..f5b6d4d0 100755 --- a/api/include/mk_player.h +++ b/api/include/mk_player.h @@ -83,7 +83,7 @@ API_EXPORT void API_CALL mk_player_seekto(mk_player ctx, float progress); /** * 设置播放器开启播放结果回调函数 * @param ctx 播放器指针 - * @param cb 回调函数指针,不得为null + * @param cb 回调函数指针,设置null立即取消回调 * @param user_data 用户数据指针 */ API_EXPORT void API_CALL mk_player_set_on_result(mk_player ctx, on_mk_play_event cb, void *user_data); @@ -91,7 +91,7 @@ API_EXPORT void API_CALL mk_player_set_on_result(mk_player ctx, on_mk_play_event /** * 设置播放被异常中断的回调 * @param ctx 播放器指针 - * @param cb 回调函数指针,不得为null + * @param cb 回调函数指针,设置null立即取消回调 * @param user_data 用户数据指针 */ API_EXPORT void API_CALL mk_player_set_on_shutdown(mk_player ctx, on_mk_play_event cb, void *user_data); @@ -100,7 +100,7 @@ API_EXPORT void API_CALL mk_player_set_on_shutdown(mk_player ctx, on_mk_play_eve * 设置音视频数据回调函数 * 该接口在播放成功事件触发后才有效 * @param ctx 播放器指针 - * @param cb 回调函数指针,不得为null + * @param cb 回调函数指针,设置null立即取消回调 * @param user_data 用户数据指针 */ API_EXPORT void API_CALL mk_player_set_on_data(mk_player ctx, on_mk_play_data cb, void *user_data); diff --git a/api/source/mk_player.cpp b/api/source/mk_player.cpp index b2a01bcd..37803de1 100755 --- a/api/source/mk_player.cpp +++ b/api/source/mk_player.cpp @@ -15,19 +15,123 @@ using namespace std; using namespace toolkit; using namespace mediakit; +class MediaPlayerForC : public std::enable_shared_from_this{ +public: + typedef std::shared_ptr Ptr; + + MediaPlayerForC(){ + _player = std::make_shared(); + } + ~MediaPlayerForC(){} + + MediaPlayer *operator->(){ + return _player.get(); + } + + void setup(){ + weak_ptr weak_self = shared_from_this(); + _player->setOnPlayResult([weak_self](const SockException &ex){ + auto strong_self = weak_self.lock(); + if(strong_self){ + strong_self->onEvent(false,ex); + } + }); + + _player->setOnShutdown([weak_self](const SockException &ex){ + auto strong_self = weak_self.lock(); + if(strong_self){ + strong_self->onEvent(true,ex); + } + }); + } + + void onEvent(bool is_shutdown, const SockException &ex){ + lock_guard lck(_mtx); + if(is_shutdown){ + //播放中断 + if(_on_shutdown){ + _on_shutdown(_on_shutdown_data,ex.getErrCode(),ex.what()); + } + return; + } + + //播放结果 + if(_on_play){ + _on_play(_on_play_data,ex.getErrCode(),ex.what()); + } + + if(ex){ + //播放失败 + return; + } + + //播放成功,添加事件回调 + weak_ptr weak_self = shared_from_this(); + auto delegate = std::make_shared([weak_self](const Frame::Ptr &frame) { + auto strong_self = weak_self.lock(); + if (strong_self) { + strong_self->onData(frame); + } + }); + for (auto &track : _player->getTracks()) { + track->addDelegate(delegate); + } + } + + void onData(const Frame::Ptr &frame){ + lock_guard lck(_mtx); + if(_on_data){ + _on_data(_on_data_data,frame->getTrackType(),frame->getCodecId(),frame->data(),frame->size(),frame->dts(),frame->pts()); + } + } + + void setOnEvent(on_mk_play_event cb, void *user_data, int type) { + lock_guard lck(_mtx); + if(type == 0){ + _on_play_data = user_data; + _on_play = cb; + }else{ + _on_shutdown_data = user_data; + _on_shutdown = cb; + } + } + + void setOnData(on_mk_play_data cb, void *user_data) { + lock_guard lck(_mtx); + _on_data_data = user_data; + _on_data = cb; + } + + MediaPlayer::Ptr& getPlayer(){ + return _player; + } +private: + MediaPlayer::Ptr _player; + recursive_mutex _mtx; + on_mk_play_event _on_play = nullptr; + on_mk_play_data _on_data = nullptr; + on_mk_play_event _on_shutdown = nullptr; + + void *_on_play_data = nullptr; + void *_on_shutdown_data = nullptr; + void *_on_data_data = nullptr; +}; + API_EXPORT mk_player API_CALL mk_player_create() { - MediaPlayer::Ptr *obj = new MediaPlayer::Ptr(new MediaPlayer()); + MediaPlayerForC::Ptr *obj = new MediaPlayerForC::Ptr(new MediaPlayerForC()); + (*obj)->setup(); return obj; } API_EXPORT void API_CALL mk_player_release(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr *obj = (MediaPlayer::Ptr *)ctx; + MediaPlayerForC::Ptr *obj = (MediaPlayerForC::Ptr *)ctx; delete obj; } API_EXPORT void API_CALL mk_player_set_option(mk_player ctx,const char* key,const char *val){ assert(ctx && key && val); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto player = obj.getPlayer(); string key_str(key), val_str(val); player->getPoller()->async([key_str,val_str,player](){ //切换线程后再操作 @@ -36,7 +140,8 @@ API_EXPORT void API_CALL mk_player_set_option(mk_player ctx,const char* key,cons } API_EXPORT void API_CALL mk_player_play(mk_player ctx, const char *url) { assert(ctx && url); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto player = obj.getPlayer(); string url_str(url); player->getPoller()->async([url_str,player](){ //切换线程后再操作 @@ -46,7 +151,8 @@ API_EXPORT void API_CALL mk_player_play(mk_player ctx, const char *url) { API_EXPORT void API_CALL mk_player_pause(mk_player ctx, int pause) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto player = obj.getPlayer(); player->getPoller()->async([pause,player](){ //切换线程后再操作 player->pause(pause); @@ -55,7 +161,8 @@ API_EXPORT void API_CALL mk_player_pause(mk_player ctx, int pause) { API_EXPORT void API_CALL mk_player_seekto(mk_player ctx, float progress) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto player = obj.getPlayer(); player->getPoller()->async([progress,player](){ //切换线程后再操作 player->seekTo(progress); @@ -64,19 +171,8 @@ API_EXPORT void API_CALL mk_player_seekto(mk_player ctx, float progress) { static void mk_player_set_on_event(mk_player ctx, on_mk_play_event cb, void *user_data, int type) { assert(ctx && cb); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - player->getPoller()->async([cb,user_data,type,player](){ - //切换线程后再操作 - if(type == 0){ - player->setOnPlayResult([cb,user_data](const SockException &ex){ - cb(user_data,ex.getErrCode(),ex.what()); - }); - }else{ - player->setOnShutdown([cb,user_data](const SockException &ex){ - cb(user_data,ex.getErrCode(),ex.what()); - }); - } - }); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + obj.setOnEvent(cb,user_data, type); } API_EXPORT void API_CALL mk_player_set_on_result(mk_player ctx, on_mk_play_event cb, void *user_data) { @@ -89,88 +185,80 @@ API_EXPORT void API_CALL mk_player_set_on_shutdown(mk_player ctx, on_mk_play_eve API_EXPORT void API_CALL mk_player_set_on_data(mk_player ctx, on_mk_play_data cb, void *user_data) { assert(ctx && cb); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - player->getPoller()->async([player,cb,user_data](){ - //切换线程后再操作 - auto delegate = std::make_shared([cb,user_data](const Frame::Ptr &frame){ - cb(user_data,frame->getTrackType(),frame->getCodecId(),frame->data(),frame->size(),frame->dts(),frame->pts()); - }); - for(auto &track : player->getTracks()){ - track->addDelegate(delegate); - } - }); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + obj.setOnData(cb,user_data); } API_EXPORT int API_CALL mk_player_video_codecId(mk_player ctx){ assert(ctx); - MediaPlayer::Ptr& player = *((MediaPlayer::Ptr*)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackVideo)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackVideo)); return track ? track->getCodecId() : CodecInvalid; } API_EXPORT int API_CALL mk_player_video_width(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackVideo)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackVideo)); return track ? track->getVideoWidth() : 0; } API_EXPORT int API_CALL mk_player_video_height(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackVideo)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackVideo)); return track ? track->getVideoHeight() : 0; } API_EXPORT int API_CALL mk_player_video_fps(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackVideo)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackVideo)); return track ? track->getVideoFps() : 0; } API_EXPORT int API_CALL mk_player_audio_codecId(mk_player ctx){ assert(ctx); - MediaPlayer::Ptr& player = *((MediaPlayer::Ptr*)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackAudio)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackAudio)); return track ? track->getCodecId() : CodecInvalid; } API_EXPORT int API_CALL mk_player_audio_samplerate(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackAudio)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackAudio)); return track ? track->getAudioSampleRate() : 0; } API_EXPORT int API_CALL mk_player_audio_bit(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackAudio)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackAudio)); return track ? track->getAudioSampleBit() : 0; } API_EXPORT int API_CALL mk_player_audio_channel(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - auto track = dynamic_pointer_cast(player->getTrack(TrackAudio)); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + auto track = dynamic_pointer_cast(obj->getTrack(TrackAudio)); return track ? track->getAudioChannel() : 0; } API_EXPORT float API_CALL mk_player_duration(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - return player->getDuration(); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + return obj->getDuration(); } API_EXPORT float API_CALL mk_player_progress(mk_player ctx) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - return player->getProgress(); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + return obj->getProgress(); } API_EXPORT float API_CALL mk_player_loss_rate(mk_player ctx, int track_type) { assert(ctx); - MediaPlayer::Ptr &player = *((MediaPlayer::Ptr *)ctx); - return player->getPacketLossRate((TrackType)track_type); + MediaPlayerForC &obj = **((MediaPlayerForC::Ptr *)ctx); + return obj->getPacketLossRate((TrackType)track_type); }