前言

简单的示例DEMO，小记一下

RetrofitUtil.java

/**
 * Created by kevin on 9/25/17.
 */
public class RetrofitUtil {

    //超时时间
    private final static long TIME_OUT = 700;
    //请求URL地址
    private final static String mUrl = "https://api.douban.com/v2/";

    /**
     * 静态内部类单例
     */
    private RetrofitUtil() {
    }

    public static RetrofitUtil getInstance() {
        return RetrofitUtilHolder.instance;
    }

    static class RetrofitUtilHolder {
        private static final RetrofitUtil instance = new RetrofitUtil();
    }

    /**
     * 实例化Retrofit
     *
     * @return Retrofit
     */
    private static Retrofit getRetrofit(String url) {

        OkHttpClient okHttpClient = new OkHttpClient.Builder()
                .addInterceptor(new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY))
                .writeTimeout(TIME_OUT, TimeUnit.SECONDS)
                .readTimeout(TIME_OUT, TimeUnit.SECONDS)
                .connectTimeout(TIME_OUT, TimeUnit.SECONDS)
                .build();

        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(url)
                .client(okHttpClient)
                .addConverterFactory(GsonConverterFactory.create(new GsonBuilder().create()))
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();

        return retrofit;
    }

    /**
     * Book实体类
     *
     * @return BookAPI
     */
    public BookAPI getBookFromServer() {
        return getRetrofit(mUrl).create(BookAPI.class);
    }
}

BookAPI.java

/**
 * 两种入参方式
 *
 * Created by kevin on 9/25/17.
 */
public interface BookAPI {

    @GET("book/search")
    Observable<BookEntity> getBookAPI(@Query("q") String name, @Query("tag") String tag, @Query("start") int start, @Query("count") int count);

    @POST("book/search")
    Observable<BookEntity> getBookApiByBody(@Body BookIn bookIn);
}

BookPresenter.java

public class BookPresenter implements Presenter {

    private BookControl mControl;
    private BookView mBookView;
    private CompositeSubscription mSubscription;
    private BookEntity mBook;
    private CustomDialog mDialog;

    @Override
    public void onCreate() {
        mControl = new BookControl();
        mSubscription = new CompositeSubscription();

    }

    @Override
    public void onStop() {
        if (mSubscription.hasSubscriptions()) {
            mSubscription.unsubscribe();
        }
    }

    @Override
    public void onAttachView(BaseView view) {
        mBookView = (BookView) view;
    }

    /**
     * 弹出Dialog
     *
     * @param activity
     */
    public void showDialog(Activity activity) {
        if (null == mDialog) {
            mDialog = new CustomDialog(activity, R.style.CustomDialog);
        }
        mDialog.show();
    }

    /**
     * 取消Dialog
     */
    public void disDialog() {
        if (null != mDialog) {
            mDialog.dismiss();
        }
    }

    /**
     * 获取书本信息
     *
     * @param activity
     * @param name
     * @param tag
     * @param start
     * @param count
     */
    public void getBookAPI(final Activity activity, String name, String tag, int start, int count) {
        mSubscription.add(mControl.getBookAPI(name, tag, start, count)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe(new Action0() {
                    @Override
                    public void call() {
                        showDialog(activity);
                    }
                }).doAfterTerminate(new Action0() {
                    @Override
                    public void call() {
                        disDialog();
                    }
                })
                .subscribe(new Observer<BookEntity>() {
                    @Override
                    public void onCompleted() {
                        if (null != mBook) {
                            mBookView.onSuccess(mBook);
                        }
                    }

                    @Override
                    public void onError(Throwable e) {
                        mBookView.onFailed("请求失败!");
                        e.printStackTrace();
                    }

                    @Override
                    public void onNext(BookEntity book) {
                        mBook = book;
                    }
                }));
    }

    public void getBookApiByBody(final Activity activity, BookIn bookIn) {
        mSubscription.add(mControl.getBookApiByBody(bookIn)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe(new Action0() {
                    @Override
                    public void call() {
                        showDialog(activity);
                    }
                }).doAfterTerminate(new Action0() {
                    @Override
                    public void call() {
                        disDialog();
                    }
                }).subscribe(new Observer<BookEntity>() {
                    @Override
                    public void onCompleted() {
                        if (null != mBook) {
                            mBookView.onSuccess(mBook);
                        }
                    }

                    @Override
                    public void onError(Throwable e) {
                        mBookView.onFailed("请求失败!");
                        e.printStackTrace();
                    }

                    @Override
                    public void onNext(BookEntity book) {
                        mBook = book;
                    }
                }));
    }
}

MainActivity.java

public class MainActivity extends AppCompatActivity {

    private TextView mResult;
    private BookPresenter mBookPresenter = new BookPresenter();

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        initView();
        initData();
        initEvent();
    }

    /**
     * 初始化事件监听
     */
    private void initEvent() {
        mBookPresenter.onAttachView(new BookView() {
            @Override
            public void onSuccess(BookEntity book) {
                mResult.setText(book.toString());
            }

            @Override
            public void onFailed(String failed) {
                Toast.makeText(MainActivity.this, failed, Toast.LENGTH_SHORT).show();
            }
        });
    }


    /**
     * 点击事件
     *
     * @param view
     */
    public void click1(View view) {
        mBookPresenter.getBookAPI(this, "西游记", null, 0, 1);
    }

    /**
     * 点击事件
     *
     * @param view
     */
    public void click2(View view) {
        BookIn bookIn = new BookIn();
        bookIn.setQ("西游记");
        bookIn.setTag(null);
        bookIn.setStart(0);
        bookIn.setCount(1);
        mBookPresenter.getBookApiByBody(this, bookIn);
    }

    /**
     * 初始化数据
     */
    private void initData() {
        mBookPresenter.onCreate();
    }

    /**
     * 初始化View
     */
    private void initView() {
        mResult = (TextView) findViewById(R.id.tv_result);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        mBookPresenter.onStop();
    }
}

运行截图

device-2017-09-26-124008.png

下载地址：Github