<uses-permission android:name="android.permission.INTERNET" />

RequestQueue mQueue = Volley.newRequestQueue(context);

/** method：請(qǐng)求方法
url：請(qǐng)求的地址
listener：響應(yīng)成功的監(jiān)聽(tīng)器
errorListener：出錯(cuò)時(shí)的監(jiān)聽(tīng)器 **/
public StringRequest(int method, String url, Listener<String> listener, ErrorListener errorListener)
/**不傳入method，默認(rèn)會(huì)調(diào)用GET方式進(jìn)行請(qǐng)求**/
public StringRequest(String url, Listener<String> listener, ErrorListener errorListener) {
this(Method.GET, url, listener, errorListener);
}

StringRequest stringRequest = new StringRequest("http://www.baidu.com",
new Response.Listener<String>() {
@Override
public void onResponse(String response) {
Toast.makeText(MainActivity.this, response, Toast.LENGTH_SHORT).show();
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
showlog(error.getMessage());
}
});

StringRequest stringRequest = new StringRequest(Method.POST, url, listener, errorListener) { 
@Override 
protected Map<String, String> getParams() throws AuthFailureError { 
Map<String, String> map = new HashMap<String, String>(); 
map.put("params1", "value1"); 
map.put("params2", "value2"); 
return map; 
} 
};

mQueue.add(stringRequest);

//jsonRequest：POST請(qǐng)求攜帶的參數(shù)，可以為空，表示不攜帶參數(shù)
public JsonObjectRequest(int method, String url, JSONObject jsonRequest, Listener<JSONObject> listener, ErrorListener errorListener) {
super(method, url, (jsonRequest == null) ? null : jsonRequest.toString(), listener, errorListener);
}
//如果jsonRequest為空，默認(rèn)使用GET請(qǐng)求，否則使用POST
public JsonObjectRequest(String url, JSONObject jsonRequest, Listener<JSONObject> listener, ErrorListener errorListener) {
this(jsonRequest == null ? Method.GET : Method.POST, url, jsonRequest, listener, errorListener);
}

RequestQueue mQueue = Volley.newRequestQueue(context);
JsonObjectRequest jsonObjectRequest = new JsonObjectRequest("http://weather.51wnl.com/weatherinfo/GetMoreWeather?cityCode=101020100&weatherType=0", null, 
new Response.Listener<JSONObject>() { 
@Override 
public void onResponse(JSONObject response) { 
Toast.makeText(MainActivity.this, response.toString(), Toast.LENGTH_SHORT).show();
try {
response = response.getJSONObject("weatherinfo");
showlog("city = " + response.getString("city"));
showlog("weather1 = " + response.getString("weather1"));
} catch (JSONException e) {
e.printStackTrace();
}
} 
}, new Response.ErrorListener() { 
@Override 
public void onErrorResponse(VolleyError error) { 
showlog(error.getMessage()); 
} 
});
mQueue.add(jsonObjectRequest);

Map<String, String> params = new HashMap<String, String>(); 
params.put("name1", "value1"); 
params.put("name2", "value2"); 
JSONObject jsonRequest= new JSONObject(params);
JsonObjectRequest jsonObjectRequest = new JsonObjectRequest(Method.POST, url, jsonRequest, listener, errorListener)

public ImageRequest(String url, Response.Listener<Bitmap> listener, int maxWidth, int maxHeight, Config decodeConfig, Response.ErrorListener errorListener) {
super(Method.GET, url, errorListener);
setRetryPolicy(new DefaultRetryPolicy(IMAGE_TIMEOUT_MS, IMAGE_MAX_RETRIES, IMAGE_BACKOFF_MULT));
mListener = listener;
mDecodeConfig = decodeConfig;
mMaxWidth = maxWidth;
mMaxHeight = maxHeight;
}

RequestQueue mQueue = Volley.newRequestQueue(context);
ImageRequest imageRequest = new ImageRequest( 
"http://img.my.csdn.net/uploads/201308/31/1377949454_6367.jpg", 
new Response.Listener<Bitmap>() { 
@Override 
public void onResponse(Bitmap response) { 
image.setImageBitmap(response); 
} 
}, 0, 0, Config.RGB_565, new Response.ErrorListener() { 
@Override 
public void onErrorResponse(VolleyError error) { 
image.setImageResource(R.drawable.default_image); 
} 
}); 
mQueue.add(imageRequest);

