美文网首页AndroidAndroid知识Android技术知识
Rxjava2+Retrofit2结合mvp的简单教程OkHtt

Rxjava2+Retrofit2结合mvp的简单教程OkHtt

作者: MrAllRight_Liu | 来源:发表于2017-07-31 11:26 被阅读286次

    本系列文章主要是讲如何实现网络的功能,以及结合mvp实现ui刷新,本系列只是讲解功能的实现,不涉及源码分析以及高级用法,why,因为作者也不会,无奈......

    本篇讲解内容:OkHttp3的基本使用(Retrofit是对其的包装,内部请求还是okhttp,所以我们要先了解一下okhttp)

    官方地址:http://square.github.io/okhttp/
    github地址:https://github.com/square/okhttp

    我们首先是按照官方的文档的列子来学习
    1.引用到项目 compile 'com.squareup.okhttp3:okhttp:3.8.1'
    2.copy官方代码

     /**
         * This program downloads a URL and print its contents as a string
         *这是官方get请求的代码
         * @param url
         * @return
         * @throws IOException
         */
    
        void run(String url) throws IOException {
            Request request = new Request.Builder()
                    .url(url)
                    .build();
    
            client.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    Log.d(TAG, "get response=" + response.body().string());
                }
            });
        }
    
        ;
    
        /**
         * This program posts data to a service
         *这是官方post请求
         * @param url
         * @param json
         * @return
         * @throws IOException
         */
        void post(String url, String json) throws IOException {
            RequestBody body = RequestBody.create(JSON, json);
            Request request = new Request.Builder()
                    .url(url)
                    .post(body)
                    .build();
            client.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
    
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    Log.d(TAG, "post response=" + response.body().string());
                }
            });
    
        }
    

    说明一下,官方用的请求是同步请求execute(),但是在项目中很少能用到,所以我们直接替换为enqueue()异步请求,在onResponse中就可以通过response.body().string()拿到服务器返回的结果(记得加上网络权限)。其中第一个是get请求,第二个是post请求,get请求非常简单直接请求一个url就可以了,我们重点来看看post请求,这里面多了一个String json参数,这个就是我们要上传给服务器的信息,比如用户名和密码。下面我把调用的代码传一下,你就能直观的看到怎么传递参数了

    public class MainActivity extends AppCompatActivity {
        private final String TAG = "MainActivity";
        private String GET_URL = "https://www.baidu.com/";
        public static final String POST_URL = "http://zhushou.72g.com/app/gift/gift_list/";
        private OkHttpClient client;
        /**
         * MediaType,即是Internet Media Type,互联网媒体类型;是我们在传输数据时定义的媒体类型,现在大部分数据传输都是json(application/json;)
         * 其他格式本篇不会设计,以后也不会设计,关键是我也不会
         */
        public static final MediaType JSON
                = MediaType.parse("application/json; charset=utf-8");
    
       @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
            client = new OkHttpClient();
            try {
                //GET请求
                run(GET_URL);
                //POST请求
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("page", "1");
                jsonObject.put("code", "news");
                jsonObject.put("pageSize", "20");
                jsonObject.put("parentid", "0");
                jsonObject.put("type", "1");
                post(POST_URL, jsonObject.toString());
            } catch (IOException e) {
                e.printStackTrace();
            } catch (JSONException e) {
                e.printStackTrace();
            }
        }
    }
    

    可以清晰的看到数据是通过JSONObject 一个个添加进去的然后传给服务器,好了现在我们已经学会了如何使用okhttp3了,至于添加超时时间,添加header我只贴出简单代码,具体不讲解。下篇我会讲一下https的请求的事项,毕竟现在是网络安全的时代

            //初始化okhttp的时候添加超时时间
            client = new OkHttpClient();
            File cacheDir = new File(getCacheDir(), "HttpResponseCache");
            client.setCache(new Cache(cacheDir, HTTP_CACHE_SIZE));//缓存目录
            client.setConnectTimeout(30, TimeUnit.SECONDS);//超时时间
           //创建request的时候添加header
            Request request = new Request.Builder()
                    .url(url)
                    //addheader
                    .addHeader("source", "android")
                    .addHeader("imei", DataUtils.getPreferences(DataUtils.KEY_PHONE_IMEI, ""))
                    .addHeader("token", DataUtils.getPreferences(DataUtils.KEY_TOKEN, ""))
                    .addHeader("platform", Constant.PLATFORM)
                    .post(body)
                    .build();
    

    本篇代码已经上传github:https://github.com/MrAllRight/HttpExample,可下载运行

    本篇参考:http://blog.csdn.net/ming2316780/article/details/51598063,特别感谢

    相关文章

      网友评论

        本文标题:Rxjava2+Retrofit2结合mvp的简单教程OkHtt

        本文链接:https://www.haomeiwen.com/subject/cnillxtx.html