Volley源码解析(一)——主流程分析

在阅读源码之前,我们先大致了解一下Volley运行的一些基本原理:Volley在启动之后会启动两种线程,分别是缓存调度线程和网络请求线程,默认情况下会创建4个网络请求线程组成线程池。Volley的请求队列,无论是准备就绪的网络请求队列还是缓存队列,都是采用优先级队列PriorityBlockingQueue进行存储的,所以Volley的网络请求是具有优先级控制功能的;由于Volley具有缓存调度,所以Volley是可以过滤重复的网络请求。我们可以在Volley的请求回调方法中安全的操作主线程,不需要担心Volley子线程引起的跨线程UI更新问题,这归功于Volley结果分发器为我们做了跨线程处理。
如果上面对Volley的原理简单介绍无法理解,不要紧,下来我们将围绕Volley的网络请求线程调度、缓存机制、优先级控制、结果分发器展开解析。
我们使用Volley时,是从newRequestQueue方法开始,那么我们就从Volley.newRequestQueue方法切入Volley的源码:

RequestQueue requestQueue = Volley.newRequestQueue(this);

newRequestQueue方法源码:

    public static RequestQueue newRequestQueue(Context context, HttpStack stack, int maxDiskCacheBytes) {
        File cacheDir = new File(context.getCacheDir(), DEFAULT_CACHE_DIR);

        String userAgent = "volley/0";
        try {
            String packageName = context.getPackageName();
            PackageInfo info = context.getPackageManager().getPackageInfo(packageName, 0);
            userAgent = packageName + "/" + info.versionCode;
        } catch (NameNotFoundException e) {
        }

        if (stack == null) {
            if (Build.VERSION.SDK_INT >= 9) {
                stack = new HurlStack();
            } else {
                // Prior to Gingerbread, HttpUrlConnection was unreliable.
                // See: http://android-developers.blogspot.com/2011/09/androids-http-clients.html
                stack = new HttpClientStack(AndroidHttpClient.newInstance(userAgent));
            }
        }

        Network network = new BasicNetwork(stack);
        
        RequestQueue queue;
        if (maxDiskCacheBytes <= -1)
        {
            // No maximum size specified
            queue = new RequestQueue(new DiskBasedCache(cacheDir), network);
        }
        else
        {
            // Disk cache size specified
            queue = new RequestQueue(new DiskBasedCache(cacheDir, maxDiskCacheBytes), network);
        }

        queue.start();

        return queue;
    }

newRequestQueue的工作步骤:
1、newRequestQueue方法的第一行就是创建一个文件目录(文件夹),这个目录将用于缓存Volley的网络请求。接着,会根据系统的版本,分别创建HurlStack和HttpClientStack。这两个类就是Volley的网络请求类,它们将执行真正的网络请求操作。只不过,HurlStack底层调用的是HttpUrlConnection类来实现网络请求,而HttpClientStack是调用HttpClient类来实现网络请求,因为在API9以下,HttpUrlConnection类是存在Bug的,所以Volley在此做了兼容。我们之后对网络请求的分析将基于HurlStack类来展开。
2、接着创建BasicNetwork类,BasicNetwork实现了Network接口,它将负责把HurlStack类执行网络请求后的结果进一步加工处理。
3、最后创建RequestQueue类,并启动它。RequestQueue就是网络请求队列、缓存的集成中心,网络请求线程、缓存线程就是由他的start方法创建启动的。
由此,我们定位到RequestQueue的start方法:

    public void start() {
        stop();  // Make sure any currently running dispatchers are stopped.
        // Create the cache dispatcher and start it.
        mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery);
        mCacheDispatcher.start();

        // Create network dispatchers (and corresponding threads) up to the pool size.
        for (int i = 0; i < mDispatchers.length; i++) {
            NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork,
                    mCache, mDelivery);
            mDispatchers[i] = networkDispatcher;
            networkDispatcher.start();
        }
    }