ImageLoader imageLoader = new ImageLoader(mQueue, new ImageCache() {
@Override
public void putBitmap(String url, Bitmap bitmap) {
}
@Override
public Bitmap getBitmap(String url) {
return null;
}
});

ImageLoader imageLoader = new ImageLoader(mQueue, new BitmapCache());
//BitmapCache的實(shí)現(xiàn)類(lèi)
public class BitmapCache implements ImageCache {
private LruCache<String, Bitmap> mCache;
public BitmapCache() {
int maxSize = 10 * 1024 * 1024;
mCache = new LruCache<String, Bitmap>(maxSize) {
@Override
protected int sizeOf(String key, Bitmap value) {
return value.getRowBytes() * value.getHeight();
}
};
@Override
public Bitmap getBitmap(String url) {
return mCache.get(url);
}
@Override
public void putBitmap(String url, Bitmap bitmap) {
mCache.put(url, bitmap);
}
}

ImageListener listener = ImageLoader.getImageListener(imageView, R.drawable.default_image, R.drawable.fail_image); 

imageLoader.get("http://img.my.csdn.net/uploads/201309/01/1378037128_5291.jpg", listener); 

imageLoader.get("http://img.my.csdn.net/uploads/201309/01/1378037128_5291.jpg", listener, 600, 600); 

public final boolean shouldCache() //查看是否已經(jīng)做了磁盤(pán)緩存。
void setShouldCache(boolean shouldCache)//設(shè)置是否運(yùn)行磁盤(pán)緩存，此方法需要在get方法前使用
public boolean isCached(String requestUrl, int maxWidth, int maxHeight)//判斷對(duì)象是否已經(jīng)被緩存，傳入url，還有圖片的最大寬高

創(chuàng)建一個(gè)RequestQueue對(duì)象。
創(chuàng)建一個(gè)ImageLoader對(duì)象。
在布局文件中添加一個(gè)NetworkImageView控件。
在代碼中獲取該控件的實(shí)例。
設(shè)置要加載的圖片地址。
<com.android.volley.toolbox.NetworkImageView
android:id="@+id/network_image_view"
android:layout_width="200dp"
android:layout_height="200dp"
android:layout_gravity="center_horizontal" />
/**創(chuàng)建RequestQueue以及ImageLoader對(duì)象**/
RequestQueue mQueue = Volley.newRequestQueue(context);
ImageLoader imageLoader = new ImageLoader(mQueue, new BitmapCache()); 
/**獲取NetworkImageView控件**/
NetworkImageView networkImageView = (NetworkImageView) findViewById(R.id.network_image_view);
/**設(shè)置加載中顯示的圖片**/
networkImageView.setDefaultImageResId(R.drawable.default_image);
/**加載失敗時(shí)顯示的圖片**/
networkImageView.setErrorImageResId(R.drawable.fail_image);
/**設(shè)置目標(biāo)圖片的URL地址**/
networkImageView.setImageUrl("http://img.my.csdn.net/uploads/201309/01/1378037151_7904.jpg", imageLoader);

package com.android.volley.toolbox;
public class StringRequest extends Request<String> {
// 建立監(jiān)聽(tīng)器來(lái)獲得響應(yīng)成功時(shí)返回的結(jié)果
private final Listener<String> mListener; 
// 傳入請(qǐng)求方法，url，成功時(shí)的監(jiān)聽(tīng)器，失敗時(shí)的監(jiān)聽(tīng)器
public StringRequest(int method, String url, Listener<String> listener, ErrorListener errorListener) {
super(method, url, errorListener);
// 初始化成功時(shí)的監(jiān)聽(tīng)器
mListener = listener;
}
/**
* Creates a new GET request.
* 建立一個(gè)默認(rèn)的GET請(qǐng)求，調(diào)用了上面的構(gòu)造函數(shù)
*/
public StringRequest(String url, Listener<String> listener, ErrorListener errorListener) {
this(Method.GET, url, listener, errorListener);
}
@Override
protected void deliverResponse(String response) {
// 用監(jiān)聽(tīng)器的方法來(lái)傳遞下響應(yīng)的結(jié)果
mListener.onResponse(response);
}
@Override
protected Response<String> parseNetworkResponse(NetworkResponse response) {
String parsed;
try {
// 調(diào)用了new String(byte[] data, String charsetName) 這個(gè)構(gòu)造函數(shù)來(lái)構(gòu)建String對(duì)象，將byte數(shù)組按照特定的編碼方式轉(zhuǎn)換為String對(duì)象，主要部分是data
parsed = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
} catch (UnsupportedEncodingException e) {
parsed = new String(response.data);
}
return Response.success(parsed, HttpHeaderParser.parseCacheHeaders(response));
}
}

public class XMLRequest extends Request<XmlPullParser> {
private final Listener<XmlPullParser> mListener;
public XMLRequest(int method, String url, Listener<XmlPullParser> listener, ErrorListener errorListener) {
super(method, url, errorListener);
mListener = listener;
}
public XMLRequest(String url, Listener<XmlPullParser> listener, ErrorListener errorListener) {
this(Method.GET, url, listener, errorListener);
}
@Override
protected Response<XmlPullParser> parseNetworkResponse(NetworkResponse response) {
try {
String xmlString = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
XmlPullParserFactory factory = XmlPullParserFactory.newInstance();
XmlPullParser xmlPullParser = factory.newPullParser();
xmlPullParser.setInput(new StringReader(xmlString));
return Response.success(xmlPullParser, HttpHeaderParser.parseCacheHeaders(response));
} catch (UnsupportedEncodingException e) {
return Response.error(new ParseError(e));
} catch (XmlPullParserException e) {
return Response.error(new ParseError(e));
}
}
@Override
protected void deliverResponse(XmlPullParser response) {
mListener.onResponse(response);
}
}

XMLRequest xmlRequest = new XMLRequest("http://flash.weather.com.cn/wmaps/xml/china.xml", 
new Response.Listener<XmlPullParser>() { 
@Override 
public void onResponse(XmlPullParser response) { 
try { 
int eventType = response.getEventType(); 
while (eventType != XmlPullParser.END_DOCUMENT) { 
switch (eventType) { 
case XmlPullParser.START_TAG: 
String nodeName = response.getName(); 
if ("city".equals(nodeName)) { 
String pName = response.getAttributeValue(0); 
String cName = response.getAttributeValue(2); 
showlog("省份：" + pName + " 城市：" + cName);
} 
break; 
} 
eventType = response.next(); 
} 
} catch (XmlPullParserException e) { 
e.printStackTrace(); 
} catch (IOException e) { 
e.printStackTrace(); 
} 
} 
}, new Response.ErrorListener() { 
@Override 
public void onErrorResponse(VolleyError error) { 
showlog(error.getMessage()); 
} 
}); 
mQueue.add(xmlRequest);

public class GsonRequest<T> extends Request<T> {
private final Listener<T> mListener;
private Gson mGson;
private Class<T> mClass;
public GsonRequest(int method, String url, Class<T> clazz, Listener<T> listener, ErrorListener errorListener) {
super(method, url, errorListener);
mGson = new Gson();
mClass = clazz;
mListener = listener;
}
public GsonRequest(String url, Class<T> clazz, Listener<T> listener, ErrorListener errorListener) {
this(Method.GET, url, clazz, listener, errorListener);
}
@Override
protected Response<T> parseNetworkResponse(NetworkResponse response) {
try {
String jsonString = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
return Response.success(mGson.fromJson(jsonString, mClass), HttpHeaderParser.parseCacheHeaders(response));
} catch (UnsupportedEncodingException e) {
return Response.error(new ParseError(e));
}
}
@Override
protected void deliverResponse(T response) {
mListener.onResponse(response);
}
}

{"weatherinfo":{"city":"上海","city_en":"","cityid":101020100,"date":"","date_y":"2016年09月20日","fchh":0,"fl1":"","fl2":"","fl3":"","fl4":"","fl5":"","fl6":"","fx1":"","fx2":"","img1":"1","img10":"1","img11":"1","img12":"1","img2":"1","img3":"1","img4":"1","img5":"1","img6":"1","img7":"1","img8":"1","img9":"1","img_single":0,"img_title1":"","img_title10":"","img_title11":"","img_title12":"","img_title2":"","img_title3":"","img_title4":"","img_title5":"","img_title6":"","img_title7":"","img_title8":"","img_title9":"","img_title_single":"","index":"","index48":"","index48_d":"","index48_uv":"","index_ag":"","index_cl":"","index_co":"","index_d":"","index_ls":"","index_tr":"","index_uv":"","index_xc":"","st1":0,"st2":0,"st3":0,"st4":0,"st5":0,"st6":0,"temp1":"20℃~28℃","temp2":"20℃~26℃","temp3":"19℃~26℃","temp4":"21℃~26℃","temp5":"23℃~28℃","temp6":"22℃~27℃","tempF1":"","tempF2":"","tempF3":"","tempF4":"","tempF5":"","tempF6":"","weather1":"多云","weather2":"多云","weather3":"多云","weather4":"多云","weather5":"多云","weather6":"多云","week":"","wind1":"","wind2":"","wind3":"","wind4":"","wind5":"","wind6":""}}

public class Weather {
public WeatherInfo weatherinfo;
}
public class WeatherInfo {
public String city;
public String cityid;
public String date_y;
public String temp1;
public String weather1;
}

GsonRequest<Weather> gsonRequest = new GsonRequest<Weather>(
"http://weather.51wnl.com/weatherinfo/GetMoreWeather?cityCode=101020100&weatherType=0", Weather.class,
new Response.Listener<Weather>() {
@Override
public void onResponse(Weather weather) {
WeatherInfo weatherInfo = weather.weatherinfo;
showlog("city is " + weatherInfo.city);
showlog("cityid is " + weatherInfo.cityid);
showlog("date_y is " + weatherInfo.date_y);
showlog("temp1 is " + weatherInfo.temp1);
showlog("weather1 is " + weatherInfo.weather1);
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
showlog(error.getMessage());
}
});
mQueue.add(gsonRequest);

public class User {
private String name; 
private int age; 
}

public class GsonRequestWithAuth<T> extends Request<T> { 
private final Gson gson = new Gson(); 
private final Class<T> clazz; 
private final Listener<T> listener; 
private Map<String, String> mHeader = new HashMap<String, String>(); 
private String mBody;
/** http請(qǐng)求編碼方式 */ 
private static final String PROTOCOL_CHARSET = "utf-8"; 
/** 設(shè)置訪問(wèn)自己服務(wù)器時(shí)必須傳遞的參數(shù)，密鑰等 */ 
static 
{ 
mHeader.put("APP-Key", "Key"); 
mHeader.put("APP-Secret", "Secret"); 
} 
/** 
* @param url 
* @param clazz 我們最終的轉(zhuǎn)化類(lèi)型 
* @param listener 
* @param appendHeader 附加頭數(shù)據(jù) 
* @param body 請(qǐng)求附帶消息體 
* @param errorListener 
*/ 
public GsonRequestWithAuth(String url, Class<T> clazz, Listener<T> listener, Map<String, String> appendHeader, String body, ErrorListener errorListener) { 
super(Method.POST, url, errorListener); 
this.clazz = clazz; 
this.listener = listener;
mHeader.putAll(appendHeader); 
mBody = body; 
} 
@Override 
public Map<String, String> getHeaders() throws AuthFailureError { 
// 默認(rèn)返回 return Collections.emptyMap(); 
return mHeader;
} 
@Override 
public byte[] getBody() {
try { 
return mBody == null ? null : mBody.getBytes(PROTOCOL_CHARSET); 
} catch (UnsupportedEncodingException uee) { 
VolleyLog.wtf("Unsupported Encoding while trying to get the bytes of %s using %s", mUserName, PROTOCOL_CHARSET); 
return null; 
} 
}
@Override 
protected void deliverResponse(T response) { 
listener.onResponse(response); 
} 
@Override 
protected Response<T> parseNetworkResponse(NetworkResponse response) { 
try 
{ 
/** 得到返回的數(shù)據(jù) */ 
String jsonStr = new String(response.data, HttpHeaderParser.parseCharset(response.headers)); 
/** 轉(zhuǎn)化成對(duì)象 */ 
return Response.success(gson.fromJson(jsonStr, clazz), HttpHeaderParser.parseCacheHeaders(response)); 
} catch (UnsupportedEncodingException e) 
{ 
return Response.error(new ParseError(e)); 
} catch (JsonSyntaxException e) 
{ 
return Response.error(new ParseError(e)); 
} 
} 
}

public class TestServlet extends HttpServlet { 
public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { 
this.doPost(request, response); 
} 
public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { 
request.setCharacterEncoding("utf-8"); 
/**獲取APP-Key和APP-Secret */ 
String appKey = request.getHeader("APP-Key"); 
String appSecret = request.getHeader("APP-Secret"); 
/**獲取用戶(hù)名、密碼 */ 
String username = request.getHeader("username"); 
String password = request.getHeader("password"); 
/**獲取消息體 */
int size = request.getContentLength();
InputStream is = request.getInputStream();
byte[] reqBodyBytes = readBytes(is, size);
String body = new String(reqBodyBytes);
if ("admin".equals(username) && "123".equals(password) && "getUserInfo".equals(body)) { 
response.setContentType("text/plain;charset=utf-8"); 
PrintWriter out = response.getWriter(); 
out.print("{\"name\":\"Watson\",\"age\":28}"); 
out.flush(); 
} 
} 
}

Map<String, String> appendHeader = new HashMap<String, String>(); 
appendHeader.put("username", "admin"); 
appendHeader.put("password", "123");
String url = "http://172.27.35.1:8080/webTest/TestServlet"; 
GsonRequestWithAuth<User> userRequest = new GsonRequestWithAuth<User>(url, User.class, new Listener<User>() { 
@Override 
public void onResponse(User response) 
{ 
Log.e("TAG", response.toString()); 
} 
}, appendHeader, "getUserInfo", null); 
mQueue.add(userRequest);

response.setContentType("text/plain;charset=utf-8");

public class CharsetStringRequest extends StringRequest {
public CharsetStringRequest(String url, Listener<String> listener, ErrorListener errorListener) {
super(url, listener, errorListener);
}
public CharsetStringRequest(int method, String url, Listener<String> listener, ErrorListener errorListener) {
super(method, url, listener, errorListener);
}
@Override
protected Response<String> parseNetworkResponse(NetworkResponse response) {
String str = null;
try {
str = new String(response.data,"utf-8"); //在此處強(qiáng)制utf-8編碼
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return Response.success(str, HttpHeaderParser.parseCacheHeaders(response));
}
}

CharsetStringRequest stringRequest = new CharsetStringRequest("http://www.weather.com.cn/data/sk/101010100.html",
new Response.Listener<String>() {
@Override
public void onResponse(String response) {
showlog(response);
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
showlog(error.getMessage());
}
});
mQueue.add(userRequest);

public static RequestQueue newRequestQueue(Context context) { 
return newRequestQueue(context, null); 
} 
public static RequestQueue newRequestQueue(Context context, HttpStack stack) { 
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) { 
} 
//如果stack是等于null的，則去創(chuàng)建一個(gè)HttpStack對(duì)象,手機(jī)系統(tǒng)版本號(hào)是大于9的，則創(chuàng)建一個(gè)HurlStack的實(shí)例，否則就創(chuàng)建一個(gè)HttpClientStack的實(shí)例,HurlStack的內(nèi)部就是使用HttpURLConnection進(jìn)行網(wǎng)絡(luò)通訊的，而HttpClientStack的內(nèi)部則是使用HttpClient進(jìn)行網(wǎng)絡(luò)通訊的
if (stack == null) { 
if (Build.VERSION.SDK_INT >= 9) { 
stack = new HurlStack(); 
} else { 
stack = new HttpClientStack(AndroidHttpClient.newInstance(userAgent)); 
} 
} 
//創(chuàng)建了一個(gè)Network對(duì)象，它是用于根據(jù)傳入的HttpStack對(duì)象來(lái)處理網(wǎng)絡(luò)請(qǐng)求的
Network network = new BasicNetwork(stack); 
RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network); 
queue.start(); 
return queue; 
}

