retrofit2+rxjava+okhttp网络请求实现

    compile ‘io.reactivex:rxandroid:1.2.0‘
    compile ‘com.squareup.retrofit2:adapter-rxjava:2.1.0‘
    compile ‘com.squareup.retrofit2:converter-gson:2.1.0‘
    compile ‘com.squareup.retrofit2:retrofit:2.1.0‘

import android.os.Build;
import okhttp3.Cache;

import com.loaderman.samplecollect.constants.HttpUrlConstants;
import com.loaderman.samplecollect.utils.UiUtil;

import java.io.File;
import java.io.IOException;

import okhttp3.Interceptor;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
import okhttp3.Response;
/**
 * Created by Administrator on 2018/10/10 0010.
 */

public class HttpManager {
    private static final Interceptor REWRITE_CACHE_CONTROL_INTERCEPTOR = new Interceptor() {
        @Override
        public Response intercept(Chain chain) throws IOException {
            int maxAge = 60 * 5; // 在线缓存在5分钟内可读取
            Request request = chain
                    .request()
                    .newBuilder()
                    .addHeader("User-Agent", Build.BRAND + "/" + Build.MODEL + "/" + Build.VERSION.RELEASE)//添加请求头
                    .header("Cache-Control", "public, max-age=" + maxAge)
                    .build();
            return chain.proceed(request);
        }
    };

    private static File httpCacheDirectory = new File(UiUtil.getContext().getCacheDir(), "mCache");
    private static int          cacheSize          = 10 * 1024 * 1024; // 10 MiB
    private static Cache cache              = new Cache(httpCacheDirectory, cacheSize);
    private static OkHttpClient client             = new OkHttpClient.Builder()
            .addNetworkInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR)
            .addInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR)
            .cache(cache)
            .build();
    private static HttpManager apiManager;
    public static HttpManager getInstence() {

        if (apiManager == null) {
            synchronized (HttpManager.class) {
                if (apiManager == null) {
                    apiManager = new HttpManager();
                }
            }
        }
        return apiManager;
    }

    private static IHttp httpService;

    public IHttp getHttpService() {
        if (httpService == null) {
            synchronized (new Object()) {
                if (httpService == null) {
                    httpService = new Retrofit
                            .Builder()
                            .baseUrl(HttpUrlConstants.BASE_URL)
                            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                            .addConverterFactory(GsonConverterFactory.create())
                            .client(client)
                            .build().create(IHttp.class);
                }
            }
        }
        return httpService;
    }
}

import com.loaderman.samplecollect.constants.HttpUrlConstants;
import com.loaderman.samplecollect.model.GetDataResult;
import com.loaderman.samplecollect.model.RequestParams;

import java.util.List;
import java.util.Map;

import okhttp3.MultipartBody;
import retrofit2.http.Body;
import retrofit2.http.Field;
import retrofit2.http.FieldMap;
import retrofit2.http.FormUrlEncoded;
import retrofit2.http.GET;
import retrofit2.http.Headers;
import retrofit2.http.Multipart;
import retrofit2.http.POST;
import retrofit2.http.Part;
import retrofit2.http.Query;
import rx.Observable;

/**
 * Created by Administrator on 2018/10/10 0010.
 */

public interface IHttp {

    @GET(HttpUrlConstants.data_url)
    Observable<GetDataResult> getData2(@Query("city") String city);

    @Headers({"Content-Type: application/json;charset=UTF-8"})
    @POST(HttpUrlConstants.data_url)
    Observable<GetDataResult> getData1(@Body RequestParams params);

    @FormUrlEncoded
    @POST(HttpUrlConstants.data_url)
    Observable<GetDataResult> getData3(@Field("city") String city);

    @FormUrlEncoded
    @POST(HttpUrlConstants.data_url)
    Observable<GetDataResult> getData4(@FieldMap Map<String, String> map);
    //上传头像
    @Multipart
    @POST(HttpUrlConstants.data_url)
    Observable<GetDataResult> upLoadIcon(@Part List<MultipartBody.Part> partList);
    
}

public interface HttpUrlConstants {
    String BASE_URL="http://wthrcdn.etouch.cn/";

    String data_url = "weather_mini";
}

HttpManager
                .getInstence()
                .getHttpService()
                .getData2("北京市")
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<GetDataResult>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {
                        LoggerUtil.systemOut(e.toString());
                    }

                    @Override
                    public void onNext(GetDataResult getDataResult) {
                        LoggerUtil.systemOut(getDataResult.toString());
                        ToastUtil.showMsg(MainActivity.this, getDataResult.data.city);
                    }
                });

  MultipartBody.Builder builder = new MultipartBody.Builder()
                .setType(MultipartBody.FORM)//表单类型
                .addFormDataPart("token", ConfigConstants.getToken(this))
                .addFormDataPart("uid", ConfigConstants.getUid(this))
                .addFormDataPart("sign", ConfigConstants.SIGN)
                ;
        RequestBody imageBody = RequestBody.create(MediaType.parse("image/png"), file);  //multipart/form-data image/png
        builder.addFormDataPart("file", file.getName(), imageBody);//file 后台接收图片流的参数名    +".png"
        List<MultipartBody.Part> parts = builder.build().parts();

        HttpManager
                .getInstence()
                .getLearnCarService()
                .upLoadIcon(parts)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<UpLoadIconEntity>() {
                    @Override
                    public void onCompleted() {
                        
                    }

                    @Override
                    public void onError(Throwable e) {
                       
                    }

                    @Override
                    public void onNext(UpLoadIconEntity upLoadIconEntity) {

                       
                        hideLoading();
                    }
                });