在start方法里面,先调用程序清除mCacheDispatcher和mDispatchers,接着在重新new创建新的mCacheDispatcher和mDispatchers。
那么mCacheDispatcher和mDispatchers是什么呢?
mCacheDispatcher是CacheDispatcher类,继承于Thread,它就是前面所说的缓存调度线程,在其run方法中进入死循环,不断的读取处理具有优先级性质的缓存队列中的请求。
mDispatchers也是NetworkDispatcher类,继承于Thread类,它就是网络请求调度线程,由mDispatchers.length个NetworkDispatcher组成网络请求调度线程池。
到这里,我们知道网络请求被压进请求队列和缓存队列,通过网络请求调度线程和缓存调度线程来处理他们,最终通过分发器回调到UI界面。那么,这些请求是怎么被压进队列里面的呢?回想一下,我们使用Volley的时候,除了创建RequestQueue之外,我们在进行网络请求的时候,会把创建Request add到RequestQueue中,所以,我们定位到RequestQueue的add方法:

    public <T> Request<T> add(Request<T> request) {
        // Tag the request as belonging to this queue and add it to the set of current requests.
        request.setRequestQueue(this);
        synchronized (mCurrentRequests) {
            mCurrentRequests.add(request);
        }

        // Process requests in the order they are added.
        request.setSequence(getSequenceNumber());
        request.addMarker("add-to-queue");

        // If the request is uncacheable, skip the cache queue and go straight to the network.
        if (!request.shouldCache()) {
            mNetworkQueue.add(request);
            return request;
        }

        // Insert request into stage if there's already a request with the same cache key in flight.
        synchronized (mWaitingRequests) {
            String cacheKey = request.getCacheKey();
            if (mWaitingRequests.containsKey(cacheKey)) {
                // There is already a request in flight. Queue up.
                Queue<Request<?>> stagedRequests = mWaitingRequests.get(cacheKey);
                if (stagedRequests == null) {
                    stagedRequests = new LinkedList<Request<?>>();
                }
                stagedRequests.add(request);
                mWaitingRequests.put(cacheKey, stagedRequests);
                if (VolleyLog.DEBUG) {
                    VolleyLog.v("Request for cacheKey=%s is in flight, putting on hold.", cacheKey);
                }
            } else {
                // Insert 'null' queue for this cacheKey, indicating there is now a request in
                // flight.
                mWaitingRequests.put(cacheKey, null);
                mCacheQueue.add(request);
            }
            return request;
        }
    }

由于网络调度线程池是由默认4个(mDispatchers.length)Thread的网络调度器组成的,所以这里用synchronized修饰同步块(第9行代码),把Request添加到当前队mCurrentRequests列里面。接着判断Request是否缓存的标志,若不需要缓存直接add到网络请求就绪队列mNetworkQueue里面直接准备进行网络请求操作;如果允许缓存,则会到阻塞队列mWaitingRequests里面查找是否存在,存在的话,刷新阻塞队列里面对应的Request;不存在的话,则把Request put进阻塞队列和缓存队列mCacheQueue。
那么阻塞队列mWaitingRequests是起什么作用的呢?缓存队列mCacheQueue会由CacheDispatcher去调度,“备份”一份在阻塞队列中,为何呢?回到阻塞队列声明的地方:

    /**
     * Staging area for requests that already have a duplicate request in flight.
     *
     * <ul>
     *     <li>containsKey(cacheKey) indicates that there is a request in flight for the given cache
     *          key.</li>
     *     <li>get(cacheKey) returns waiting requests for the given cache key. The in flight request
     *          is <em>not</em> contained in that list. Is null if no requests are staged.</li>
     * </ul>
     */
    private final Map<String, Queue<Request<?>>> mWaitingRequests =
            new HashMap<String, Queue<Request<?>>>();

从他的英文注释中可以知道,这个阻塞队列是为了防止重复的Request。当有多个相同的Request请求发起,后续的相同的Request并不会产生新的Request,而是更新原来的第一个的Request信息。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,444评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,421评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,036评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,363评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,460评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,502评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,511评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,280评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,736评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,014评论 2 328
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,190评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,848评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,531评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,159评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,411评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,067评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,078评论 2 352

推荐阅读更多精彩内容