public void start() { 
stop(); // Make sure any currently running dispatchers are stopped. 
//先是創(chuàng)建了一個(gè)CacheDispatcher的實(shí)例，然后調(diào)用了它的start()方法
mCacheDispatcher = new CacheDispatcher(mCacheQueue, mNetworkQueue, mCache, mDelivery); 
mCacheDispatcher.start(); 
//for循環(huán)創(chuàng)建NetworkDispatcher的實(shí)例，并分別調(diào)用它們的start()方法 
for (int i = 0; i < mDispatchers.length; i++) { 
NetworkDispatcher networkDispatcher = new NetworkDispatcher(mNetworkQueue, mNetwork, mCache, mDelivery); 
mDispatchers[i] = networkDispatcher; 
networkDispatcher.start(); 
} 
}

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"); 
//判斷當(dāng)前的請(qǐng)求是否可以緩存，如果不能緩存則直接將這條請(qǐng)求加入網(wǎng)絡(luò)請(qǐng)求隊(duì)列
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 { 
//當(dāng)前的請(qǐng)求可以緩存的話則將這條請(qǐng)求加入緩存隊(duì)列
mWaitingRequests.put(cacheKey, null); 
mCacheQueue.add(request); 
} 
return request; 
} 
}

public class CacheDispatcher extends Thread { 
…… 
@Override 
public void run() { 
if (DEBUG) VolleyLog.v("start new dispatcher"); 
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND); 
// Make a blocking call to initialize the cache. 
mCache.initialize(); 
while (true) { 
try { 
// Get a request from the cache triage queue, blocking until 
// at least one is available. 
final Request<?> request = mCacheQueue.take(); 
request.addMarker("cache-queue-take"); 
// If the request has been canceled, don't bother dispatching it. 
if (request.isCanceled()) { 
request.finish("cache-discard-canceled"); 
continue; 
} 
//嘗試從緩存當(dāng)中取出響應(yīng)結(jié)果 
Cache.Entry entry = mCache.get(request.getCacheKey()); 
if (entry == null) { 
request.addMarker("cache-miss"); 
// 如何為空的話則把這條請(qǐng)求加入到網(wǎng)絡(luò)請(qǐng)求隊(duì)列中
mNetworkQueue.put(request); 
continue; 
} 
// 如果不為空的話再判斷該緩存是否已過(guò)期，如果已經(jīng)過(guò)期了則同樣把這條請(qǐng)求加入到網(wǎng)絡(luò)請(qǐng)求隊(duì)列中
if (entry.isExpired()) { 
request.addMarker("cache-hit-expired"); 
request.setCacheEntry(entry); 
mNetworkQueue.put(request); 
continue; 
} 
//沒(méi)有過(guò)期就認(rèn)為不需要重發(fā)網(wǎng)絡(luò)請(qǐng)求，直接使用緩存中的數(shù)據(jù)即可 
request.addMarker("cache-hit"); 
//對(duì)數(shù)據(jù)進(jìn)行解析 
Response<?> response = request.parseNetworkResponse( 
new NetworkResponse(entry.data, entry.responseHeaders)); 
request.addMarker("cache-hit-parsed"); 
if (!entry.refreshNeeded()) { 
// Completely unexpired cache hit. Just deliver the response. 
mDelivery.postResponse(request, response); 
} else { 
// Soft-expired cache hit. We can deliver the cached response, 
// but we need to also send the request to the network for 
// refreshing. 
request.addMarker("cache-hit-refresh-needed"); 
request.setCacheEntry(entry); 
// Mark the response as intermediate. 
response.intermediate = true; 
// Post the intermediate response back to the user and have 
// the delivery then forward the request along to the network. 
mDelivery.postResponse(request, response, new Runnable() { 
@Override 
public void run() { 
try { 
mNetworkQueue.put(request); 
} catch (InterruptedException e) { 
// Not much we can do about this. 
} 
} 
}); 
} 
} catch (InterruptedException e) { 
// We may have been interrupted because it was time to quit. 
if (mQuit) { 
return; 
} 
continue; 
} 
} 
} 
}

