allprojects {
repositories {
...
maven { url 'https://jitpack.io' }
}
}
dependencies {
implementation 'com.github.eajon:RxHttp:0.2.0'
}
RxConfig.init(this)/*必填*/
.baseUrl("http://192.168.0.1/api/")/*基础路径，这里配置了请求中可以不单独配置*/
.baseHeader(null)/*公用请求头*/
.baseParameter(null)/*公用请参数*/
.okHttpClient(null)/*自定义okHttpClient*/
.logTag("RxHttp");/*自定义Log名称*/
//返回对象
new RxHttp
.Builder()
.get()/*post() put() delete() 按需配置默认POST*/
.baseUrl("http://192.168.0.1/api/")/* 按需配置 RxConfig已配置，可不配*/
.apiUrl("login")/* 按需配置 具体接口名称*/
.entity(Login.class)/* 按需配置 返回的数据类型，默认string*/
.addHeader(null)/* 按需配置 */
.addParameter(null)/* 按需配置 */
.lifecycle(this)/* 关联生命周期，可以指定到Activity具体动作，使用生命周期当前Activity需要继承RxAppCompatActivity 或者BaseMvpActivity */
.build()
.request(new HttpObserver<Login>() {
@Override
protected void onSuccess(Login o) {
}
@Override
protected void onError(String t) {
}
});
//返回string数据
new RxHttp
.Builder()
.get()/*post() put() delete() 按需配置默认POST*/
.baseUrl("http://192.168.0.1/api/")/* 按需配置 RxConfig已配置，可不配*/
.apiUrl("login")/* 按需配置 具体接口名称*/
.addHeader(null)/* 按需配置 */
.addParameter(null)/* 按需配置 */
.lifecycle(this)/* 关联生命周期，可以指定到Activity具体动作，使用生命周期当前Activity需要继承RxAppCompatActivity 或者BaseMvpActivity */
.build()
.request(new HttpObserver() {
@Override
protected void onSuccess(Object o) {
}
@Override
protected void onError(String t) {
}
});
String requestBody = new Gson().toJson(new Login("username","password"));
RequestBody body = RequestBody.create(MediaType.parse("application/json"), requestBody);//对象转化为RequestBody
new RxHttp
.Builder()
.baseUrl("http://192.168.0.1/api/")
.apiUrl("login")
.entity(Response.class)
.addHeader(null)
.lifecycle(this)/* 关联生命周期，可以指定到Activity具体动作，使用生命周期当前Activity需要继承RxAppCompatActivity 或者BaseMvpActivity */
.setRequestBody(body)/*必填参数 */
.build()
.request(new HttpObserver<Response>() {
@Override
protected void onSuccess(Response o) {
}
@Override
protected void onError(String t) {
}
});
File file1 = new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), "WEIXIN" + ".apk")
String url1 = "http://imtt.dd.qq.com/16891/50CC095EFBE6059601C6FB652547D737.apk?fsname=com.tencent.mm_6.6.7_1321.apk&csr=1bbd";
DownloadTask downloadTask = new DownloadTask(file1.getName(), file1.getAbsolutePath(), url1);
DownloadTask downloadTask;
new RxHttp
.Builder()
.lifecycle(this)
.downloadTask(downloadTask)
.build()
.download(new DownloadObserver() {
@Override
protected void onSuccess(DownloadTask downloadTask) {
}
@Override
protected void onError(String s) {
}
});
File file1 = new File(Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS), "WEIXIN" + ".apk")
String url1 = "http://imtt.dd.qq.com/16891/50CC095EFBE6059601C6FB652547D737.apk?fsname=com.tencent.mm_6.6.7_1321.apk&csr=1bbd";
DownloadTask downloadTask = new DownloadTask(file1.getName(), file1.getAbsolutePath(), url1);
RxHttp rxHttp = new RxHttp.Builder().lifecycle(this).downloadTask(downloadTask).build();
DownloadObserver downloadObserver = new DownloadObserver() {
@Override
protected void onSuccess(DownloadTask downloadTask) {
LogUtils.e(RxHttp.getConfig().getLogTag(), downloadTask.getState());
}
@Override
protected void onError(String t) {
}
};
rxHttp.download(downloadObserver);
//暂停OnClick
downloadTask.setState(DownloadTask.State.PAUSE);//设置暂停状态
textView.setText(downloadTask.getState().toString() + downloadTask.getProgress() + "%");//显示进度
downloadObserver.dispose();//取消发射，暂停
//实时获取进度 通过RXbus实现 Activity需要继承BaseMvpActivity
@Override
public void onResponse(RxResponse response) {
if (response.getTag().equals(downloadTask.getTag())) {//判断tag Tag相同表示是当前任务 注：在多线程下载的过程中，确保Tag唯一
DownloadTask downloadTask = (DownloadTask) response.getData();//获取当前下载任务
download.setText(downloadTask.getState().toString() + downloadTask.getProgress() + "%");//获取进度
}
}
UploadTask uploadTask = new UploadTask("SingleTag", new File(path));
new RxHttp.Builder()
.baseUrl("https://shop.cxwos.com/admin/File/")
.apiUrl("UploadFile?tentantId=16")
.uploadTask(uploadTask)/* 单文件必填*/
.lifecycle(this)
.build()
.upload(new UploadObserver() {
@Override
protected void onSuccess(Object o) {
}
@Override
protected void onError(String t) {
}
});
ArrayList <UploadTask> uploadTasks = new ArrayList <>();
UploadTask uploadTask = new UploadTask("SingleTag", new File(path));
UploadTask uploadTask2 = new UploadTask("Single2Tag", new File(path2));
uploadTasks.add(uploadTask);
uploadTasks.add(uploadTask2);
MultipartUploadTask multipartUploadTask =new MultipartUploadTask("muiltTag",uploadTasks);
new RxHttp.Builder()
.baseUrl("https://shop.cxwos.com/admin/File/")
.apiUrl("UploadFile?tentantId=16")
.multipartUploadTask(multipartUploadTask)
.lifecycle(this)
.build()
.upload(new UploadObserver() {
@Override
protected void onSuccess(Object o) {
}
@Override
protected void onError(String t) {
}
});
//实时获取进度 通过RXbus实现 Activity需要继承BaseMvpActivity
@Override
public void onResponse(RxResponse response) {
if (response.getTag().equals(uploadTask.getTag())) {//单文件
UploadTask uploadTask = (UploadTask)response.getData();
textView.setText(uploadTask.getState().toString()+uploadTask.getProgress()+"%");
}
if (response.getTag().equals(multipartUploadTask。getTag()) {//多文件
MultipartUploadTask multipartUploadTask = (MultipartUploadTask) response.getData();
content.setText("总进度：" + multipartUploadTask.getProgress() + "%" + multipartUploadTask.getState().toString());//总进度
//单个文件进度
multipartUploadTask.getUploadTasks().get(0).getProgress();
}
}