简单理解网络框架

有时候看网络框架的源码会看不懂，其实只要我们抓住主体的脉络去看的话， 就容易的多了 ，关键不是怎么写代码，而是思路。


network.png

思路

  1. 用户（也就是Activity/Service）发送网络请求，框架负责去处理请求，然后给用户返回来 请求的数据就OK。
  2. 首先网络请求是需要在子线程里的，请求有可能需要很多条，所以需要线程池，需要请求队列。这里举一个例子比较好理解：我（用户1⃣️）中午去餐厅（2⃣️）吃饭，饭菜比较好，所以有很多人去吃饭，餐厅里面的食堂面积有限，所以有很多人需要去排队（3⃣️），里面的人吃完了，外面的人才可以进来，但是当里面的人吃完的时候需要有一个人（服务员 也可以理解成coreThead）去通知外面的人进来（线程调度）。首先我们需要完成的就是“餐厅”那一部分的设计。

具体实现

1.创建一个 ThreadPoolManager.java 相当于上图的餐厅 餐厅外面有等待进来的人（LinkedBlockingQueue），里面有负责通知调度的服务员（coreThread），有餐厅食堂（ThreadPoolManager）

public class ThreadPoolManager {

    private static ThreadPoolManager mThreadPoolManager = new ThreadPoolManager();
    //创建等待队列
    private LinkedBlockingQueue<Runnable> mLinkedBlockingQueue = new LinkedBlockingQueue<>();

    public static ThreadPoolManager getThreadPoolManagerInstance() {
        return mThreadPoolManager;
    }
    //添加线程到请求队列里
    public void addTask(Runnable runnable) {
        if (runnable != null) {
            try {
                mLinkedBlockingQueue.put(runnable);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    //创建线程池
    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);
    }

    //核心线程 相当于服务员， 通过一个死循环 不断的从请求队列里取出来请求数据，扔到线程池里面
    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⃣️联系起来的接口

public interface IHttpRequest {
    void setUrl(String url); // 传过来的url
    void setData(byte[] data); //传过来的请求数据
    void setCallBackListener(CallBackListener listener);//回调函数，回调请求结果的
    void execute();//执行网络操作
}

public interface CallBackListener {
    void onSuccess(String result);

    void Failure();
}

这个接口这是一个例子，主要是为了说明下这个思想。
3.有了接口 那就的实现接口里的具体方法了，这里实现一个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() {
     
        //执行网络请求；
        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();
                     //回调成功的结果 这里回调字符串 也可以在封装一层
                    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();
            }
        }

    }
}
  1. 把请求和响应组合在一起 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.把任务添加到请求队列

public class HttpUtil {
    public static void sendHttpRequest(String url, CallBackListener callBackListener) {
        HttpTask httpTask = new HttpTask(url, callBackListener);
        ThreadPoolManager.getThreadPoolManagerInstance().addTask(httpTask);
    }
}
  1. 这样一个网络框架就完成了 当然这只是为了理清楚大概的思路 有了思路才会有完美的实现。
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";//这里自己的本地服务器，因为这里的请求是
      //http 在高版本的Android 里默认是不允许明文传递数据的 需要在MainMainfest里的application
      //标签加上“android:usesCleartextTraffic="true"”
        HttpUtil.sendHttpRequest(url, new CallBackListener() {
            @Override
            public void onSuccess(String result) {
                Log.d("result: ", "onSuccess: " + result);
            }

            @Override
            public void Failure() {

            }
        });
    }
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念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