public class NetworkDispatcher extends Thread { 
…… 
@Override 
public void run() { 
Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND); 
Request<?> request; 
while (true) { 
try { 
// Take a request from the queue. 
request = mQueue.take(); 
} catch (InterruptedException e) { 
// We may have been interrupted because it was time to quit. 
if (mQuit) { 
return; 
} 
continue; 
} 
try { 
request.addMarker("network-queue-take"); 
// If the request was cancelled already, do not perform the 
// network request. 
if (request.isCanceled()) { 
request.finish("network-discard-cancelled"); 
continue; 
} 
addTrafficStatsTag(request); 
//調(diào)用Network的performRequest()方法來(lái)去發(fā)送網(wǎng)絡(luò)請(qǐng)求 
NetworkResponse networkResponse = mNetwork.performRequest(request); 
request.addMarker("network-http-complete"); 
// If the server returned 304 AND we delivered a response already, 
// we're done -- don't deliver a second identical response. 
if (networkResponse.notModified && request.hasHadResponseDelivered()) { 
request.finish("not-modified"); 
continue; 
} 
// Parse the response here on the worker thread. 
Response<?> response = request.parseNetworkResponse(networkResponse); 
request.addMarker("network-parse-complete"); 
// Write to cache if applicable. 
// TODO: Only update cache metadata instead of entire record for 304s. 
if (request.shouldCache() && response.cacheEntry != null) { 
mCache.put(request.getCacheKey(), response.cacheEntry); 
request.addMarker("network-cache-written"); 
} 
// Post the response back. 
request.markDelivered(); 
mDelivery.postResponse(request, response); 
} catch (VolleyError volleyError) { 
parseAndDeliverNetworkError(request, volleyError); 
} catch (Exception e) { 
VolleyLog.e(e, "Unhandled exception %s", e.toString()); 
mDelivery.postError(request, new VolleyError(e)); 
} 
} 
} 
}

