在Android开发直播应用时,大家都会首先想到找一个开源的第三方播放器框架,只是这些开源框架的更新维护都几乎停滞了,为什么呢?Android已经发展了10多年了,官方的播放器已经非常强大,可以支持当前的主流播放需求。ExoPlayer就是Google推出的官方Android媒体播放组件,具体可以参考:https://developer.android.com/guide/topics/media/exoplayer,Demo源码在:https://github.com/google/ExoPlayer
现在我们来基于ExoPlayer搭建一个Android网络电视应用:
1. 集成ExoPlayer:
Android集成步骤,参考:https://github.com/google/ExoPlayer
自定义播放器控件:
public class ExoPlayerLayout extends RelativeLayout {
//播放器相关定义
private PlayerView mPlayerView;
private DataSource.Factory mDataSourceFactory;
private DefaultBandwidthMeter mDefaultBandwidthMeter;
private SimpleExoPlayer mPlayer;
private MediaSource mMediaSource;
protected String mUserAgent;
private Cache mDownloadCache;
private boolean mNewPlayFlag = false;
private long mPlayerSuspendStart = 0; //卡顿开始时间点
private static final String TAG = "ExoPlayerLayout";
//节目列表相关定义
private TVProgramBean mTVProgramBean = null;
private String mTVProgramUrl = "";
private Handler mEventHandler;
public ExoPlayerLayout(Context context) {
super(context);
}
public ExoPlayerLayout(Context context, AttributeSet attrs) {
super(context, attrs);
}
public ExoPlayerLayout(Context context, AttributeSet attrs, int defStyleAttr) {
super(context, attrs, defStyleAttr);
}
public boolean initView() {
Log.i("ExoPlayerLayout",
"initView:");
//播放器控件初始化
mPlayerView = new PlayerView(this.getContext());
RelativeLayout.LayoutParams layoutParams = new RelativeLayout.LayoutParams(this.getWidth(), this.getHeight());
mPlayerView.setControllerAutoShow(false);
mPlayerView.setUseController(false);
mPlayerView.setFocusable(false);
this.addView(mPlayerView, RelativeLayout.LayoutParams.MATCH_PARENT, RelativeLayout.LayoutParams.MATCH_PARENT);
//事件处理Handler初始化
mEventHandler = new Handler(Looper.getMainLooper());
//数据初始化
mUserAgent = Util.getUserAgent(this.getContext(), "LoveTV");
mDataSourceFactory = buildDataSourceFactory();
return true;
}
//开始节目播放
public void startProgram(TVProgramBean tvProgramBean) {
mNewPlayFlag = true;
palyTV(tvProgramBean, "");
}
//播放节目
private void palyTV(TVProgramBean tvProgramBean, String defalutTVProgramUrl) {
mTVProgramBean = tvProgramBean;
if (null != mPlayer) {
if (null != mPlayerView) {
mPlayerView.onPause();
this.removeView(mPlayerView);
mPlayerView = new PlayerView(this.getContext());
RelativeLayout.LayoutParams layoutParams = new RelativeLayout.LayoutParams(this.getWidth(), this.getHeight());
mPlayerView.setControllerAutoShow(false);
mPlayerView.setUseController(false);
mPlayerView.setFocusable(false);
this.addView(mPlayerView, RelativeLayout.LayoutParams.MATCH_PARENT, RelativeLayout.LayoutParams.MATCH_PARENT);
}
mPlayer.release();
mPlayer = null;
}
mPlayer =
ExoPlayerFactory.newSimpleInstance(
/* context= */ this.getContext());
//设置播放器事件监听
mPlayer.addListener(new PlayerEventListener());
mPlayer.setPlayWhenReady(true);
mPlayerView.setPlayer(mPlayer);
mTVProgramUrl = defalutTVProgramUrl;
if (!TextUtils.isEmpty(tvProgramBean.getSrcFHDUrl())) {
mTVProgramUrl = tvProgramBean.getSrcFHDUrl();
} else if (!TextUtils.isEmpty(tvProgramBean.getSrcHDUrl())) {
mTVProgramUrl = tvProgramBean.getSrcHDUrl();
} else if (!TextUtils.isEmpty(tvProgramBean.getSrcUrl())) {
mTVProgramUrl = tvProgramBean.getSrcUrl();
}
mMediaSource = buildMediaSource(Uri.parse(mTVProgramUrl), null);
mPlayer.prepare(mMediaSource, true, false);
startLoading();
}
private MediaSource buildMediaSource(Uri uri) {
return buildMediaSource(uri, null);
}
@SuppressWarnings("unchecked")
private MediaSource buildMediaSource(Uri uri, @Nullable String overrideExtension) {
@C.ContentType int type = Util.inferContentType(uri, overrideExtension);
List<StreamKey> keysList = new ArrayList<>();
switch (type) {
case C.TYPE_DASH:
return new DashMediaSource.Factory(mDataSourceFactory)
.setManifestParser(
new FilteringManifestParser<>(new DashManifestParser(), keysList))
.createMediaSource(uri);
case C.TYPE_SS:
return new SsMediaSource.Factory(mDataSourceFactory)
.setManifestParser(
new FilteringManifestParser<>(new SsManifestParser(), keysList))
.createMediaSource(uri);
case C.TYPE_HLS:
return new HlsMediaSource.Factory(mDataSourceFactory)
.setPlaylistParserFactory(
new DefaultHlsPlaylistParserFactory(keysList))
.createMediaSource(uri);
case C.TYPE_OTHER:
return new ExtractorMediaSource.Factory(mDataSourceFactory).createMediaSource(uri);
default: {
throw new IllegalStateException("Unsupported type: " + type);
}
}
}
public void releaseProgram() {
if (null != mPlayerView) {
mPlayerView.onPause();
this.removeView(mPlayerView);
}
if (mPlayer != null) {
mPlayer.release();
mPlayer = null;
mMediaSource = null;
}
}
/**
* Returns a {@link DataSource.Factory}.
*/
public DataSource.Factory buildDataSourceFactory() {
//设置带宽监测
mDefaultBandwidthMeter = new DefaultBandwidthMeter();
DefaultDataSourceFactory upstreamFactory = new DefaultDataSourceFactory(this.getContext(),
mUserAgent, mDefaultBandwidthMeter);
return buildReadOnlyCacheDataSource(upstreamFactory, getDownloadCache());
}
private static CacheDataSourceFactory buildReadOnlyCacheDataSource(
DefaultDataSourceFactory upstreamFactory, Cache cache) {
return new CacheDataSourceFactory(
cache,
upstreamFactory,
new FileDataSourceFactory(),
/* cacheWriteDataSinkFactory= */ null,
CacheDataSource.FLAG_IGNORE_CACHE_ON_ERROR,
/* eventListener= */ null);
}
private synchronized Cache getDownloadCache() {
//设置下载缓存
Log.i("ExoPlayerLayout",
"getDownloadCache:" + mDownloadCache);
if (mDownloadCache == null) {
File downloadContentDirectory = new File(this.getContext().getFilesDir().toString()
+ "/ExoPlayer/");
mDownloadCache = new SimpleCache(downloadContentDirectory, new NoOpCacheEvictor());
}
return mDownloadCache;
}
private class PlayerEventListener implements Player.EventListener {
@Override
public void onPlayerStateChanged(boolean playWhenReady, int playbackState) {
switch (playbackState) {
case Player.STATE_IDLE:
case Player.STATE_BUFFERING:
startLoading();
break;
case Player.STATE_READY:
finishLoading();
break;
case Player.STATE_ENDED:
break;
}
Log.i("PlayerEventListener",
"onPlayerStateChanged:" + playWhenReady + "," + playbackState);
}
@Override
public void onPlayerError(ExoPlaybackException error) {
String errStr = error.getCause().getMessage();
Log.d(TAG, mTVProgramUrl);
Log.d(TAG, error.getLocalizedMessage());
}
}
private void startLoading() {
try {
/*增加加載gif动画效果*/
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
private void finishLoading() {
try {
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
}
2. 接入网络电视直播源:
电视的节目源是.m3u8的HLS流,可以在网上找到,如:
"CCTV1-综合",
"http://223.110.245.159/ott.js.chinamobile.com/PLTV/3/224/3221225530/index.m3u8"
3. 监测直播流的下载速度:
网上有很多直播流的下载速率计算方法,但我们只要官方的方法即可:
DefaultBandwidthMeter:ExoPlayer的官方带宽统计类,我们只要调用mDefaultBandwidthMeter.getBitrateEstimate(),即可获取网络的下载速率。
4. 监测播放器的卡顿、视频源错误:
ExoPlayer的Player.EventListener,是官方的播放异常检测类,我们只要重载相关方法即可完成相关事件监测:
private class PlayerEventListener implements Player.EventListener {
@Override
public void onPlayerStateChanged(boolean playWhenReady, int playbackState) {
switch (playbackState) {
case Player.STATE_IDLE:
case Player.STATE_BUFFERING:
startLoading();
break;
case Player.STATE_READY:
finishLoading();
break;
case Player.STATE_ENDED:
break;
}
Log.i("PlayerEventListener",
"onPlayerStateChanged:" + playWhenReady + "," + playbackState);
}
@Override
public void onPlayerError(ExoPlaybackException error) {
String errStr = error.getCause().getMessage();
Log.d(TAG, mTVProgramUrl);
Log.d(TAG, error.getLocalizedMessage());
}
}
onPlayerStateChanged:可以用来检测播放器的卡顿问题,只有当播放器处于Player.STATE_READY状态,视频流才处于播放中; Player.STATE_IDLE/Player.STATE_BUFFERING状态,表示播放器处于等待状态。
onPlayerError:可以监测播放过程中的源错误,如:找不到源的404错误,源格式错误等。
总结:
1. ExoPlayer是个优秀的官方播放器方案,可以实现绝大部分的播放需求;
2. 基于系统级的播放器,可以大大减小第三方播放器的库文件大小,同时减小APK的包尺寸;
3. 随着Android系统的日益成熟,视频流的播放难点会由播放器本身转移到网络、服务器能力。