###1.AndroidManifest.xml添加权限：

// 访问网络权限
uses-permission android:name="android.permission.INTERNET"
// 往sdcard中写入数据的权限
uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE"
// 在sdcard中创建/删除文件的权限
uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS"

###2.Application初始化操作 @Override public void onCreate(){super.onCreate(); HttpManager.Opration.setBaseUrl("http://www.cmonbaby.com/"); // 请求路径前缀，可参考Retrofit2 HttpManager.Opration.setShowLoger(true); // 是否打印网络请求详情，可参考Okhttp3 }

###普通GET请求： public void testGet(){Subscription s = HttpHelper.Builder .builder(service.getVersion(getVersionParamas())) .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e(" >>> ", "before(new Action0)")} }) .loadable(this) // 可不填，请求Dialog实现 .filter(new Action1<BaseBean>(){// 非必需实现 @Override public void call(BaseBean o){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 if (!o.isSuccess()) Log.e(" >>> ", o.isSuccess() + "")} }) .callback(new HttpCallback<BaseBean>(){@Override public void onSuccess(BaseBean o){Log.e(" >>> ", o.getData().getChangeLog())} }) .toSubscribe(); addSubscription(s)}

###普通POST请求： public void testPost(){Subscription s = HttpHelper.Builder .builder(service.versionAction(getVersionParamas())) .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e(" >>> ", "before(new Action0)")} }) .loadable(this) // 可不填，请求Dialog实现 .filter(new Action1<BaseBean>(){// 非必需实现 @Override public void call(BaseBean o){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 if (!o.isSuccess()) Log.e(" >>> ", o.isSuccess() + "")} }) .callback(new HttpCallback<BaseBean>(){@Override public void onSuccess(BaseBean o){Log.e(" >>> ", o.getData().getChangeLog())} }) .toSubscribe(); addSubscription(s)}

###当某些请求需要携带Token，而Token失效自动刷新再续发原请求： public void testToken(){Subscription s = TokenHelper.Builder .builder(service.loginReward(mToken, testUrl1), service.login(testUrl2, "simon@cmonbaby.com", "123456")) .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e(" before >>> ", "before(new Action0)")} }) .loadable(this) // 可不填，请求Dialog实现 .retryCount(3) // 非必需重写，默认3次请求失败重试 .tokenFilter(new TokenAction<BaseHttpEntity, BaseHttpEntity>(){@Override public Observable<BaseHttpEntity> call(BaseHttpEntity token){// token自动刷新后，得到token再返回续发请求接口 mToken = token.getData().getXauthToken(); Log.e("token >>> ", mToken); return service.loginReward(mToken, testUrl1)} }) .actionFilter(new Action1<BaseHttpEntity>(){// 非必需实现 @Override public void call(BaseHttpEntity info){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 if (!info.isSuccess()) Log.e("actionFilter >>> ", info.getErr())} }) .callback(new HttpCallback<BaseHttpEntity>(){@Override public void onSuccess(BaseHttpEntity info){// 最终请求返回数据 Log.e("callback >>> ", info.getData().toString())} }) .toSubscribe(); addSubscription(s)}

###嵌套请求（比如第二个接口需要第一个接口的参数） public void nesting(){Subscription s = NestingHelper.Builder .builder(service.login(testUrl2, "simon@cmonbaby.com", "123456"), service.loginReward(mToken, testUrl1)) .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e(" >>> ", "before(new Action0)")} }) .loadable(this) // 可不填，请求Dialog实现 .nestingCall(new NestingFunction<BaseHttpEntity, BaseHttpEntity>(){@Override public Observable<BaseHttpEntity> call(BaseHttpEntity token){Log.e("token >>> ", token.getData().getXauthToken()); // 得到第一个接口数据返回 mToken = token.getData().getXauthToken(); // 请求第二个接口 return service.loginReward(mToken, testUrl1)} }) .toFilter(new Action1<BaseHttpEntity>(){// 非必需实现 @Override public void call(BaseHttpEntity info){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 if (!info.isSuccess()) Log.e("toFilter >>> ", info.getErr())} }) .callback(new HttpCallback<BaseHttpEntity>(){@Override public void onSuccess(BaseHttpEntity info){// 第二个接口数据返回 Log.e("callback >>> ", info.getData().toString())} }) .toSubscribe(); addSubscription(s)}

###数组、集合的遍历 public void list(){String[] names ={"张三", "李四", "王五", "赵六", "钱七"}; Observable .from(names) .subscribe(new Action1(){

 @Override public void call(String name){Log.e("list >>> ", name)} })} 

