Retrofit+RxJava联网

简介: Retrofit+RxJava联网public class RetrofitUtils { private static final String BASE_URL="http:www.

Retrofit+RxJava联网

public class RetrofitUtils {
    private static final String  BASE_URL="http:www.baidu.com/";
    private volatile static RetrofitUtils mRetrofitUtils;
    private Retrofit mRetrofit;

    private RetrofitUtils(){

        initRetrofit();
    }

   public static RetrofitUtils getInstance(){
        if(mRetrofitUtils==null){
            synchronized (RetrofitUtils.class){
                if(mRetrofitUtils==null){
                    mRetrofitUtils=new RetrofitUtils();
                }
            }
        }
        return mRetrofitUtils;
   }


    private void initRetrofit() {

        HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
            @Override
            public void log(String message) {
                try {
                    String msg = URLDecoder.decode(message, "utf-8");
                    Log.i("OkHttpInterceptor-----", msg);

                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                    Log.i("OkHttpInterceptor-----", message);
                }
            }
        });
        interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
        /**okhttp默认时间10秒 请求时间较长时,重新设置下  **/
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        builder.connectTimeout(15, TimeUnit.SECONDS);
        builder.readTimeout(20, TimeUnit.SECONDS);
        builder.writeTimeout(20, TimeUnit.SECONDS);
        builder.retryOnConnectionFailure(true);
        OkHttpClient client = builder.build();
        mRetrofit = new Retrofit.Builder()
                .baseUrl(BASE_URL)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .client(client)
                .build();
    }

    public <T> T getApiServier(Class<T> reqServer){
        return mRetrofit.create(reqServer);
    }
}

依赖

implementation 'com.squareup.okhttp3:logging-interceptor:3.5.0'
implementation 'io.reactivex.rxjava2:rxjava:2.1.14'
implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
implementation 'com.squareup.retrofit2:retrofit:2.4.0'
implementation 'com.squareup.retrofit2:converter-gson:2.4.0'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0'

用法

FinanceApiService.class
public interface FinanceApiService {
    //POST请求
    @FormUrlEncoded
    @POST("acc/incomeAccounting")
    Observable<ResultBean> incomeAccounting(@Field("incTime") String incTime, @Field("operator") String operator, @Field("paymentMethod") String paymentMethod,
                                            @Field("incomeReason ") String incomeReason , @Field("incMoney") int incMoney, @Field("paymentUnit") String paymentUnit,
                                            @Field("consNumber") String consNumber, @Field("note") String note);
    //GET请求
    @GET("acc/incomeAccounting")
    Observable<ResultBean> incomeAccounting2(@Query("incTime") String incTime, @Query("operator") String operator, @Query("paymentMethod") String paymentMethod,
                                             @Query("incomeReason ") String incomeReason , @Query("incMoney") int incMoney, @Query("paymentUnit") String paymentUnit,
                                             @Query("consNumber") String consNumber, @Query("note") String note);
}
使用方法
 RetrofitUtils.getInstance().getApiServier(FinanceApiService.class)
                    .incomeAccounting(time,caozuoren,zhifufangshi,laiyuan,jine,fukuanfang,"HY123456",beizhu)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Consumer<ResultBean>() {
                        @Override
                        public void accept(ResultBean resultBean) throws Exception {
                           //请求成功
                        }
                    }, new Consumer<Throwable>() {
                        @Override
                        public void accept(Throwable throwable) throws Exception {
                            //请求失败
                        }
                    });
目录
相关文章
|
4月前
retrofit+okhttp+rxjava
retrofit+okhttp+rxjava
|
6月前
|
JSON Java 数据格式
rxjava2+retrofit2
rxjava2+retrofit2
51 1
|
缓存 JSON API
XHttp2 一个功能强悍的网络请求库,使用RxJava2 + Retrofit2 + OKHttp进行组装
XHttp2 一个功能强悍的网络请求库,使用RxJava2 + Retrofit2 + OKHttp进行组装
698 0
XHttp2 一个功能强悍的网络请求库,使用RxJava2 + Retrofit2 + OKHttp进行组装
|
JSON 缓存 前端开发
鸿蒙开发之网络框架搭建,MVP+Retrofit2+okhttp3+Rxjava2+RxHarmony2
鸿蒙开发之网络框架搭建,MVP+Retrofit2+okhttp3+Rxjava2+RxHarmony
334 1
|
JSON 缓存 前端开发
打造终极MVP+Retrofit2+okhttp3+Rxjava2网络请求,开发实用,简约2
打造终极MVP+Retrofit2+okhttp3+Rxjava2网络请求,开发实用,简约
227 0
|
设计模式 搜索推荐 Java
Android网络框架系列: Retrofit2.5(2)
简介: Retrofit是Square公司开发的一款针对Android网络请求的框架,遵循Restful设计风格,我们查看 invoke 可以发现:底层基于OkHttp实现的 ,相比其他网络请求框架,有以下优势: 性能最好,速度最快(动态代理优势) 简洁易用,代码简化 解耦彻底,职责细分 易与其他框架联用(Rxjava)
125 0
|
安全 API Android开发
Android网络框架系列: Retrofit2.5(1)
Retrofit是Square公司开发的一款针对Android网络请求的框架,遵循Restful设计风格,我们查看 invoke 可以发现:底层基于OkHttp实现的 ,相比其他网络请求框架,有以下优势: 性能最好,速度最快(动态代理优势) 简洁易用,代码简化 解耦彻底,职责细分 易与其他框架联用(Rxjava)
133 0
Android网络框架系列: Retrofit2.5(1)
|
XML 缓存 JSON
Android OkHttp+Retrofit+RxJava搭建网络访问框架(含源码)
Android OkHttp+Retrofit+RxJava搭建网络访问框架(含源码)
771 0
Android OkHttp+Retrofit+RxJava搭建网络访问框架(含源码)
|
JSON Java 数据格式
rxjava2+retrofit2 简介
rxjava2+retrofit2 简介
101 0
|
JSON Android开发 数据格式
使用Retrofit + RxJava 网络请求
使用Retrofit + RxJava 网络请求
389 0
使用Retrofit + RxJava 网络请求