//  完美封装简化版
  private void simpleDo() {
    SubjectPost postEntity = new SubjectPost(simpleOnNextListener,this);
    postEntity.setAll(true);
    HttpManager manager = HttpManager.getInstance();
    manager.doHttpDeal(postEntity);
  }

  //  回调一一对应
  HttpOnNextListener simpleOnNextListener = new HttpOnNextListener<List<Subject>>() {
    @Override
    public void onNext(List<Subject> subjects) {
      tvMsg.setText("已封装：\n" + subjects.toString());
    }

    /*用户主动调用，默认是不需要覆写该方法*/
    @Override
    public void onError(Throwable e) {
      super.onError(e);
      tvMsg.setText("失败：\n" + e.toString());
    }
  };

/** 
  * Retrofit加入rxjava实现http请求 
  */ 
  private void onButton9Click() { 
    //手动创建一个OkHttpClient并设置超时时间 
    okhttp3.OkHttpClient.Builder builder = new OkHttpClient.Builder(); 
    builder.connectTimeout(5, TimeUnit.SECONDS); 

    Retrofit retrofit = new Retrofit.Builder() 
        .client(builder.build()) 
        .addConverterFactory(GsonConverterFactory.create()) 
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
        .baseUrl(HttpManager.BASE_URL) 
        .build(); 

/    加载框 
    final ProgressDialog pd = new ProgressDialog(this); 

    HttpService apiService = retrofit.create(HttpService.class); 
    Observable<RetrofitEntity> observable = apiService.getAllVedioBy(true); 
    observable.subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) 
        .subscribe( 
            new Subscriber<RetrofitEntity>() { 
              @Override 
              public void onCompleted() { 
                if (pd != null && pd.isShowing()) { 
                  pd.dismiss(); 
                } 
              } 

              @Override 
              public void onError(Throwable e) { 
                if (pd != null && pd.isShowing()) { 
                  pd.dismiss(); 
                } 
              } 

              @Override 
              public void onNext(RetrofitEntity retrofitEntity) { 
                tvMsg.setText("无封装：\n" + retrofitEntity.getData().toString()); 
              } 

              @Override 
              public void onStart() { 
                super.onStart(); 
                pd.show(); 
              } 
            } 

        ); 
  }

<uses-permission android:name="android.permission.INTERNET"/>

 /*rx-android-java*/
  compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
  compile 'com.trello:rxlifecycle:1.0'
  compile 'com.trello:rxlifecycle-components:1.0'
  /*rotrofit*/
  compile 'com.squareup.retrofit2:retrofit:2.1.0'
  compile 'com.squareup.retrofit2:converter-gson:2.0.0'
  compile 'com.google.code.gson:gson:2.8.0'

/** 
 * @api  videoLink  50音图视频链接 
 * @url  http://www.izaodao.com/Api/AppFiftyToneGraph/videoLink 
 * @method post 
 * @param once_no bool(选填,ture无链接) 一次性获取下载地址 
 * @return json array( 
 * ret:1成功,2失败 
 * msg:信息 
 * data:{ 
 *    name:视频名称 
 *    title:标题 
 * } 
 )

String BASE_URL = " http://www.izaodao.com/Api/" 
  Retrofit retrofit = new Retrofit.Builder() 
      .baseUrl(BASE_URL) 
      .addConverterFactory(GsonConverterFactory.create()) 
      .build();

/** 
 * 接口地址 
 * Created by WZG on 2016/7/16. 
 */ 
public interface MyApiEndpointInterface { 
  @POST("AppFiftyToneGraph/videoLink") 
  Call<RetrofitEntity> getAllVedio(@Body boolean once_no)       
}

MyApiEndpointInterface apiService = retrofit.create(MyApiEndpointInterface.class); 
Call<RetrofitEntity> call = apiService.getAllVedio(true); 
call.enqueue(new Callback<RetrofitEntity>() { 
  @Override 
  public void onResponse(Response<RetrofitEntity> response, Retrofit retrofit) { 
    RetrofitEntity entity = response.body(); 
    Log.i("tag", "onResponse----->" + entity.getMsg()); 
  } 

  @Override 
  public void onFailure(Throwable t) { 
    Log.i("tag", "onFailure----->" + t.toString()); 

  } 
});

@POST("AppFiftyToneGraph/videoLink") 
Observable<RetrofitEntity> getAllVedioBy(@Body boolean once_no);

Retrofit retrofit = new Retrofit.Builder() 
        .client(builder.build()) 
        .addConverterFactory(GsonConverterFactory.create()) 
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
        .baseUrl(HttpManager.BASE_URL) 
        .build();

