实现主线程回调接口

Author: jiaqizho

android-SpillOver/src/frameDesign/CacheHandler.java

@@ -15,21 +15,27 @@ public class CacheHandler extends Thread {
 	private CacheJudgement mCacheJudge;
 
 	private volatile boolean quit = false;
+
+	private ResponseParse mResponseParse = null;
 
-	
+	private ResponseHandler mCallBack = null;
+
 	public CacheHandler(BlockingQueue<Request<?>> mQueue,
-			BlockingQueue<Request<?>> mNetQueue, Cache mCache) {
-		this(mQueue,mNetQueue,mCache,new CacheJudgement());
+			BlockingQueue<Request<?>> mNetQueue, Cache mCache,ResponseParse parse,ResponseHandler callBack) {
+		this(mQueue,mNetQueue,mCache,parse,new CacheJudgement(),callBack);
 	}
-
+	
 	public CacheHandler(BlockingQueue<Request<?>> mQueue, BlockingQueue<Request<?>> mNetQueue,
-			Cache mCache,CacheJudgement judge) {
+			Cache mCache,ResponseParse parse,CacheJudgement judge,ResponseHandler callBack) {
 		this.mQueue = mQueue;
 		this.mNetQueue = mNetQueue;
 		this.mCache = mCache;
 		this.mCacheJudge = judge;
+		this.mResponseParse = parse;
+		this.mCallBack = callBack;
 	}
 
+	
 	@Override
 	public void run() {
         android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_BACKGROUND);
@@ -45,18 +51,17 @@ public void run() {
 						mNetQueue.put(request);
 					}
 					if(mCacheJudge.hasTTl(entry.ttl) || mCacheJudge.hasExpired(entry.expires)){
-						//回调处理
+						String callBackdata = null;
+			        	callBackdata = mResponseParse.byteToEntity(entry.datas,entry.headers);
+			        	mCallBack.callBack(request, callBackdata);
 						continue;
 					} 
-						
 					//过期了之后丢放etag 和  Last-Modified
 					if(mCacheJudge.usefulEtag(entry.etag)) {
 						request.setEtag(entry.etag);
 					} else if(mCacheJudge.usefulIMS(entry.iMS)){
 						request.setiMS(entry.iMS);
 					} 
-					
-					
 				} catch (IOException e) {
 				} finally{
 					if(quit){

android-SpillOver/src/frameDesign/NetworkHandler.java

@@ -10,7 +10,7 @@
 import org.apache.http.StatusLine;
 import org.apache.http.message.BasicHttpResponse;
 
-import android.util.Log;
+import android.os.Looper;
 import file.Cache;
 import file.IndexPoolOverflowException;
 
@@ -26,13 +26,19 @@ public class NetworkHandler extends Thread{
 
 	private static final int DEFAULT_POOL_SIZE = 4096;
 
-	public NetworkHandler(BlockingQueue<Request<?>> mQueue, Cache mCache, HttpHeap mHttpHeap , ResponseParse parse) {
+	private ResponseHandler mCallBack = null;
+
+	public NetworkHandler(BlockingQueue<Request<?>> mQueue, Cache mCache,
+			HttpHeap mHttpHeap , ResponseParse parse , ResponseHandler response) {
 		this.mQueue = mQueue;
 		this.mCache = mCache;
 		this.mHttpHeap = mHttpHeap;
 		this.mResponseParse = parse;
+		this.mCallBack = response;
 	}
 
+	
+	
 	@Override
 	public void run() {
 
@@ -41,19 +47,22 @@ public void run() {
 		while(true){
 			try {
 				Request<?> request = mQueue.take();
+				
+				String callBackdata = null;
 				BasicHttpResponse response = mHttpHeap.handlerRequest(request);
 				Map<String,String> responseHeaders = convertHeaders(response.getAllHeaders());
 		        StatusLine statusLine = response.getStatusLine();
 		        int statusCode = statusLine.getStatusCode();
+		        
+				//304²Ù×÷;
 		        if(statusCode == HttpStatus.SC_NOT_MODIFIED){
-		        	
-		        	
-					//304操作; 
+		        	Cache.Entry entry = mCache.get(request.getUrl());
+		        	callBackdata = mResponseParse.byteToEntity(entry.datas,responseHeaders);
+		        	mCallBack.callBack(request, callBackdata);
+		        	continue;
 				}
 
-		        /**
-		         * 设好缓存
-		         */
+		        // ÉèºÃ»º´æ 
 				if(request.shouldCache()){
 					Cache.Entry entry = new Cache.Entry();
 					long ttl = mResponseParse.parseTtl(responseHeaders.get("Cache-Control"));
@@ -65,16 +74,12 @@ public void run() {
 					entry.iMS = responseHeaders.get("Last-Modified");
 					entry.etag = responseHeaders.get("Etag");
 					entry.headers = responseHeaders;
-					entry.datas = mResponseParse.entityToBytes(response.getEntity(), new ByteArrayPool(DEFAULT_POOL_SIZE));
+					byte[] bd = mResponseParse.entityToBytes(response.getEntity(), new ByteArrayPool(DEFAULT_POOL_SIZE));
+					entry.datas = bd;
+					callBackdata = mResponseParse.byteToEntity(bd,responseHeaders);
 					mCache.put(request.getUrl(), entry);
 				}
-				
-				
-				
-				/**
-				 * 处理完缓存之后就进行reponse回调操作
-				 */
-				
+				mCallBack.callBack(request, callBackdata);
 			} catch (IOException e) {
 				e.printStackTrace();
 			} catch (InterruptedException e) {
@@ -94,4 +99,6 @@ private static Map<String, String> convertHeaders(Header[] headers) {
         }
         return result;
     }
+    
+
 }

android-SpillOver/src/frameDesign/Request.java

@@ -13,17 +13,17 @@
  */
 public abstract class Request <T> implements Comparable<Request<T>> {
 
-	public ResponseListener<?> listener;
+	public ResponseListener<T> listener;
 
 	private String mUrl;
 
-	Request(String url ,ResponseListener<?> listener){
+	Request(String url ,ResponseListener<T> listener){
 		this.listener = listener;
 		this.mUrl = url;
 	}
 
 	interface ResponseListener<T>{
-		public void callBack(T arg0);
+		public void callBack(String responseData);
 	}
 
 	public Method method = Method.POST; 

android-SpillOver/src/frameDesign/RequestHandler.java

@@ -5,8 +5,8 @@
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.PriorityBlockingQueue;
 
+import android.os.Looper;
 import android.util.Log;
-
 import file.Cache;
 
 public class RequestHandler implements Handler {
@@ -25,17 +25,20 @@ public class RequestHandler implements Handler {
 
 	private ResponseParse parse;
 
+	private ResponseHandler mCallBack = null;
+	
 	public RequestHandler(HttpHeap heap, Cache cache) {
-		this(heap,cache,new HttpResponseParse());
+		this(heap,cache,new HttpResponseParse(),new CallBackResponse(new android.os.Handler(Looper.getMainLooper())));
 	}
 
 
-	public RequestHandler(HttpHeap heap, Cache cache,ResponseParse parse) {
+	public RequestHandler(HttpHeap heap, Cache cache,ResponseParse parse,ResponseHandler callBack) {
 		this.mHttpHeap = heap;
 		this.mCache = cache;
 		mCacheQueue = new PriorityBlockingQueue<Request<?>>();
 		mNetQueue = new PriorityBlockingQueue<Request<?>>();
 		this.parse = parse;
+		this.mCallBack = callBack;
 	}
 
 
@@ -46,8 +49,9 @@ public void parseRequest(Request<?> request) {
 
 	@Override
 	public void init()  {
-		mCacheHandler = new CacheHandler(mCacheQueue, mNetQueue,mCache);
-		mNetworkHandler = new NetworkHandler(mNetQueue,mCache,mHttpHeap,parse);
+		
+		mCacheHandler = new CacheHandler(mCacheQueue, mNetQueue,mCache,parse,mCallBack);
+		mNetworkHandler = new NetworkHandler(mNetQueue,mCache,mHttpHeap,parse,mCallBack);
 		mCacheHandler.start();
 		mNetworkHandler.start(); 
 		mNetQueue.add(new Request<String>("http://192.168.1.104:8080/QQServer/Expires",new Request.ResponseListener<String>() {

android-SpillOver/src/test/MainActivity.java

@@ -9,6 +9,7 @@
 
 import android.app.Activity;
 import android.os.Bundle;
+import android.util.Log;
 
 public class MainActivity extends Activity{
 
@@ -17,7 +18,7 @@ protected void onCreate(Bundle savedInstanceState) {
 		super.onCreate(savedInstanceState);
 		setContentView(R.layout.mainview);
 
-		
+		Log.i("DemoLog", Thread.currentThread().toString() + "Mainaaaas");
 		new Thread(new Runnable() { 
 
 			@Override