《Android进阶之光》--RxJava结合Retrofit访问网络
2023-09-14 09:00:41 时间
1)配置
dependencies{
...
compile 'io.reactivex:rxjava:1.2.0'
compile 'io.reactivex:rxandroid:1.2.1'
compile 'com.squareup.retrofit2:retorfit:2.1.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
}
2)修改请求网络接口
Retrofit请求接口返回Call。若结合RxJava,则需要把Call改为Observable
public interface IpServiceForPost{ @FormUrlEncoded @POST("getIpInfo.php") Observable<IpModel> getIpMsg(@Field("ip") String first); }
3)修改请求网络方法
private void postIpInformation(String ip){ String url = "http://ip.taobao.com/service/"; Retrofit retrofit = new Retrofit.Builder().baseUrl(url).addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()).build(); IpServiceForPost ipService = retrofit.create(IpServcieForPost.class); subscription=ipService.getIpMsg(ip).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<IpModel>(){ @Override public void onCompleted(){ Log.d(TAG,"onCompleted"); } @Override public void onError(Throwable e){ Log.d(TAG,"onError"); } @Override public void onNext(IpModel ipModel){ String country=ipModel.getData().getCountry(); Toast.makeText(getApplicationContext(),country,Toast.LENGTH_SHORT).show(); } }); }
4)请求返回数据格式封装
public class IpModel{ private int code; private IpData data; public void setCode(int code){ this.code = code; } public int getCode(){ return this.code; } ... }
public class HttpResult<T>{ private int code; private T data; public int getCode(){ return code; } public void setCode(int code){ this.code = code; } public T getData(){ return data; } public void setData(T data){ this.data = data; } }
public interface IpServiceForPost{ @FormUrlEncoded @POST("getIpInfo.php") Observable<HttpResult<IpData>> getIpMsg(@Field("ip") String first); }
private void postIpInformation(String ip){ ... subscription=ipService.getIpMsg(ip).subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<HttpResult<IpData>>(){ @Override public void onCompleted(){ } @Override public void onError(Throwable e){ } @Override public void onNext(HttpResult<IpData> ipDataHttpResult){ IpData data=ipDataHttpResult.getData(); Toast.matkText(getApplicationContext(),data.getCountry(),Toast.LENGTH_SHORT).show(); } }); }
5)取消请求
@Override public void onStop(){ super.onStop(); if(subscription!=null && subscription.isUnsubscribed()){ subscription.unsubscribe(); } }
private CompositeSubscription compositeSubscription = new CompositeSubscription(); ... //发送请求的地方,将返回的subscription添加到compositeSubscription中 compositeSubscription.add(subscription); ... //取消所有请求 @Override public void onStop(){ super.onStop(); compositeSubscription.unsubscribe(); }
相关文章
- android+制作开机动画,Android 开机动画制作详解
- 74款android开机动画,修改Android系统开机动画
- 基于chromium for android开发Android浏览器
- android 的hook技术,Android Native Hook技术(一)
- strictmode android,Android中的StrictMode
- android sdk manager安装,Android SDK Manager安装过程
- Android listView用法详解
- Android游戏引擎_2d游戏引擎
- android跳转到相册需要权限,Android打开相册获取图片路径[通俗易懂]
- android studio 导入第三方库的记录
- android 系统浏览器 源码-Android 最最最简单的浏览器代码
- 【Android 应用开发】 Android 各种版本简介 ( Support 支持库版本 | Android Studio 版本 | Gradle 版本 | jcenter 库版本 )
- 【Android Gradle 插件】Android Studio 工程 Gradle 构建流程 ① ( 触发 Android Studio 工程构建 | Gradle 构建脚本执行顺序 )
- 【Android 启动过程】Activity 启动源码分析 ( ActivityThread -> Activity、主线程阶段 二 )
- 【Android 逆向】加壳技术识别 ( VMP 加壳示例 | Dex2C 加壳示例 )
- 【Android WebSocket】Android 端 WebSocket 基本用法 ( 添加依赖和权限 | 创建 WebSocketClient 客户端类 | 建立连接并发送消息 )
- 【错误记录】Android Studio 编译时 lint 检查报错 ( WARNING: DSL element ‘android.dataBinding.enabled‘ is obsolet )
- Android下获取SD卡的状态并写入文件到SD卡详解编程语言
- 微信7.0.20 for Android发布 加入青少年模式 可选择停用大量功能
- Android系统自带样式(android:theme)
- Android入门之RelativeLayout、FrameLayout用法分析