###定时操作 public void timer(){Observable.timer(2, TimeUnit.SECONDS) .subscribe(new Observer(){

 @Override public void onCompleted(){Log.e ("timer >>> ", "completed")} @Override public void onError(Throwable e){Log.e("timer >>> ", "error")} @Override public void onNext(Long number){Log.e ("timer >>> ", "hello world")} })} 

###周期性操作 public void cycle(){Observable.interval(2, TimeUnit.SECONDS) .subscribe(new Observer(){

 @Override public void onCompleted(){Log.e ("cycle >>> ", "completed")} @Override public void onError(Throwable e){Log.e("cycle >>> ", "error")} @Override public void onNext(Long number){Log.e ("cycle >>> ", "hello world")} })} 

###轮询请求 public void polling(){Observable.create(new Observable.OnSubscribe<BaseBean>(){@Override public void call(final Subscriber<? super BaseBean> observer){Schedulers.newThread().createWorker() .schedulePeriodically(new Action0(){@Override public void call(){Log.e("polling >>> ", "polling")} }, 3000, 5000, TimeUnit.MILLISECONDS)} // 首次执行行动之前等待， 执行动作之间等待的时间间隔 }).subscribe(new HttpCallback<BaseBean>(){@Override public void onSuccess(BaseBean bean){Log.e("polling >>> ", bean.getData().getChangeLog())} })}

###多异步请求并发，不按顺序返回接受 public void merge(){// 拼接两个Observable的输出，不保证顺序，按照事件产生的顺序发送给订阅者 Subscription s = Merge2Helper.Builder.builder(service.versionAction(getVersionParamas()), service.login(testUrl2, "simon@cmonbaby.com", "123456")) .loadable(this) // 可不填，请求Dialog实现 .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "before")} }) .result1(new Action1<BaseBean>(){@Override public void call(BaseBean version){// 第一个接口返回 Log.e("result1 >>> ", version.getData().getChangeLog())} }) .result2(new Action1<BaseHttpEntity>(){@Override public void call(BaseHttpEntity token){// 第二个接口返回 Log.e("result2 >>> ", token.getData().getXauthToken())} }) .toSubscribe(); addSubscription(s)}

