有時(shí)候看網(wǎng)絡(luò)框架的源碼會看不懂，其實(shí)只要我們抓住主體的脈絡(luò)去看的話， 就容易的多了 ，關(guān)鍵不是怎么寫代碼，而是思路。
network.png
思路
- 用戶（也就是Activity/Service）發(fā)送網(wǎng)絡(luò)請求，框架負(fù)責(zé)去處理請求，然后給用戶返回來 請求的數(shù)據(jù)就OK。
- 首先網(wǎng)絡(luò)請求是需要在子線程里的，請求有可能需要很多條，所以需要線程池，需要請求隊(duì)列。這里舉一個(gè)例子比較好理解：我（用戶1??）中午去餐廳（2??）吃飯，飯菜比較好，所以有很多人去吃飯，餐廳里面的食堂面積有限，所以有很多人需要去排隊(duì)（3??），里面的人吃完了，外面的人才可以進(jìn)來，但是當(dāng)里面的人吃完的時(shí)候需要有一個(gè)人（服務(wù)員 也可以理解成coreThead）去通知外面的人進(jìn)來（線程調(diào)度）。首先我們需要完成的就是“餐廳”那一部分的設(shè)計(jì)。
具體實(shí)現(xiàn)
1.創(chuàng)建一個(gè) ThreadPoolManager.java 相當(dāng)于上圖的餐廳 餐廳外面有等待進(jìn)來的人（LinkedBlockingQueue），里面有負(fù)責(zé)通知調(diào)度的服務(wù)員（coreThread），有餐廳食堂（ThreadPoolManager）
public class ThreadPoolManager {
private static ThreadPoolManager mThreadPoolManager = new ThreadPoolManager();
//創(chuàng)建等待隊(duì)列
private LinkedBlockingQueue<Runnable> mLinkedBlockingQueue = new LinkedBlockingQueue<>();
public static ThreadPoolManager getThreadPoolManagerInstance() {
return mThreadPoolManager;
}
//添加線程到請求隊(duì)列里
public void addTask(Runnable runnable) {
if (runnable != null) {
try {
mLinkedBlockingQueue.put(runnable);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
//創(chuàng)建線程池
private ThreadPoolExecutor mThreadPoolExecutor;
private ThreadPoolManager() {
mThreadPoolExecutor = new ThreadPoolExecutor(3, 10, 10,
TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(4), new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
addTask(r);
}
});
mThreadPoolExecutor.execute(coreThread);
}
//核心線程 相當(dāng)于服務(wù)員， 通過一個(gè)死循環(huán) 不斷的從請求隊(duì)列里取出來請求數(shù)據(jù)，扔到線程池里面
private Runnable coreThread = new Runnable() {
Runnable runnable = null;
@Override
public void run() {
while (true) {
try {
runnable = mLinkedBlockingQueue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
mThreadPoolExecutor.execute(runnable);
}
}
};
}
2.然后定義請求的接口 也就是1??和2??聯(lián)系起來的接口
public interface IHttpRequest {
void setUrl(String url); // 傳過來的url
void setData(byte[] data); //傳過來的請求數(shù)據(jù)
void setCallBackListener(CallBackListener listener);//回調(diào)函數(shù)，回調(diào)請求結(jié)果的
void execute();//執(zhí)行網(wǎng)絡(luò)操作
}
public interface CallBackListener {
void onSuccess(String result);
void Failure();
}
這個(gè)接口這是一個(gè)例子，主要是為了說明下這個(gè)思想。
3.有了接口 那就的實(shí)現(xiàn)接口里的具體方法了，這里實(shí)現(xiàn)一個(gè)StringHttpRequest.java
public class StringHttpRequest implements IHttpRequest {
private String mUrl;
private byte[] mData;
private CallBackListener mListener;
@Override
public void setUrl(String url) {
mUrl = url;
}
@Override
public void setData(byte[] data) {
mData = data;
}
@Override
public void setCallBackListener(CallBackListener listener) {
mListener = listener;
}
@Override
public void execute() {
//執(zhí)行網(wǎng)絡(luò)請求；
HttpURLConnection connection = null;
InputStream inputStream = null;
String result = null;
try {
URL url = new URL(mUrl);
connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
// Timeout for reading InputStream arbitrarily set to 3000ms.
connection.setReadTimeout(3000);
// Timeout for connection.connect() arbitrarily set to 3000ms.
connection.setConnectTimeout(3000);
// connection.setDoInput(true);
connection.connect();
int responseCode = connection.getResponseCode();
if (responseCode != HttpURLConnection.HTTP_OK) {
//訪問失敗
mListener.Failure();
} else {
inputStream = connection.getInputStream();
if (inputStream != null) {
//Converts Stream to String
StringBuilder sb = new StringBuilder();
String line;
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
while ((line = bufferedReader.readLine()) != null) {
sb.append(line);
}
result = sb.toString();
//回調(diào)成功的結(jié)果 這里回調(diào)字符串 也可以在封裝一層
mListener.onSuccess(result);
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (connection != null) {
connection.disconnect();
}
}
}
}
- 把請求和響應(yīng)組合在一起 HttpTask.java
public class HttpTask implements Runnable {
private StringHttpRequest mStringHttpRequest ;
public HttpTask(String url, CallBackListener callBackListener) {
mStringHttpRequest =new StringHttpRequest();
mStringHttpRequest.setUrl(url);
mStringHttpRequest.setCallBackListener(callBackListener);
}
@Override
public void run() {
mStringHttpRequest.execute();
}
}
5.把任務(wù)添加到請求隊(duì)列
public class HttpUtil {
public static void sendHttpRequest(String url, CallBackListener callBackListener) {
HttpTask httpTask = new HttpTask(url, callBackListener);
ThreadPoolManager.getThreadPoolManagerInstance().addTask(httpTask);
}
}
- 這樣一個(gè)網(wǎng)絡(luò)框架就完成了 當(dāng)然這只是為了理清楚大概的思路 有了思路才會有完美的實(shí)現(xiàn)。
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
String url = "http://10.0.2.2:8000";//這里自己的本地服務(wù)器，因?yàn)檫@里的請求是
//http 在高版本的Android 里默認(rèn)是不允許明文傳遞數(shù)據(jù)的 需要在MainMainfest里的application
//標(biāo)簽加上“android:usesCleartextTraffic="true"”
HttpUtil.sendHttpRequest(url, new CallBackListener() {
@Override
public void onSuccess(String result) {
Log.d("result: ", "onSuccess: " + result);
}
@Override
public void Failure() {
}
});
}
}