HttpService apiService = retrofit.create(HttpService.class); 
    Observable<RetrofitEntity> observable = apiService.getAllVedioBy(true); 
    observable.subscribeOn(Schedulers.io()).unsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()) 
        .subscribe( 
            new Subscriber<RetrofitEntity>() { 
              @Override 
              public void onCompleted() { 
              } 

              @Override 
              public void onError(Throwable e) {                
              } 

              @Override 
              public void onNext(RetrofitEntity retrofitEntity) { 
                tvMsg.setText("无封装：\n" + retrofitEntity.getData().toString()); 
              }              
            } 

        );

public abstract class BaseApi<T> implements Func1<BaseResultEntity<T>, T> {
  //rx生命周期管理
  private SoftReference<RxAppCompatActivity> rxAppCompatActivity;
  /*回调*/
  private SoftReference<HttpOnNextListener> listener;
  /*是否能取消加载框*/
  private boolean cancel;
  /*是否显示加载框*/
  private boolean showProgress;
  /*是否需要缓存处理*/
  private boolean cache;
  /*基础url*/
  private String baseUrl="http://www.izaodao.com/Api/";
  /*方法-如果需要缓存必须设置这个参数；不需要不用設置*/
  private String mothed;
  /*超时时间-默认6秒*/
  private int connectionTime = 6;
  /*有网情况下的本地缓存时间默认60秒*/
  private int cookieNetWorkTime=60;
  /*无网络的情况下本地缓存时间默认30天*/
  private int cookieNoNetWorkTime=24*60*60*30;
}

  /**
   * 设置参数
   *
   * @param retrofit
   * @return
   */
  public abstract Observable getObservable(Retrofit retrofit);

public class SubjectPostApi extends BaseApi {
   xxxxxxx
   xxxxxxx

 @Override
  public Observable getObservable(Retrofit retrofit) {
    HttpPostService service = retrofit.create(HttpPostService.class);
    return service.getAllVedioBys(isAll());
  }
}

Func1<BaseResultEntity<T>, T>，后边结合结果处理链接起来使用
  @Override
  public T call(BaseResultEntity<T> httpResult) {
    if (httpResult.getRet() == 0) {
      throw new HttpTimeException(httpResult.getMsg());
    }
    return httpResult.getData();
  }

 * ret:1成功,2失败 
 * msg:信息 
 * data:{ 
 *    name:视频名称 
 *    title:标题 
 * }

/**
 * 回调信息统一封装类
 * Created by WZG on 2016/7/16.
 */
public class BaseResultEntity<T> {
  // 判断标示
  private int ret;
  //  提示信息
  private String msg;
  //显示数据（用户需要关心的数据）
  private T data;


  xxxxx get-set xxxxx
}

public interface HttpPostService {
  @POST("AppFiftyToneGraph/videoLink")
  Call<RetrofitEntity> getAllVedio(@Body boolean once_no);
}

  private volatile static HttpManager INSTANCE;

  //构造方法私有
  private HttpManager() {
  }

  //获取单例
  public static HttpManager getInstance() {
    if (INSTANCE == null) {
      synchronized (HttpManager.class) {
        if (INSTANCE == null) {
          INSTANCE = new HttpManager();
        }
      }
    }
    return INSTANCE;
  }

 /**
   * 处理http请求
   *
   * @param basePar 封装的请求数据
   */
  public void doHttpDeal(BaseApi basePar) {
    //手动创建一个OkHttpClient并设置超时时间缓存等设置
    OkHttpClient.Builder builder = new OkHttpClient.Builder();
    builder.connectTimeout(basePar.getConnectionTime(), TimeUnit.SECONDS);
    builder.addInterceptor(new CookieInterceptor(basePar.isCache()));

    /*创建retrofit对象*/
    Retrofit retrofit = new Retrofit.Builder()
        .client(builder.build())
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
        .baseUrl(basePar.getBaseUrl())
        .build();


    /*rx处理*/
    ProgressSubscriber subscriber = new ProgressSubscriber(basePar);
    Observable observable = basePar.getObservable(retrofit)
        /*失败后的retry配置*/
        .retryWhen(new RetryWhenNetworkException())
        /*生命周期管理*/
        .compose(basePar.getRxAppCompatActivity().bindToLifecycle())
        /*http请求线程*/
        .subscribeOn(Schedulers.io())
        .unsubscribeOn(Schedulers.io())
        /*回调线程*/
        .observeOn(AndroidSchedulers.mainThread())
        /*结果判断*/
        .map(basePar);

    /*数据回调*/
    observable.subscribe(subscriber);
  }

/**
 * 用于在Http请求开始时，自动显示一个ProgressDialog
 * 在Http请求结束是，关闭ProgressDialog
 * 调用者自己对请求数据进行处理
 * Created by WZG on 2016/7/16.
 */