public void concat(){Subscription s = Concat2Helper.Builder.builder(service.versionAction(getVersionParamas()), service.login(testUrl2, "li_ai@baxter.com", "123456")) .loadable(this) // 可不填，请求Dialog实现 .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "before")} }) .result1(new Action1<BaseBean<VersionEntity>>(){@Override public void call(BaseBean<VersionEntity> version){// 第一个接口返回 Log.e("result1 >>> ", version.getData().getChangeLog())} }) .result2(new Action1<BaseHttpEntity<TokenEntity>>(){@Override public void call(BaseHttpEntity<TokenEntity> token){// 第二个接口返回 Log.e("result2 >>> ", token.getData().getXauthToken())} }) .toSubscribe(); addSubscription(s)} 

###多异步请求并发，等待所有异步完成再做操作 public void zip(){Subscription s = Zip2Helper.Builder.builder(service.versionAction(getVersionParamas()), service.login(testUrl2, "simon@cmonbaby.com", "123456"), String.class) .loadable(this) // 可不填，请求Dialog实现 .before(new Action0(){// 非必需实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "before")} }) .result1(new Action1<BaseBean>(){@Override public void call(BaseBean version){// 第一个接口返回 Log.e("result1 >>> ", version.getData().getChangeLog())} }) .result2(new Action1<BaseHttpEntity>(){@Override public void call(BaseHttpEntity token){// 第二个接口返回 Log.e("result2 >>> ", token.getData().getXauthToken())} }) .result(new Func2<BaseBean, BaseHttpEntity, String>(){@Override public String call(BaseBean version, BaseHttpEntity token){// 得到第一个，第二个接口返回后，执行第三个接口 Log.e("result >>> ", version.getData().getChangeLog() + "\n" + token.getData().getXauthToken()); return version.getData().getChangeLog() + "\n" + token.getData().getXauthToken()} }) .callback(new HttpCallback(){@Override public void onSuccess(String s){// 第三个接口数据返回 Log.e("callback >>> ", s)} }) .toSubscribe(); addSubscription(s)}

###普通上传文件 public void testUpload(){String url = "http://www.cmonbaby.com/image"; String path = Environment.getExternalStorageDirectory().getAbsolutePath(); File file = new File(path + "/" + "simon.jpg"); RequestBody body = RequestBody.create(MediaType.parse("image/jpeg"), file); MultipartBody.Part part = MultipartBody.Part.createFormData("file", file.getName(), body); service.uploadFile(url, getVersionParamas(), part) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(AndroidSchedulers.mainThread()) .subscribe(new HttpCallback<BaseBean>(){@Override public void onSuccess(BaseBean version){// 上传完成 Log.e("simon >>> ", version.getData().getName())} })}

###上传文件显示进度 public void testUploadProgress(){final String url = "http://www.cmonbaby.com/image"; Subscription s = UploadFile.Builder.upload(VersionService.class, service.uploadFile(null, null, null)) .loadable(this) // 可不填，请求Dialog实现 .dialogTitle("图片上传") // 可不填 .dialogContent("正在上传……") // 可不填 .fileType("image/jpeg") // 可不填 .fileParams("file") // 可不填 .filePath(Environment.getExternalStorageDirectory().getAbsolutePath() + "/testUpload.jpg") // 测试路径 .requestService(new UploadFileCall<BaseBean, VersionService>(){@Override public Observable<BaseBean> uploadFile(VersionService service, MultipartBody.Part part){return service.uploadFile(url, getVersionParamas(), part)} }) .before(new Action0(){// 可不实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "init something")} }) .progressListener(new ProgressListener(){// 上传进度监听 @Override public void onProgress(long progress, long total, boolean isFinish){// 可不实现 Log.e("progress >>> ", progress + " / " + total + " --- " + isFinish)} }) .filter(new Action1<BaseBean>(){// 可不实现 @Override public void call(BaseBean version){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 Log.e("filter >>> ", version.getData().getName())} }) .callback(new HttpCallback<BaseBean>(){@Override public void onSuccess(BaseBean version){// 上传完成 Log.e("callback >>> ", version.getData().getName())} }) .toSubscribe(); addSubscription(s)}

###多文件上传显示进度 public void testUploadFiles(){final String url = "http://www.cmonbaby.com/images"; String path = Environment.getExternalStorageDirectory().getAbsolutePath(); Subscription s = UploadFiles.Builder.uploadFiles(VersionService.class, service.uploadFiles(null, null, null)) .loadable(this) // 可不填，请求Dialog实现 .dialogTitle("图片上传") // 可不填 .dialogContent("正在上传……") // 可不填 .fileParams("files") // 可不填 .files(new File(path + "/" + "simon.jpg")) // 测试路径1 .files(new File(path + "/" + "testUpload.jpg")) // 测试路径2 .files(new File(path + "/" + "temp.jpg")) // 测试路径3 .requestService(new UploadFilesCall<BaseListBean, VersionService>(){@Override public Observable<BaseListBean> uploadFiles(VersionService service, Map<String, RequestBody> requestBodyMap){return service.uploadFiles(url, requestBodyMap, getVersionParamas())} }) .before(new Action0(){// 可不实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "init something")} }) .progressListener(new ProgressListener(){// 上传进度监听 @Override public void onProgress(long progress, long total, boolean isFinish){// 可不实现 Log.e("progress >>> ", progress + " / " + total + " --- " + isFinish)} }) .filter(new Action1<BaseListBean>(){// 可不实现 @Override public void call(BaseListBean version){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 Log.e("filter >>> ", version.getData().size() + "")} }) .callback(new HttpCallback<BaseListBean>(){@Override public void onSuccess(BaseListBean version){// 上传完成 Log.e("callback >>> ", version.getData().size() + "")} }) .toSubscribe(); addSubscription(s)}

###普通下载 public void testDown(){String url = "http://www.cmonbaby.com/download/http-2.3.5.apk"; service.downloadFile(url) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(AndroidSchedulers.mainThread()) .subscribe(new HttpCallback<Response>(){@Override public void onSuccess(Response response){// 下载完成，流的写入代码此处省略 Log.e("simon >>> ", response.body().toString())} })}

###下载文件显示进度 public void testDownProgress(){final String url = "http://www.cmonbaby.com/download/http-2.3.5.apk"; Subscription s = DownloadFile.Builder.download(VersionService.class) .loadable(this) // 可不填，请求Dialog实现 .dialogTitle("文件下载") // 可不填 .dialogContent("文件下载中，请稍候……") // 可不填 .responseService(new DownLoadCall(){@Override public Observable<Response> downloadFile(VersionService service){return service.downloadFile(url)} }) .before(new Action0(){// 可不实现 @Override public void call(){// 请求之前做一些事情，周期只有一次 Log.e("before >>> ", "init something")} }) .progressListener(new ProgressListener(){// 下载进度监听 @Override public void onProgress(long progress, long total, boolean isFinish){Log.e("progress >>> ", progress + " / " + total + " --- " + isFinish)} }) .filter(new Action1<Response>(){// 可不实现 @Override public void call(Response response){// 数据过滤，比如服务端返回200，但业务出现错误可在此进行处理 Log.e("filter >>> ", response.body().toString())} }) .callback(new HttpCallback<Response>(){@Override public void onSuccess(Response response){// 下载完成，流的写入代码此处省略 Log.e("callback >>> ", response.body().toString())} }) .toSubscribe(); addSubscription(s)}