AndroidVideoCache源码浅析

Posted yongfengnice

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了AndroidVideoCache源码浅析相关的知识,希望对你有一定的参考价值。

1. 边播放边缓存

  视频播放时边播放边缓存,这样用户再次播放时可以节省流量,提高用户体验,这是视频播放很常见的需求。但是,android的VideoView是没有提供这样的功能的。

有个开源库比较好用,github地址:https://github.com/danikula/AndroidVideoCache

2. 简述一下AndroidVideoCache的大体实现原理

  大家都知道,VideoView.setVideoPath(proxyUrl);走的也是http请求,而http底层是走tcp协议的socket实现的。AndroidVideoCache的实现就是在tcp层架一个SocketServer的代理服务器,也就是说VideoView.setVideoPath(proxyUrl);的请求是先请求到代理服务器SocketServer,然后代理服务器SocketServer再去请求真正的服务器。这样,这个代理服务器SocketServer就可以去请求真正的服务器去下载视频(AndroidVideoCache是分段下载,也就是断点续传,每次8 * 1024大小),然后将视频响应给请求。当然代理服务器SocketServer还会先判断该视频是否已经下载缓存完,如果已经下载缓存完就直接使用本地的缓存视频。

3. AndroidVideoCache源代码简述

  1)App全局架设一个本地Socket代理服务器 

    InetAddress inetAddress = InetAddress.getByName(PROXY_HOST);
    this.serverSocket = new ServerSocket(0, 8, inetAddress);

  2)getProxyUrl方法,先判断是否已经缓存过了,如果是直接使用本地缓存。如果否,就判断代理服务器SocketServer是否可用

    public String getProxyUrl(String url, boolean allowCachedFileUri) {
      if (allowCachedFileUri && isCached(url)) {  //缓存ok
        File cacheFile = getCacheFile(url);
        touchFileSafely(cacheFile);  //touch一下文件,让该文件时间最新,用于LRUcache缓存,LRUcache缓存是按照时间排序的。
        return Uri.fromFile(cacheFile).toString();
      }
        return isAlive() ? appendToProxyUrl(url) : url;  //isAlive()方法里就是ping了一下代理服务器SocketServer,看看是否可用?是,包装成proxyURL,否,使用来源的url,不缓存
      }

  3)processSocket处理所有的请求进来的Socket,包括ping的和VideoView.setVideoPath(proxyUrl)的Socket

      private void processSocket(Socket socket) {
        GetRequest request = GetRequest.read(socket.getInputStream());
        LOG.debug("Request to cache proxy:" + request);
        String url = ProxyCacheUtils.decode(request.uri);
        if (pinger.isPingRequest(url)) {  //如果是ping的,返回ping响应
          pinger.responseToPing(socket);
        } else {  //视频的Socket,启动对应的Client去处理
          HttpProxyCacheServerClients clients = getClients(url);
          clients.processRequest(request, socket);
        }
      }

  4)clients.processRequest(request, socket);方法的实现

    public void processRequest(GetRequest request, Socket socket) throws ProxyCacheException, IOException {
      startProcessRequest();  //这个方法其实就是获取一个proxyCache对应
      try {
        clientsCount.incrementAndGet();
        proxyCache.processRequest(request, socket);  //交给proxyCache处理
      } finally {
        finishProcessRequest();
      }
    }

    private synchronized void startProcessRequest() throws ProxyCacheException {
      proxyCache = proxyCache == null ? newHttpProxyCache() : proxyCache;  //newHttpProxyCache() 这个方法准备一下url,缓存file路径,监听器等等。。。
    }

  5)proxyCache.processRequest(request, socket);方法的实现

    public void processRequest(GetRequest request, Socket socket) throws IOException, ProxyCacheException {
      OutputStream out = new BufferedOutputStream(socket.getOutputStream());  //创建一个Socket的响应流
      String responseHeaders = newResponseHeaders(request);
      out.write(responseHeaders.getBytes("UTF-8"));

      long offset = request.rangeOffset;
      if (isUseCache(request)) {  //判断是否使用缓存?是
        responseWithCache(out, offset);  //缓存并响应  
      } else {  //不使用缓存
        responseWithoutCache(out, offset);  //不缓存并响应
      }
    }

  6)responseWithCache(out, offset);方法的实现

    while (!cache.isCompleted() && cache.available() < (offset + length) && !stopped) {
      readSourceAsync();  //异步请求真正的服务器读取该段数据,读取完会通知
      waitForSourceData();  //加锁等待readSourceAsync()的通知
      checkReadSourceErrorsCount();  //校验错误
    }

  6-1)readSourceAsync();方法最后回调用readSource()方法 

    private void readSource() {
      long sourceAvailable = -1;
      long offset = 0;
      try {
        offset = cache.available();
        source.open(offset);
        sourceAvailable = source.length();
        byte[] buffer = new byte[ProxyCacheUtils.DEFAULT_BUFFER_SIZE];  //每次读取这么多数据ProxyCacheUtils.DEFAULT_BUFFER_SIZE
        int readBytes;
        while ((readBytes = source.read(buffer)) != -1) {
          synchronized (stopLock) {
            if (isStopped()) {
            return;
          }
          cache.append(buffer, readBytes);  //追加到cache
        }
        offset += readBytes;
        notifyNewCacheDataAvailable(offset, sourceAvailable);  //通知有数据可用,也就是唤醒waitForSourceData()方法,让while (!cache.isCompleted() && cache.available() < (offset + length) && !stopped)继续判断执行下去
      }
        tryComplete();  //这个方法判断文件是否已经下载完成了。cache的文件是一个临时的.download为后缀的文件,分段缓存完成整个视频文件后,修改文件名为与请求url关联的文件名
        onSourceRead();
      } catch (Throwable e) {
        readSourceErrorsCount.incrementAndGet();
        onError(e);
      } finally {
        closeSource();
        notifyNewCacheDataAvailable(offset, sourceAvailable);
      }
    }

  7)responseWithoutCache(out, offset);方法的实现

    private void responseWithoutCache(OutputStream out, long offset) throws ProxyCacheException, IOException {
      HttpUrlSource newSourceNoCache = new HttpUrlSource(this.source);
      try {
        newSourceNoCache.open((int) offset);  //这个方法里面打开HttpURLConnection
        byte[] buffer = new byte[DEFAULT_BUFFER_SIZE];
        int readBytes;
        while ((readBytes = newSourceNoCache.read(buffer)) != -1) {  //read读取HttpURLConnection的getInputStream()的数据
        out.write(buffer, 0, readBytes);
        offset += readBytes;
      }
      out.flush();
    } finally {
      newSourceNoCache.close();
    }
  }

  




















































































以上是关于AndroidVideoCache源码浅析的主要内容,如果未能解决你的问题,请参考以下文章

kernel源码浅析

redux 源码浅析

flinkFlink 1.12.2 源码浅析 : Task 浅析

Android手势源码浅析-----手势绘制(GestureOverlayView)

jQuery源码浅析

View绘制源码浅析(一)布局的加载