技术员联盟提供win764位系统下载,win10,win7,xp,装机纯净版,64位旗舰版,绿色软件,免费软件下载基地!

当前位置:主页 > 教程 > 服务器类 >

Android视频点播的实现代码(边播边缓存)

来源:技术员联盟┆发布时间:2017-06-16 12:46┆点击:

一些知名的视频app客户端(优酷,爱奇艺)播放视频的时候都有一些缓存进度(二级进度缓存),还有一些短视频app,都有边播边缓的处理。还有就是当文件缓存完毕了再次播放的话就不再请求网络了直接播放本地文件了。既节省了流程又提高了加载速度。

今天我们就是来研究讨论实现这个边播边缓存的框架,因为它不和任何的业务逻辑耦合。

开源的项目

目前比较好的开源项目是:https://github.com/danikula/AndroidVideoCache

代码的架构写的也很不错,网络用的httpurlconnect,文件缓存处理,文件最大限度策略,回调监听处理,断点续传,代理服务等。很值得研究阅读.

个人觉得项目中有几个需要优化的点,今天就来处理这几个并简要分析下原理

优化点比如:

文件的缓存超过限制后没有按照lru算法删除,

处理返回给播放器的http响应头消息,响应头消息的获取处理改为head请求(需服务器支持)

替换网络库为okhttp(因为大部分的项目都是以okhttp为网络请求库的)

该开源项目的原理分析-本地代理

Android视频点播的实现代码(边播边缓存)

采用了本地代理服务的方式,通过原始url给播放器返回一个本地代理的一个url ,代理URL类似::57430/xxxx;然后播放器播放的时候请求到了你本地的代理上了。

本地代理采用ServerSocket监听127.0.0.1的有效端口,这个时候手机就是一个服务器了,客户端就是socket,也就是播放器。

读取客户端就是socket来读取数据(http协议请求)解析http协议。

根据url检查视频文件是否存在,读取文件数据给播放器,也就是往socket里写入数据。同时如果没有下载完成会进行断点下载,当然弱网的话数据需要生产消费同步处理。

优化点

1. 文件的缓存超过限制后没有按照lru算法删除.

Files类。

由于在移动设备上file.setLastModified() 方法不支持毫秒级的时间处理,导致超出限制大小后本应该删除老的,却没有删除抛出了异常。注释掉主动抛出的异常即可。因为文件的修改时间就是对的。

static void setLastModifiedNow(File file) throws IOException { if (file.exists()) { long now = System.currentTimeMillis(); boolean modified = file.setLastModified(now/1000*1000); // on some devices (e.g. Nexus 5) doesn't work if (!modified) { modify(file); // if (file.lastModified() < now) { // VideoCacheLog.debug("LruDiskUsage", "modified not ok "); // throw new IOException("Error set last modified date to " + file); // }else{ // VideoCacheLog.debug("LruDiskUsage", "modified ok "); // } } } }

2. 处理返回给播放器的http响应头消息,响应头消息的获取处理改为head请求(需要服务器支持)

HttpUrlSource类。fetchContentInfo方法是获取视频文件的Content-Type,Content-Length信息,是为了播放器播放的时候给播放器组装http响应头信息用的。所以这一块需要用数据库保存,这样播放器每次播放的时候不要在此获取了,减少了请求的次数,节省了流量。既然是只需要头信息,不需要响应体,所以我们在获取的时候可以直接采用HEAD方法。所以代码增加了一个方法openConnectionForHeader如下:

private void fetchContentInfo() throws ProxyCacheException { VideoCacheLog.debug(TAG,"Read content info from " + sourceInfo.url); HttpURLConnection urlConnection = null; InputStream inputStream = null; try { urlConnection = openConnectionForHeader(20000); long length = getContentLength(urlConnection); String mime = urlConnection.getContentType(); inputStream = urlConnection.getInputStream(); this.sourceInfo = new SourceInfo(sourceInfo.url, length, mime); this.sourceInfoStorage.put(sourceInfo.url, sourceInfo); VideoCacheLog.debug(TAG,"Source info fetched: " + sourceInfo); } catch (IOException e) { VideoCacheLog.error(TAG,"Error fetching info from " + sourceInfo.url ,e); } finally { ProxyCacheUtils.close(inputStream); if (urlConnection != null) { urlConnection.disconnect(); } } } // for HEAD private HttpURLConnection openConnectionForHeader(int timeout) throws IOException, ProxyCacheException { HttpURLConnection connection; boolean redirected; int redirectCount = 0; String url = this.sourceInfo.url; do { VideoCacheLog.debug(TAG, "Open connection for header to " + url); connection = (HttpURLConnection) new URL(url).openConnection(); if (timeout > 0) { connection.setConnectTimeout(timeout); connection.setReadTimeout(timeout); } //只返回头部,不需要BODY,既可以提高响应速度也可以减少网络流量 connection.setRequestMethod("HEAD"); int code = connection.getResponseCode(); redirected = code == HTTP_MOVED_PERM || code == HTTP_MOVED_TEMP || code == HTTP_SEE_OTHER; if (redirected) { url = connection.getHeaderField("Location"); VideoCacheLog.debug(TAG,"Redirect to:" + url); redirectCount++; connection.disconnect(); VideoCacheLog.debug(TAG,"Redirect closed:" + url); } if (redirectCount > MAX_REDIRECTS) { throw new ProxyCacheException("Too many redirects: " + redirectCount); } } while (redirected); return connection; }

3.替换网络库为okhttp(因为大部分的项目都是以okhttp为网络请求库的)