public class ProgressSubscriber<T> extends Subscriber<T> {
  /*是否弹框*/
  private boolean showPorgress = true;
  /* 软引用回调接口*/
  private SoftReference<HttpOnNextListener> mSubscriberOnNextListener;
  /*软引用反正内存泄露*/
  private SoftReference<RxAppCompatActivity> mActivity;
  /*加载框可自己定义*/
  private ProgressDialog pd;
  /*请求数据*/
  private BaseApi api;


  /**
   * 构造
   *
   * @param api
   */
  public ProgressSubscriber(BaseApi api) {
    this.api = api;
    this.mSubscriberOnNextListener = api.getListener();
    this.mActivity = new SoftReference<>(api.getRxAppCompatActivity());
    setShowPorgress(api.isShowProgress());
    if (api.isShowProgress()) {
      initProgressDialog(api.isCancel());
    }
  }


  /**
   * 初始化加载框
   */
  private void initProgressDialog(boolean cancel) {
    Context context = mActivity.get();
    if (pd == null && context != null) {
      pd = new ProgressDialog(context);
      pd.setCancelable(cancel);
      if (cancel) {
        pd.setOnCancelListener(new DialogInterface.OnCancelListener() {
          @Override
          public void onCancel(DialogInterface dialogInterface) {
            onCancelProgress();
          }
        });
      }
    }
  }


  /**
   * 显示加载框
   */
  private void showProgressDialog() {
    if (!isShowPorgress()) return;
    Context context = mActivity.get();
    if (pd == null || context == null) return;
    if (!pd.isShowing()) {
      pd.show();
    }
  }


  /**
   * 隐藏
   */
  private void dismissProgressDialog() {
    if (!isShowPorgress()) return;
    if (pd != null && pd.isShowing()) {
      pd.dismiss();
    }
  }
}

 /**
   * 订阅开始时调用
   * 显示ProgressDialog
   */
  @Override
  public void onStart() {
    showProgressDialog();
    /*缓存并且有网*/
    if (api.isCache() && AppUtil.isNetworkAvailable(RxRetrofitApp.getApplication())) {
       /*获取缓存数据*/
      CookieResulte cookieResulte = CookieDbUtil.getInstance().queryCookieBy(api.getUrl());
      if (cookieResulte != null) {
        long time = (System.currentTimeMillis() - cookieResulte.getTime()) / 1000;
        if (time < api.getCookieNetWorkTime()) {
          if (mSubscriberOnNextListener.get() != null) {
            mSubscriberOnNextListener.get().onCacheNext(cookieResulte.getResulte());
          }
          onCompleted();
          unsubscribe();
        }
      }
    }
  }

 /**
   * 完成，隐藏ProgressDialog
   */
  @Override
  public void onCompleted() {
    dismissProgressDialog();
  }

/**
   * 对错误进行统一处理
   * 隐藏ProgressDialog
   *
   * @param e
   */
  @Override
  public void onError(Throwable e) {
    dismissProgressDialog();
    /*需要緩存并且本地有缓存才返回*/
    if (api.isCache()) {
      Observable.just(api.getUrl()).subscribe(new Subscriber<String>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {
          errorDo(e);
        }

        @Override
        public void onNext(String s) {
          /*获取缓存数据*/
          CookieResulte cookieResulte = CookieDbUtil.getInstance().queryCookieBy(s);
          if (cookieResulte == null) {
            throw new HttpTimeException("网络错误");
          }
          long time = (System.currentTimeMillis() - cookieResulte.getTime()) / 1000;
          if (time < api.getCookieNoNetWorkTime()) {
            if (mSubscriberOnNextListener.get() != null) {
              mSubscriberOnNextListener.get().onCacheNext(cookieResulte.getResulte());
            }
          } else {
            CookieDbUtil.getInstance().deleteCookie(cookieResulte);
            throw new HttpTimeException("网络错误");
          }
        }
      });
    } else {
      errorDo(e);
    }
  }

  /*错误统一处理*/
  private void errorDo(Throwable e) {
    Context context = mActivity.get();
    if (context == null) return;
    if (e instanceof SocketTimeoutException) {
      Toast.makeText(context, "网络中断，请检查您的网络状态", Toast.LENGTH_SHORT).show();
    } else if (e instanceof ConnectException) {
      Toast.makeText(context, "网络中断，请检查您的网络状态", Toast.LENGTH_SHORT).show();
    } else {
      Toast.makeText(context, "错误" + e.getMessage(), Toast.LENGTH_SHORT).show();
    }
    if (mSubscriberOnNextListener.get() != null) {
      mSubscriberOnNextListener.get().onError(e);
    }
  }

  /**
   * 将onNext方法中的返回结果交给Activity或Fragment自己处理
   *
   * @param t 创建Subscriber时的泛型类型
   */
  @Override
  public void onNext(T t) {
    if (mSubscriberOnNextListener.get() != null) {
      mSubscriberOnNextListener.get().onNext(t);
    }
  }

/**
 * 成功回调处理
 * Created by WZG on 2016/7/16.
 */
