Android Retrofit+RXJava的使用

Retrofit+RXJava

RetrofitRXJava分别是什么就不一个个的介绍了,都是我们现在常用的最受欢迎的.当然,现在常用的也是将Retrofit与RXJava结合起来,下面就是我将两者最简单的结合

首先第一步我们添加依赖和添加网络权限
 //RXJava
    implementation 'io.reactivex.rxjava2:rxjava:2.2.6'
    implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'
 //Retrofit
    implementation 'com.squareup.retrofit2:retrofit:2.4.0'
    //Gson converter
    implementation 'com.squareup.retrofit2:converter-gson:2.4.0'
    //RxJava2 Adapter
    implementation "com.squareup.retrofit2:adapter-rxjava2:2.3.0"
    //http
    implementation 'com.squareup.okhttp3:okhttp:3.4.1'
    implementation 'com.squareup.okhttp3:logging-interceptor:3.9.1'
//清单文件内添加网络权限
    <uses-permission android:name="android.permission.INTERNET"/>
第二步创建一个实体类,用来存放数据
package com.example.retrofitdemo;

import java.util.List;

public class FoodBean {

    /**
     * ret : 1
     * data : [{"id":"8289","title":"油焖大虾","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/9/8289.jpg","collect_num":"1668","food_str":"大虾 葱 生姜 植物油 料酒","num":1668},{"id":"2127","title":"四川回锅肉","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2127.jpg","collect_num":"1590","food_str":"猪肉 青蒜 青椒 红椒 姜片","num":1590},{"id":"30630","title":"超简单芒果布丁","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/31/30630.jpg","collect_num":"1542","food_str":"QQ糖 牛奶 芒果","num":1542},{"id":"9073","title":"家常红烧鱼","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/10/9073.jpg","collect_num":"1425","food_str":"鲜鱼 姜 葱 蒜 花椒","num":1425},{"id":"10097","title":"家常煎豆腐","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10097.jpg","collect_num":"1417","food_str":"豆腐 新鲜红椒 青椒 葱花 油","num":1417},{"id":"10509","title":"水煮肉片","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10509.jpg","collect_num":"1340","food_str":"瘦猪肉 生菜 豆瓣酱 干辣椒 花椒","num":1340},{"id":"46968","title":"红糖苹果银耳汤","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/47/46968.jpg","collect_num":"1252","food_str":"银耳 苹果 红糖","num":1252},{"id":"10191","title":"麻婆豆腐","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10191.jpg","collect_num":"1220","food_str":"豆腐 肉末 生抽 白糖 芝麻油","num":1220},{"id":"2372","title":"皮蛋瘦肉粥","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2372.jpg","collect_num":"1151","food_str":"大米 皮蛋 猪肉 油条 香葱","num":1151},{"id":"2166","title":"蚂蚁上树","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2166.jpg","collect_num":"1144","food_str":"红薯粉 肉 姜 蒜 花椒","num":1144},{"id":"2262","title":"糖醋肉","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2262.jpg","collect_num":"1077","food_str":"猪肉 红椒 黄椒 洋葱 蛋清","num":1077},{"id":"9971","title":"鱼香豆腐","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/10/9971.jpg","collect_num":"1009","food_str":"豆腐 木耳 胡萝卜 香葱 番茄酱","num":1009},{"id":"10172","title":"干煸四季豆","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10172.jpg","collect_num":"991","food_str":"四季豆 干辣椒 蒜头 酱油 糖","num":991},{"id":"2685","title":"胡萝卜肉末蒸蛋","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2685.jpg","collect_num":"926","food_str":"胡萝卜 肉 蛋 生抽 盐","num":926},{"id":"9972","title":"虎皮青椒","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/10/9972.jpg","collect_num":"891","food_str":"青辣椒 大蒜 香醋 白糖 生抽","num":891},{"id":"10437","title":"叉烧排骨","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10437.jpg","collect_num":"802","food_str":"排骨 李锦记叉烧酱 植物油 清水 油菜","num":802},{"id":"2892","title":"\u201c五行\u201d彩蔬汤","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2892.jpg","collect_num":"760","food_str":"黑木耳 玉米 牛蒡 胡萝卜 西兰花","num":760},{"id":"2348","title":"麻辣肉丝面","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/3/2348.jpg","collect_num":"758","food_str":"面条 肉丝 淀粉 酱油 辣椒","num":758},{"id":"33783","title":"美人豆浆","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/34/33783.jpg","collect_num":"757","food_str":"黄豆 红豆 绿豆 黑豆 黑米","num":757},{"id":"10044","title":"土豆炖翅根","pic":"http://www.qubaobei.com/ios/cf/uploadfile/132/11/10044.jpg","collect_num":"755","food_str":"土豆 翅根 葱 姜 料酒","num":755}]
     */

