{"id":387,"date":"2023-02-25T08:42:36","date_gmt":"2023-02-25T00:42:36","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=387"},"modified":"2023-04-30T14:38:31","modified_gmt":"2023-04-30T06:38:31","slug":"retrofit2-learning-9-combine-with-rxjava","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/02\/25\/retrofit2-learning-9-combine-with-rxjava\/","title":{"rendered":"Retrofit2\u5b66\u4e60\u4e4b\u4e5d\uff1a\u4e0eRxJava\u7ed3\u5408"},"content":{"rendered":"

\u9700\u6c42\uff1a\u5b9e\u73b0\u7528\u6237\u767b\u5f55\uff0c\u7136\u540e\u901a\u8fc7\u767b\u9646\u8fd4\u56de\u7684\u7528\u6237Id\u83b7\u53d6\u7528\u6237\u4fe1\u606f\u3002<\/p>\n

\u666e\u901a\u5b9e\u73b0<\/h2>\n

<\/p>\n

\u521b\u5efa\u4e1a\u52a1\u8bf7\u6c42\u63a5\u53e3<\/h3>\n
public interface Api {\n\n    @POST("login\/json")\n    Call<ResponseResult> login(@Body UserParam param);\n\n}<\/code><\/pre>\n
\u521b\u5efa\u4e00\u4e2aRetrofit\u7684\u5b9e\u4f8b\uff0c\u7136\u540e\u5229\u7528Retrofit\u5b9e\u4f8b\u521b\u5efa\u63a5\u53e3\u5bf9\u8c61\u548c\u8c03\u7528\u63a5\u53e3\u65b9\u6cd5<\/h3>\n
public void login(View view) {\n    Retrofit retrofit = new Retrofit.Builder()\n            .baseUrl(SERVER_ADDRESS)\n            .addConverterFactory(GsonConverterFactory.create())\n            .build();\n\n    api = retrofit.create(Api.class);\n\n    api.login(new UserParam("AppBlog.CN", "123456")).enqueue(new Callback<ResponseResult>() {\n        @Override\n        public void onResponse(Call<ResponseResult> call, Response<ResponseResult> response) {\n            if (response.isSuccessful()) {\n                int userId = response.body().getUserId();\n                api.getUserInfoWithPath(userId).enqueue(new Callback<User>() {\n                    @Override\n                    public void onResponse(Call<User> call, Response<User> response) {\n                        if (response.isSuccessful()) {\n                            User user = response.body();\n                            Toast.makeText(MainActivity.this, user.getUsername(), Toast.LENGTH_SHORT).show();\n                        }\n                    }\n\n                    @Override\n                    public void onFailure(Call<User> call, Throwable t) {\n                        Log.i(TAG, "\u8bf7\u6c42\u5931\u8d25: " + t.getLocalizedMessage());\n                    }\n                });\n            }\n        }\n\n        @Override\n        public void onFailure(Call<ResponseResult> call, Throwable t) {\n            Log.i(TAG, "\u767b\u5f55\u5931\u8d25: " + t.getLocalizedMessage());\n        }\n    });\n}<\/code><\/pre>\n
\u7f3a\u70b9\uff1a\u4ee3\u7801\u7e41\u7410\uff0c\u5d4c\u5957\u591a\u4e0d\u65b9\u4fbf\u6269\u5c55<\/p>\n
\u4e0eRxJava\u7ed3\u5408<\/h2>\n
\u6dfb\u52a0\u4f9d\u8d56<\/h3>\n
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'\ncompile 'io.reactivex:rxandroid:1.2.1'\ncompile 'io.reactivex:rxjava:1.2.3'<\/code><\/pre>\n
\u521b\u5efa\u4e1a\u52a1\u8bf7\u6c42\u63a5\u53e3<\/h3>\n
public interface Api {\n\n    @POST("login\/json")\n    Observable<ResponseResult> loginWithRx(@Body UserParam param);\n\n}<\/code><\/pre>\n
\u521b\u5efa\u4e00\u4e2aRetrofit\u7684\u5b9e\u4f8b\uff0c\u7136\u540e\u5229\u7528Retrofit\u5b9e\u4f8b\u521b\u5efa\u63a5\u53e3\u5bf9\u8c61\u548c\u8c03\u7528\u63a5\u53e3\u65b9\u6cd5<\/h3>\n
\/\/\u5d4c\u5957\u5199\u6cd5\npublic void loginWithRx(View view) {\n    Retrofit retrofit = new Retrofit.Builder()\n            .baseUrl(SERVER_ADDRESS)\n            .addConverterFactory(GsonConverterFactory.create())\n            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())\n            .build();\n\n    api = retrofit.create(Api.class);\n\n    api.loginWithRx(new UserParam("AppBlog.CN", "123456")).subscribeOn(Schedulers.io()).subscribe(new Subscriber<ResponseResult>() {\n        @Override\n        public void onCompleted() {\n\n        }\n\n        @Override\n        public void onError(Throwable e) {\n            e.printStackTrace();\n            Log.i(TAG, "\u767b\u5f55\u5931\u8d25: " + e.getLocalizedMessage());\n        }\n\n        @Override\n        public void onNext(ResponseResult responseResult) {\n            api.getUserInfoWithRx(responseResult.getUserId())\n                    .subscribeOn(Schedulers.io())\n                    .observeOn(AndroidSchedulers.mainThread())\n                    .subscribe(new Action1<User>() {\n                        @Override\n                        public void call(User user) {\n                            Toast.makeText(MainActivity.this, user.getUsername(), Toast.LENGTH_SHORT).show();\n                        }\n                    });\n        }\n    });\n}<\/code><\/pre>\n
\u4f18\u70b9\uff1a<\/p>\n
    \n
  • \u4f7f\u7528RxJava\u9002\u914d\u5668 addCallAdapterFactory(RxJavaCallAdapterFactory.create())<\/code> \u53ef\u4ee5\u5b9e\u73b0\u8fd4\u56deBody\u81ea\u52a8\u8f6c\u6362\u4e3aResponseResult\u5bf9\u8c61<\/li>\n
  • \u4f7f\u7528 subscribeOn(Schedulers.io())<\/code> \u548c observeOn(AndroidSchedulers.mainThread())<\/code> \u8f7b\u677e\u5b9e\u73b0IO\u7ebf\u7a0b\u548cUI\u7ebf\u7a0b\u95f4\u7684\u5207\u6362<\/li>\n<\/ul>\n
    \u7f3a\u70b9\uff1a\u4ee3\u7801\u5d4c\u5957\u4ecd\u7136\u8fc7\u591a\uff0c\u4e0d\u65b9\u4fbf\u6269\u5c55<\/p>\n
    RxJava\u94fe\u5f0f\u5199\u6cd5<\/h2>\n
    \u521b\u5efa\u4e1a\u52a1\u8bf7\u6c42\u63a5\u53e3<\/h3>\n
    public interface Api {\n\n    @GET("user\/{id}")\n    Observable<User> getUserInfoWithRx(@Path("id") int userId);\n\n}<\/code><\/pre>\n
    \u521b\u5efa\u4e00\u4e2aRetrofit\u7684\u5b9e\u4f8b\uff0c\u7136\u540e\u5229\u7528Retrofit\u5b9e\u4f8b\u521b\u5efa\u63a5\u53e3\u5bf9\u8c61\u548c\u8c03\u7528\u63a5\u53e3\u65b9\u6cd5<\/h3>\n
    \/\/\u94fe\u5f0f\u5199\u6cd5\npublic void loginWithRxChain(View view) {\n    Retrofit retrofit = new Retrofit.Builder()\n            .baseUrl(SERVER_ADDRESS)\n            .addConverterFactory(GsonConverterFactory.create())\n            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())\n            .build();\n\n    api = retrofit.create(Api.class);\n\n    api.loginWithRx(new UserParam("AppBlog.CN", "123456")).flatMap(new Func1<ResponseResult, Observable<User>>() {\n        @Override\n        public Observable<User> call(ResponseResult responseResult) {\n            return api.getUserInfoWithRx(responseResult.getUserId());\n        }\n    }).doOnNext(new Action1<User>() {\n        @Override\n        public void call(User user) {\n            \/\/download avatar\n        }\n    }).doOnSubscribe(new Action0() {\n        @Override\n        public void call() {\n\n        }\n    }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<User>() {\n        @Override\n        public void call(User user) {\n            Toast.makeText(MainActivity.this, user.getUsername(), Toast.LENGTH_SHORT).show();\n        }\n    });\n}<\/code><\/pre>\n
    \u4f18\u70b9\uff1a\u4ee3\u7801\u94fe\u5f0f\u5199\u6cd5\uff0c\u7ed3\u6784\u6e05\u6670\uff0c\u6269\u5c55\u65b9\u4fbf<\/p>\n","protected":false},"excerpt":{"rendered":"
    \u9700\u6c42\uff1a\u5b9e\u73b0\u7528\u6237\u767b\u5f55\uff0c\u7136\u540e\u901a\u8fc7\u767b\u9646\u8fd4\u56de\u7684\u7528\u6237Id\u83b7\u53d6\u7528\u6237\u4fe1\u606f\u3002 \u666e\u901a\u5b9e\u73b0 \u521b\u5efa\u4e1a\u52a1\u8bf7\u6c42\u63a5\u53e3 public int […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[130],"tags":[],"class_list":["post-387","post","type-post","status-publish","format-standard","hentry","category-retrofit"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/387","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=387"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/387\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=387"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=387"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=387"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}