public class BasicNetwork implements Network { 
…… 
@Override 
public NetworkResponse performRequest(Request<?> request) throws VolleyError { 
long requestStart = SystemClock.elapsedRealtime(); 
while (true) { 
HttpResponse httpResponse = null; 
byte[] responseContents = null; 
Map<String, String> responseHeaders = new HashMap<String, String>(); 
try { 
// Gather headers. 
Map<String, String> headers = new HashMap<String, String>(); 
addCacheHeaders(headers, request.getCacheEntry()); 
//調(diào)用了HttpStack的performRequest()方法，這里的HttpStack就是在一開(kāi)始調(diào)用newRequestQueue()方法是創(chuàng)建的實(shí)例，默認(rèn)情況下如果系統(tǒng)版本號(hào)大于9就創(chuàng)建的HurlStack對(duì)象，否則創(chuàng)建HttpClientStack對(duì)象 
httpResponse = mHttpStack.performRequest(request, headers); 
StatusLine statusLine = httpResponse.getStatusLine(); 
int statusCode = statusLine.getStatusCode(); 
responseHeaders = convertHeaders(httpResponse.getAllHeaders()); 
// Handle cache validation. 
if (statusCode == HttpStatus.SC_NOT_MODIFIED) { 
//將服務(wù)器返回的數(shù)據(jù)組裝成一個(gè)NetworkResponse對(duì)象進(jìn)行返回
return new NetworkResponse(HttpStatus.SC_NOT_MODIFIED, 
request.getCacheEntry() == null ? null : request.getCacheEntry().data, 
responseHeaders, true); 
} 
// Some responses such as 204s do not have content. We must check. 
if (httpResponse.getEntity() != null) { 
responseContents = entityToBytes(httpResponse.getEntity()); 
} else { 
// Add 0 byte response as a way of honestly representing a 
// no-content request. 
responseContents = new byte[0]; 
} 
// if the request is slow, log it. 
long requestLifetime = SystemClock.elapsedRealtime() - requestStart; 
logSlowRequests(requestLifetime, request, responseContents, statusLine); 
if (statusCode < 200 || statusCode > 299) { 
throw new IOException(); 
} 
return new NetworkResponse(statusCode, responseContents, responseHeaders, false); 
} catch (Exception e) { 
…… 
} 
} 
} 
}