    private int ret;
    private List<DataBean> data;

    public int getRet() {
        return ret;
    }

    public void setRet(int ret) {
        this.ret = ret;
    }

    public List<DataBean> getData() {
        return data;
    }

    public void setData(List<DataBean> data) {
        this.data = data;
    }

    public static class DataBean {
        /**
         * id : 8289
         * title : 油焖大虾
         * pic : http://www.qubaobei.com/ios/cf/uploadfile/132/9/8289.jpg
         * collect_num : 1668
         * food_str : 大虾 葱 生姜 植物油 料酒
         * num : 1668
         */

        private String id;
        private String title;
        private String pic;
        private String collect_num;
        private String food_str;
        private int num;

        public String getId() {
            return id;
        }

        public void setId(String id) {
            this.id = id;
        }

        public String getTitle() {
            return title;
        }

        public void setTitle(String title) {
            this.title = title;
        }

        public String getPic() {
            return pic;
        }

        public void setPic(String pic) {
            this.pic = pic;
        }

        public String getCollect_num() {
            return collect_num;
        }

        public void setCollect_num(String collect_num) {
            this.collect_num = collect_num;
        }

        public String getFood_str() {
            return food_str;
        }

        public void setFood_str(String food_str) {
            this.food_str = food_str;
        }

        public int getNum() {
            return num;
        }

        public void setNum(int num) {
            this.num = num;
        }

        @Override
        public String toString() {
            return "DataBean{" +
                    "id='" + id + '\'' +
                    ", title='" + title + '\'' +
                    ", pic='" + pic + '\'' +
                    ", collect_num='" + collect_num + '\'' +
                    ", food_str='" + food_str + '\'' +
                    ", num=" + num +
                    '}';
        }
    }

}

第三步创建一个Retrofit用于来网络请求的接口(注意:导入包的时候别错了)
  • @GET注解代表的是请求方法,使用GET请求网络,里面所填写的参数代表完整Url的后半段
  • Observable为被观察者对象,泛型就是我们所要的数据的实体类
  • getFood()为用来返回Observable类型的参数,方法内的参数为Url内可改变的一些数,我们到时候可以根据自己需要来将数码传进来
  • @Query内的参数就是Url上的可改变数的名字,如Url上有页码 page = 1 那么我们就定义 @Query(“page”)

import io.reactivex.Observable;
import retrofit2.http.GET;
import retrofit2.http.Query;

//http://www.qubaobei.com/ios/cf/dish_list.php?stage_id=1&limit=20&page=1
public interface RetrofitJson {
  @GET("ios/cf/dish_list.php")
  Observable<FoodBean> getFood(@Query("stage_id")String stage, @Query("limit")String limit, @Query("page")String page);

} 
第四步就是回到我们需要的地方了,我是在Activity内,自己定义一个方法然后在需求里调用
 private void RxRetrofit() {
 		//创建Retrofit的Builder对象
        Retrofit retrofit = new Retrofit.Builder()
        //设置Url的前部分
       .baseUrl("http://www.qubaobei.com/")
       //设置Gson解析器
       .addConverterFactory(GsonConverterFactory.create())  
       //设置RxJava适配器 
       .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
         .build();//创建对象
		//使用Retrofit动态代理获取之前定义的接口	
        RetrofitJson retrofitJson = retrofit.create(RetrofitJson.class);
        //调用接口内的方法,传入自己Url上所需的
        retrofitJson.getFood("1","10","1")
        //设置被观察者在子线程中执行
        .subscribeOn(Schedulers.io())
        //设置观察者在主线程中执行UI
        .observeOn(AndroidSchedulers.mainThread())
        //设置观察者,这里直接在里面创建一个并重写方法
        .subscribe(new Observer<FoodBean>() {
                    @Override
                    public void onSubscribe(Disposable d) {
					//此方法为创建的时候调用
                    }

                    @Override
                    public void onNext(FoodBean foodBean) {
                    //此方法为接收到onNext时候调用
                    //此方法已经帮我们把数据传了过来 这里为foodBean,根据需求使用就可以了
                        String s = foodBean.getData().toString();
                        Toast.makeText(MainActivity.this, ""+s, Toast.LENGTH_SHORT).show();
                    }

                    @Override
                    public void one rror(Throwable e) {
					//此方法在错误的时候调用
                    }

                    @Override
                    public void onComplete() {
					//此方法在结束的时候调用
                    }
                });


    }
以上是我对两者结合简单基础的了解,想要了解更多的话上面蓝色字体为超链接,点击进入!!
上一篇:Wpa_supplicant工作流程分析之scan(从应用层到内核)(上)


下一篇:Loadrunner:脚本编写通用模板(Http协议类型)