public abstract class HttpOnNextListener<T> {
  /**
   * 成功后回调方法
   * @param t
   */
  public abstract void onNext(T t);

  /**
   * 緩存回調結果
   * @param string
   */
  public void onCacheNext(String string){

  }

  /**
   * 失败或者错误方法
   * 主动调用，更加灵活
   * @param e
   */
  public void onError(Throwable e){

  }

  /**
   * 取消回調
   */
  public void onCancel(){

  }
}

OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.retryOnConnectionFailure(true);

 /**
 * retry条件
 * Created by WZG on 2016/10/17.
 */
public class RetryWhenNetworkException implements Func1<Observable<? extends Throwable>, Observable<?>> {
//  retry次数
  private int count = 3;
//  延迟
  private long delay = 3000;
//  叠加延迟
  private long increaseDelay = 3000;

  public RetryWhenNetworkException() {

  }

  public RetryWhenNetworkException(int count, long delay) {
    this.count = count;
    this.delay = delay;
  }

  public RetryWhenNetworkException(int count, long delay, long increaseDelay) {
    this.count = count;
    this.delay = delay;
    this.increaseDelay = increaseDelay;
  }

  @Override
  public Observable<?> call(Observable<? extends Throwable> observable) {
    return observable
        .zipWith(Observable.range(1, count + 1), new Func2<Throwable, Integer, Wrapper>() {
          @Override
          public Wrapper call(Throwable throwable, Integer integer) {
            return new Wrapper(throwable, integer);
          }
        }).flatMap(new Func1<Wrapper, Observable<?>>() {
          @Override
          public Observable<?> call(Wrapper wrapper) {
            if ((wrapper.throwable instanceof ConnectException
                || wrapper.throwable instanceof SocketTimeoutException
                || wrapper.throwable instanceof TimeoutException)
                && wrapper.index < count + 1) { //如果超出重试次数也抛出错误，否则默认是会进入onCompleted
              return Observable.timer(delay + (wrapper.index - 1) * increaseDelay, TimeUnit.MILLISECONDS);

            }
            return Observable.error(wrapper.throwable);
          }
        });
  }

  private class Wrapper {
    private int index;
    private Throwable throwable;

    public Wrapper(Throwable throwable, int index) {
      this.index = index;
      this.throwable = throwable;
    }
  }
}

/**
 * 测试数据
 * Created by WZG on 2016/7/16.
 */
public class SubjectPostApi extends BaseApi {
//  接口需要传入的参数 可自定义不同类型
  private boolean all;
  /*任何你先要传递的参数*/
//  String xxxxx;

  /**
   * 默认初始化需要给定回调和rx周期类
   * 可以额外设置请求设置加载框显示，回调等（可扩展）
   * @param listener
   * @param rxAppCompatActivity
   */
  public SubjectPostApi(HttpOnNextListener listener, RxAppCompatActivity rxAppCompatActivity) {
    super(listener,rxAppCompatActivity);
    setShowProgress(true);
    setCancel(true);
    setCache(true);
    setMothed("AppFiftyToneGraph/videoLink");
    setCookieNetWorkTime(60);
    setCookieNoNetWorkTime(24*60*60);
  }

  public boolean isAll() {
    return all;
  }

  public void setAll(boolean all) {
    this.all = all;
  }

  @Override
  public Observable getObservable(Retrofit retrofit) {
    HttpPostService service = retrofit.create(HttpPostService.class);
    return service.getAllVedioBys(isAll());
  }
}

 //  完美封装简化版
  private void simpleDo() {
    SubjectPostApi postEntity = new SubjectPostApi(simpleOnNextListener,this);
    postEntity.setAll(true);
    HttpManager manager = HttpManager.getInstance();
    manager.doHttpDeal(postEntity);
  }

  //  回调一一对应
  HttpOnNextListener simpleOnNextListener = new HttpOnNextListener<List<SubjectResulte>>() {
    @Override
    public void onNext(List<SubjectResulte> subjects) {
      tvMsg.setText("网络返回：\n" + subjects.toString());
    }

    @Override
    public void onCacheNext(String cache) {
      /*缓存回调*/
      Gson gson=new Gson();
      java.lang.reflect.Type type = new TypeToken<BaseResultEntity<List<SubjectResulte>>>() {}.getType();
      BaseResultEntity resultEntity= gson.fromJson(cache, type);
      tvMsg.setText("缓存返回：\n"+resultEntity.getData().toString() );
    }

    /*用户主动调用，默认是不需要覆写该方法*/
    @Override
    public void onError(Throwable e) {
      super.onError(e);
      tvMsg.setText("失败：\n" + e.toString());
    }

    /*用户主动调用，默认是不需要覆写该方法*/
    @Override
    public void onCancel() {
      super.onCancel();
      tvMsg.setText("取消請求");
    }
  };