public void postResponse(Request<?> request, Response<?> response, Runnable runnable) { 
request.markDelivered(); 
request.addMarker("post-response"); 
mResponsePoster.execute(new ResponseDeliveryRunnable(request, response, runnable)); 
}

private class ResponseDeliveryRunnable implements Runnable { 
private final Request mRequest; 
private final Response mResponse; 
private final Runnable mRunnable; 
public ResponseDeliveryRunnable(Request request, Response response, Runnable runnable) { 
mRequest = request; 
mResponse = response; 
mRunnable = runnable; 
} 
@SuppressWarnings("unchecked") 
@Override 
public void run() { 
// If this request has canceled, finish it and don't deliver. 
if (mRequest.isCanceled()) { 
mRequest.finish("canceled-at-delivery"); 
return; 
} 
// Deliver a normal response or error, depending. 
if (mResponse.isSuccess()) { 
mRequest.deliverResponse(mResponse.result); 
} else { 
mRequest.deliverError(mResponse.error); 
} 
// If this is an intermediate response, add a marker, otherwise we're done 
// and the request can be finished. 
if (mResponse.intermediate) { 
mRequest.addMarker("intermediate-response"); 
} else { 
mRequest.finish("done"); 
} 
// If we have been provided a post-delivery runnable, run it. 
if (mRunnable != null) { 
mRunnable.run(); 
} 
} 
}