一篇文章带你走通 OkHttp+Retrofit+Rxjava

首先说明以下为什么要把这3个东西放在一起,其实主要是想介绍 Retrofit ,当时网上很多文章上来就是各种用法,对 我们刚刚接触框架的人不太友好,所以想写这篇文章来展示一下它们之间到底有什么关联。

Retrofit 我们知道是一个现在非常流行的网络请求库,它流行的关键在于它非常好使用,对Http请求做了封装,让我们使用起来更加方便,并且还提供了基于Anotation的 Rest风格的请求方式,如果使用过SpringMVC的人就能感觉到,这两者结合起来,可以后台和客户端开发契合得更好。

OkHttp 是 Retrofit 底层使用的Http请求库,都是 Square 公司的开源产品。OkHttp 和 Android中的 ,HttpUriConneciton才是一级的产品,而Retrofit 底层使用作为Http通信的工具的就是 OkHttp。

RxJava 其实和 Retrofit 并没有什么关系,但是由于它流式编程的思想,丰富的操作符,线程的任意切换等优点广受大家的喜爱。特别是用在像做网络请求这样比较繁琐的逻辑处理中,更能显示出它的威力,所以将RxJava和Retrofit结合起来,威力无比强大。

但是我也刚刚接触,学习总结以下,所以这篇文章也只针对新手而已,大神请自行绕过。

参考网站

OkHttp官网
Okio官网
Retrofit官网

OkHttp部分

要使用OkHttp,首先需要添加它的依赖,同时OkHttp又依赖了Okio,所以需要同时添加Okio的依赖。

OkHttp依赖

maven:

<dependency>
  <groupId>com.squareup.okhttp3</groupId>
  <artifactId>okhttp</artifactId>
  <version>3.6.0</version>
</dependency>

gradle:

compile 'com.squareup.okhttp3:okhttp:3.6.0'

Okio依赖

maven:

<dependency>
    <groupId>com.squareup.okio</groupId>
    <artifactId>okio</artifactId>
    <version>1.11.0</version>
</dependency>

gradle:

compile 'com.squareup.okio:okio:1.11.0'

使用OkHttp下载图片例子

class DownloadImageThread extends Thread {
    private String url;
    private ImageView imageView;

    public DownloadImageThread(String url, ImageView imageView) {
      this.url = url;
      this.imageView = imageView;
    }

    @Override
    public void run() {
      OkHttpClient client = new OkHttpClient();
      Request request = new Request.Builder()
          .url(url)
          .build();

      try {
        Response response = client.newCall(request).execute();
        if (response.isSuccessful()) {
          final Bitmap bitmap = BitmapFactory.decodeStream(response.body().byteStream());
          runOnUiThread(new Runnable() {
            @Override
            public void run() {
              imageView.setImageBitmap(bitmap);
            }
          });
        }
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }

Retrofit部分

Retrofit依赖

Maven:

<dependency>
  <groupId>com.squareup.retrofit2</groupId>
  <artifactId>retrofit</artifactId>
  <version>2.1.0</version>
</dependency>

Gradle:

compile 'com.squareup.retrofit2:retrofit:2.1.0'

Gson依赖

compile 'com.google.code.gson:gson:2.3.1'

返回数据转换器依赖

在Retrofit中将转换器称为 Converters,它的作用就是用来添加对返回数据的转换支持。例如的是String 就需要 scalar,如果是 json,需要使用 gson 等。后面的代码中可以看到

  • Scalars (primitives, boxed, and String): com.squareup.retrofit2:converter-scalars:2.1.0
  • Gson: com.squareup.retrofit2:converter-gson:2.1.0
  • Jackson: com.squareup.retrofit2:converter-jackson:{最新版本号}
  • Moshi: com.squareup.retrofit2:converter-moshi:{最新版本号}
  • Protobuf: com.squareup.retrofit2:converter-protobuf:{最新版本号}
  • Wire: com.squareup.retrofit2:converter-wire:{最新版本号}
  • Simple XML: com.squareup.retrofit2:converter-simplexml:{最新版本号}

例子所有依赖

接下来两个例子将展示怎么使用Retrofit请求Github api的数据。

dependencies {
    //...
    compile 'com.squareup.retrofit2:converter-scalars:2.1.0'
    compile 'com.squareup.retrofit2:converter-gson:2.1.0'
    compile 'com.squareup.retrofit2:retrofit:2.1.0'
    compile 'com.google.code.gson:gson:2.3.1'
}

请求String数据例子

GitHubService.java 定义发出Http请求的接口。两个接口,一个返回String,一个返回GitModel(Github返回的Json数据的Pojo类)

public interface GitHubService {

  String BASEURL = "https://api.github.com";

  @GET("users/{user}")
  Call<String> getData(@Path("user") String user);
  
  @GET("users/{user}")
  Call<GitModel> getUserInfo(@Path("user") String user);
}

GitModel.java 注意:这里省略了 getters 和 setters,还需要 Gson 支持

public class GitModel {
  @Expose
  private String login;
  @Expose
  private Integer id;
  @SerializedName("avatar_url")
  @Expose
  private String avatarUrl;
  @SerializedName("gravatar_id")
  @Expose
  private String gravatarId;
  @Expose
  private String url;
  @SerializedName("html_url")
  @Expose
  private String htmlUrl;
  @SerializedName("followers_url")
  @Expose
  private String followersUrl;
  @SerializedName("following_url")
  @Expose
  private String followingUrl;
  @SerializedName("gists_url")
  @Expose
  private String gistsUrl;
  @SerializedName("starred_url")
  @Expose
  private String starredUrl;
  @SerializedName("subscriptions_url")
  @Expose
  private String subscriptionsUrl;
  @SerializedName("organizations_url")
  @Expose
  private String organizationsUrl;
  @SerializedName("repos_url")
  @Expose
  private String reposUrl;
  @SerializedName("events_url")
  @Expose
  private String eventsUrl;
  @SerializedName("received_events_url")
  @Expose
  private String receivedEventsUrl;
  @Expose
  private String type;
  @SerializedName("site_admin")
  @Expose
  private Boolean siteAdmin;
  @Expose
  private String name;
  @Expose
  private String company;
  @Expose
  private String blog;
  @Expose
  private String location;
  @Expose
  private String email;
  @Expose
  private Boolean hireable;
  @Expose
  private Object bio;
  @SerializedName("public_repos")
  @Expose
  private Integer publicRepos;
  @SerializedName("public_gists")
  @Expose
  private Integer publicGists;
  @Expose
  private Integer followers;
  @Expose
  private Integer following;
  @SerializedName("created_at")
  @Expose
  private String createdAt;
  @SerializedName("updated_at")
  @Expose
  private String updatedAt;

  // Getters
  // ...
  
  // Setters
  // ...
}

MainActivity.java

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl(GitHubService.BASEURL)
    //添加String支持
    .addConverterFactory(ScalarsConverterFactory.create())
    .build();
    
GitHubService service = retrofit.create(GitHubService.class);
Call<String> call = service.getData(username);//username 可以自己传入github的用户名

// 异步请求
call.enqueue(new Callback<String>() {
  @Override
  public void onResponse(Call<String> call, Response<String> response) {
    // 处理返回数据
    if (response.isSuccessful()) {
      Log.d(TAG, "onResponse: " + response.body());
    }
  }
  @Override
  public void onFailure(Call<String> call, Throwable t) {
    Log.d(TAG, "onFailure: 请求数据失败");
  }
});

请求Json数据例子

如果是Json数据,使用Gson自动解析

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl(GitHubService.BASEURL)
    // 添加Json转换器支持
    .addConverterFactory(GsonConverterFactory.create())
    .build();
GitHubService service = retrofit.create(GitHubService.class);
Call<GitModel> call = service.getUserInfo(username);//username 可填入自己Github账号用户名
call.enqueue(new Callback<GitModel>() {
  @Override
  public void onResponse(Call<GitModel> call, Response<GitModel> response) {
    if (response.isSuccessful()) {
      Log.d(TAG, "onResponse: " + response.body().getName());
    }
  }
  @Override
  public void onFailure(Call<GitModel> call, Throwable t) {
    Log.d(TAG, "onFailure: " + t.getMessage());
  }
});

使用 ResponseBody

当然,我们还可以直接使用 ResponseBody,还记得前面我们介绍过OkHttp,其实Retrofit 底层使用的 也是OkHttp,所以我们的请求完全也可以使用 OkHttp 的 Response 对象 中的 ResponseBody 对象来处理返回数据。

GitHubService.java

public interface GitHubService {
  String BASEURL = "https://api.github.com";

  //...

  @GET("users/{user}")
  Call<ResponseBody> getResponseBody(@Path("user") String user);
}

获取 ResponseBody,然后处理方法就和 OkHttp 一样了

GitHubService service = retrofit.create(GitHubService.class);
Call<ResponseBody> call = service.getResponseBody(username);
call.enqueue(new Callback<ResponseBody>() {
  @Override
  public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
    if(response.isSuccessful()){
      try {
        Log.d(TAG, "onResponse: "+response.body().string());
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }

  @Override
  public void onFailure(Call<ResponseBody> call, Throwable t) {
    Log.d(TAG, "onFailure: ");
  }
});

使用RxJava

要使用RxJava和Retrofit的结合,首先我们要添加要给依赖

compile 'io.reactivex:rxjava:1.1.7'
compile 'io.reactivex:rxandroid:1.2.1'
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'

再添加一个新的访问数据方法

public interface GitHubService {
  String BASEURL = "https://api.github.com";

  //...
  @GET("users/{user}")
  Observable<GitModel> rxUser(@Path("user") String user);
}

使用Rxjava访问

public void rxRetrofit(String username) {
  Retrofit retrofit = new Retrofit.Builder()
      .baseUrl(GitHubService.BASEURL)
      .addConverterFactory(GsonConverterFactory.create())
      .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
      .build();

  GitHubService service = retrofit.create(GitHubService.class);
  Observable<GitModel> obserable = service.rxUser(username);
  obserable
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new Subscriber<GitModel>() {
        @Override
        public void onCompleted() {
          Log.d(TAG, "onCompleted: ");
        }

        @Override
        public void onError(Throwable e) {
          Log.d(TAG, "onError: " + e.getMessage());
        }

        @Override
        public void onNext(GitModel gitModel) {
          Log.d(TAG, "onNext: " + gitModel.getName());
        }
      });
}

在使用时发现代码不但没有减少,而且增多了,其实不然。这只是展示的一个最基本的例子,RxJava的强大之处在于它流式编程的思想,强大的操作符,以及线程之间的切换。当我们有比较复杂的逻辑的时候,它的强大就显现出来了,这里只是为了演示用法。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,332评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,508评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,812评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,607评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,728评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,919评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,071评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,802评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,256评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,576评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,712评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,389评论 4 332
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,032评论 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,798评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,026评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,473评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,606评论 2 350

推荐阅读更多精彩内容