前言
從今年2月份開始接觸RxJava式廷，看了不少博客和項(xiàng)目赠涮，在8月份的時(shí)候把公司的項(xiàng)目完成了改版。使用RxJava+Retrofit2+Dagger2 +MVP開發(fā)梁厉，關(guān)于這種模式的介紹的文章網(wǎng)上琳瑯滿目辜羊，這里就不再贅述了。附錄于兩個(gè)不錯(cuò)的項(xiàng)目词顾，想學(xué)習(xí)MVP開發(fā)的童鞋可以看看已添。開發(fā)大型項(xiàng)目使用mvp再好不過了昭灵，可是很多時(shí)候?qū)τ谛⌒晚?xiàng)目，業(yè)務(wù)邏輯沒有那么復(fù)雜的情況下，MVC顯得更好用黍瞧。下面進(jìn)入正文辫继。
Points
RxJava配合Retrofit2做網(wǎng)絡(luò)請(qǐng)求
Rxlifecycle和CompositeSubscription做異步的生命周期管理
EventBus來做組件間的通信
Bufferkinfe做組件注入和點(diǎn)擊事件回調(diào)
Okhttp3對(duì)網(wǎng)絡(luò)返回內(nèi)容設(shè)置頭部信息，控制臺(tái)日志，resonpse預(yù)處理等配置
Dagger2將M層注入V層
Glide做圖片的處理和加載
Gson配合Retrofit2做數(shù)據(jù)解析
ultra-ptr做列表刷新
項(xiàng)目結(jié)構(gòu)：
api：網(wǎng)絡(luò)請(qǐng)求接口 網(wǎng)絡(luò)請(qǐng)求客戶端 自定義網(wǎng)絡(luò)請(qǐng)求異常
beans:實(shí)體類(對(duì)應(yīng)網(wǎng)絡(luò)請(qǐng)求數(shù)據(jù)結(jié)構(gòu))
event:項(xiàng)目中的事件纳本，結(jié)合eventbus 如登錄 用戶信息修改 充值 登錄異常等
injector:注入相關(guān) component（注射器）和module（全局實(shí)例倉庫）
net:網(wǎng)絡(luò)請(qǐng)求中的相關(guān)設(shè)置和處理類
ui：Activity Fragment 和adapter
utils:工具類
widget:第三方或者自定義控件
wxapi:微信分享
api介紹
ApiInterface中是使用Retrofit2的語法定義的網(wǎng)絡(luò)請(qǐng)求接口如：
/** * 驗(yàn)證碼 */
@FormUrlEncoded
@POST("public/sms")
Observable<HttpResult<SuccessBean>> get_auth_code(@Field("mobile") String mobile);
......
這里規(guī)定了
請(qǐng)求頭
請(qǐng)求參數(shù)
請(qǐng)求方式
返回結(jié)果類型
看不懂的同學(xué)可以先看下retrofit官網(wǎng)的介紹。
關(guān)于返回類型Observable是RxJava中的被觀察者腋颠，其中的泛型就是實(shí)體類繁成。
ApiService 是請(qǐng)求服務(wù)類 ，相當(dāng)于一個(gè)網(wǎng)絡(luò)幫助類淑玫。
private ApiService() {
//HTTP log
HttpLoggingInterceptor httpLoggingInterceptor =newHttpLoggingInterceptor();
httpLoggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
//RequestInterceptor
RequestInterceptor requestInterceptor =newRequestInterceptor();
//ResponseInterceptor
ResponseInterceptor responseInterceptor =newResponseInterceptor();
//OkHttpClient
OkHttpClient mOkHttpClient =newOkHttpClient.Builder()
.connectTimeout(Constants.TIME_OUT,TimeUnit.SECONDS)
.addInterceptor(requestInterceptor)
.addInterceptor(responseInterceptor)
.addInterceptor(httpLoggingInterceptor)
.build();
//Retrofit
Retrofit mRetrofit =newRetrofit.Builder()
.client(mOkHttpClient)
.addConverterFactory(ScalarsConverterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.baseUrl(Constants.IP)
.build();
//ApiInterface
mApiInterface= mRetrofit.create(ApiInterface.class);
}
再其構(gòu)造方法中初始化retrofit2客戶端 并完成代理 mRetrofit.create(ApiInterface.class)進(jìn)行這一部操作后巾腕，返回的ApiInterface就是被代理后的Interface，便有了網(wǎng)絡(luò)請(qǐng)求的功能混移。構(gòu)造方法私有的原因是為了寫單例模式祠墅，一個(gè)項(xiàng)目中，我們只需要一個(gè)網(wǎng)絡(luò)請(qǐng)求客戶端歌径。
單例模式（寫法有很多種毁嗦，看個(gè)人愛好隨便選一種就好）
//Singleton
private static class SingletonHolder {
private static final ApiService INSTANCE = new ApiService();
}
//Instance
public static ApiService getApiService() {
return SingletonHolder.INSTANCE;
}
ApiService 應(yīng)定義好請(qǐng)求的方法，這里舉出兩個(gè)例子
/**
* 驗(yàn)證碼
*/
public Subscription get_auth_code(Subscriber<SuccessBean> subscriber, String mobile) {
return mApiInterface.get_auth_code(mobile)
.compose(new SchedulersTransformer<>())
.map(new HttpResultFunc<>())
.subscribe(subscriber);
}
......省略的其他api
接受一個(gè)subscriber 和請(qǐng)求的參數(shù) 使用RxJava完成設(shè)置線程和訂閱回铛，這種是第一種情況狗准，這種情況，這個(gè)鏈?zhǔn)饺蝿?wù)在這里就結(jié)束了茵肃，把結(jié)果發(fā)送給subscriber 腔长。
/**
* 登錄
*/
public Observable<LoginBean> login(String mobile, String pwd, String device_token) {
Map<String, Object> map = new HashMap<>();
map.put("mobile", mobile);
map.put("pwd", pwd);
map.put("device_token", device_token);
return mApiInterface.login(map)
.compose(new SchedulersTransformer<>())
.map(new HttpResultFunc<>());
}
登錄下載完成后拿到數(shù)據(jù)，我們還要存到本地验残，這部操作我們可以繼續(xù)用map執(zhí)行任務(wù)捞附，存完以后再把結(jié)果發(fā)送給subscriber ，應(yīng)該是上面的這種寫法您没。然后我們?cè)贚oginActivity這樣使用
mApi.login( phone, pwd, device_token)
.compose(this.bindToLifecycle())
.flatMap(loginBean -> {
String phoneNumber = vEtPhoneNumber.getText().toString();
SharePreferenceUtil.setLastLoginTime(LoginActivity.this);//最后登錄時(shí)間
SharePreferenceUtil.savePhoneNumber(LoginActivity.this, phoneNumber);//保存最后登錄賬號(hào)
if (loginBean != null) {
App.saveSessionId(loginBean.session_id);//保存session_id
}
MobclickAgent.onEvent(LoginActivity.this, "login");// 登陸成功計(jì)數(shù)
//發(fā)送登陸成功廣播
EventBus.getDefault().post(new LoginEvent());
//加入登錄過的賬號(hào)
Set<String> phones = SharePreferenceUtil.getLoginPhones(LoginActivity.this);
phones.add(phoneNumber);
SharePreferenceUtil.saveLoginPhones(LoginActivity.this, phones);
return Observable.just(true);})
.subscribe(aBoolean -> {
T.showShort(getString(R.string.tip_success_login));
LoginActivity.this.finish();
}, Throwable::printStackTrace);
因?yàn)檫@里是LoginActivity鸟召，我們可以不用Subscription 去處理生命周期 ，結(jié)合rxlifecycle處理任務(wù)的生命周期即.compose(this.bindToLifecycle())氨鹏；
然后接來下我又進(jìn)行了存用戶數(shù)據(jù)的操作flatMap欧募。最后才把發(fā)送Subscriber登錄成功。
總結(jié)一下：如果需要繼續(xù)操作下載后的數(shù)據(jù)在ApiService 求請(qǐng)方法就可以這樣寫仆抵，如果拿到數(shù)據(jù)不繼續(xù)操作數(shù)據(jù)跟继，只是為了展示的話，或者提示可以參考第一種寫法镣丑。
線程統(tǒng)一處理
/**
* hepeng Created on 2016/11/21.
* 類描述：統(tǒng)一線程處理
*/
public class SchedulersTransformer <T> implements Observable.Transformer<T, T> {
@Override
public Observable<T> call(Observable<T> tObservable) {
return tObservable.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
}
請(qǐng)求方法中的map操作是RxJava的轉(zhuǎn)換舔糖，對(duì)結(jié)果進(jìn)行處理
/**
* 用來統(tǒng)一處理Http的resultCode,并將HttpResult的Data部分剝離出來返回給subscriber
*
* @param <T> Subscriber真正需要的數(shù)據(jù)類型，也就是Data部分的數(shù)據(jù)類型
*/
public class HttpResultFunc<T> implements Func1<HttpResult<T>, T> {
@Override
public T call(HttpResult<T> httpResult) {
if (!httpResult.status.equals("1")) {
if (StringUtil.checkStr(httpResult.errcode)) {
if (httpResult.errcode.equals(Constants.SESSION_EXPIRE)) {
EventBus.getDefault().post(new SessionExpireEvent());
}
}
throw new ApiException(httpResult.errmsg);
}
return httpResult.dataresult;
}
}
這里要先講一下實(shí)體類格式
HttpResult：
status為1表示成功莺匠，status為0表示失敗金吗，展示errmsg。成功的數(shù)據(jù)都在dataresult中。
HttpResultFunc就是這這里把錯(cuò)的結(jié)果過濾掉辽聊，判斷了登錄過期SESSION_EXPIRE如果過期會(huì)發(fā)送過期事件，然后把前臺(tái)真正需要的數(shù)據(jù)返回即dataresult期贫。
ApiException 就是一個(gè)自定義的異常跟匆，接受一個(gè)錯(cuò)誤的message參數(shù)
Api到此就結(jié)束了。
實(shí)體類沒什么好講的搞java或者android應(yīng)該都知道通砍。
event 包下是一些全局的事件使用方法見EventBus
接下來講一下injector
dagger2是一個(gè)DI類庫 想學(xué)習(xí)的小伙伴可以參考牛曉偉的幾篇文章
Android：dagger2讓你愛不釋手-基礎(chǔ)依賴注入框架篇
Android：dagger2讓你愛不釋手-重點(diǎn)概念講解玛臂、融合篇
Android：dagger2讓你愛不釋手-終結(jié)篇
估計(jì)看完你就對(duì)dagger2有一點(diǎn)理解了。
下面我相信你已經(jīng)對(duì)dagger2有一定了解了封孙，直接上代碼迹冤。
AppComponent
/**
* Created by 何鵬 on 2016/8/4.
* 提供全局的實(shí)例對(duì)象
*/
@Singleton
@Component(modules = {AppModule.class})
public interface AppComponent {
//Exposed to sub-graphs.
Context getContext();
Gson getGson();
ApiService getApiService();
// inject to application
void inject(App app);
}
ActivityComponent
/**
* hepeng Created on 2016/10/12.
* 類名稱：ActivityComponent Activity注入類
*/
@PerActivity
@Component(dependencies = AppComponent.class, modules = ActivityModule.class)
public interface ActivityComponent {
//Exposed to sub-graphs.
Activity activity();
// inject Activity
void inject(MainActivity activity);
void inject(PersonInfoActivity activity);
.....
}
FragmentComponent
/**
* 類描述：
* 作者：何鵬 on 2016/4/19 15:23
* 郵箱：hepeng@xinxinnongren.com
*/
@PerFragment
@Component(modules = FragmentModule.class, dependencies = AppComponent.class)
public interface FragmentComponent {
//Exposed to sub-graphs.
Activity getActivity();
Fragment getFragment();
// inject Fragment
void inject(HomeFragment fragment);
void inject(AccountFragment fragment);
......
以上三個(gè)類都屬于component，ActivityComponent,FragmentComponent都依賴于AppComponent虎忌，用來提供實(shí)例 并申明接受注入的類泡徙。
下面看module
/**
* Created by CAI on 2016/8/4.
* 全局實(shí)例倉庫
*/
@Module
public class AppModule {
private final Context context;
public AppModule(Context context) {
this.context = context;
}
/**
* @return Context(application)
*/
@Singleton
@Provides
public Context ProvideContext() {
return context;
}
/***
* Gson客戶端
*/
@Provides
@Singleton
public Gson provideGson() {
return new Gson();
}
/***
* ApiService
*/
@Provides
@Singleton
public ApiService provideApiService() {
return ApiService.getApiService();
}
......
}
這里提供了 Context Gson 和 ApiService 其他類想用直接注入就好了，下面需要用的時(shí)候膜蠢，我會(huì)介紹怎么用堪藐。
net
HttpSubscriber 是對(duì)RxJava中Subscriber的封裝
/**
* hepeng Created on 2016/9/30.
* 類名稱： 網(wǎng)絡(luò)請(qǐng)求訂閱者
*/
public abstract class HttpSubscriber<T> extends Subscriber<T> {
@Override
public void onStart() {
super.onStart();
if (!NetUtils.isConnected()) {
if (!isUnsubscribed()) {
unsubscribe();
}
com.shoucainu.shoucainu.utils.T.showShort("請(qǐng)檢查網(wǎng)絡(luò)連接后重試!");
finish();
}
}
@Override
public void onError(Throwable e) {
finish();
if (e instanceof HttpException ||e instanceof ConnectException || e instanceof SocketTimeoutException || e instanceof TimeoutException) {
onNetworkException(e);
} else if (e instanceof ApiException) {
onApiException(e);
} else {
onUnknownException(e);
}
}
@Override
public void onCompleted() {
finish();
}
public abstract void finish();
public void onNetworkException(Throwable e) {
e.printStackTrace();
com.shoucainu.shoucainu.utils.T.showShort("獲取數(shù)據(jù)失敗，請(qǐng)檢查網(wǎng)絡(luò)狀態(tài)");
}
public void onApiException(Throwable e) {
e.printStackTrace();
com.shoucainu.shoucainu.utils.T.showShort(e.getMessage());
}
public void onUnknownException(Throwable e) {
e.printStackTrace();
}
}
在任務(wù)開始時(shí)對(duì)網(wǎng)絡(luò)進(jìn)行檢查 對(duì)錯(cuò)誤進(jìn)行區(qū)分處理 并且onError 和 onCompleted或者 onStart 結(jié)束后都會(huì)回調(diào)給子類finish()方法挑围。在回調(diào)中處理請(qǐng)求結(jié)束的改變礁竞，若成功還會(huì)回調(diào)onNext()方法，會(huì)把請(qǐng)求下的數(shù)據(jù)回調(diào)給子類杉辙。
RequestInterceptor
public class RequestInterceptor implements Interceptor {
@Override
public Response intercept(Chain chain) throws IOException {
Request original = chain.request();
//請(qǐng)求定制：添加請(qǐng)求頭
Request.Builder requestBuilder = original
.newBuilder()
.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
//set Cookie
String sessionId = App.getSessionId();
if (StringUtil.checkStr(sessionId)) {
requestBuilder.addHeader("Cookie", "PHPSESSID=" + sessionId);
}
//請(qǐng)求體定制：統(tǒng)一添加參數(shù)
if (original.body() instanceof FormBody) {
FormBody.Builder newFormBody = new FormBody.Builder();
FormBody oidFormBody = (FormBody) original.body();
for (int i = 0; i < oidFormBody.size(); i++) {
newFormBody.addEncoded(oidFormBody.encodedName(i), oidFormBody.encodedValue(i));
}
String client = Constants.CONFIG_CLIENT;
String key = Constants.CONFIG_KEY;
String sign = Md5Util.getMD5Str(client + "|" + key);
newFormBody.add("_deviceid_", App.getDeviceId());
newFormBody.add("_client_", client);
newFormBody.add("_sign_", sign);
newFormBody.add("version", Constants.CONFIG_VERSION);
newFormBody.add("channel", App.getUmengChannel());
requestBuilder.method(original.method(), newFormBody.build());
}
return chain.proceed(requestBuilder.build());
}
RequestInterceptor 是統(tǒng)一設(shè)置請(qǐng)求頭和一些common的請(qǐng)求參數(shù)
ResponseInterceptor
/**
* hepeng Created on 2016/10/8.
* 類名稱:ResponseInterceptor
*/
public class ResponseInterceptor implements Interceptor {
String emptyString = ":\"\"";
String emptyObject = ":{}";
String emptyArray = ":[]";
String newChars = ":null";
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
Response response = chain.proceed(request);
ResponseBody responseBody = response.body();
if (responseBody != null) {
String json = responseBody.string();
MediaType contentType = responseBody.contentType();
if (!json.contains(emptyString)) {
ResponseBody body = ResponseBody.create(contentType, json);
return response.newBuilder().body(body).build();
}else {
String replace = json.replace(emptyString, newChars);
String replace1 = replace.replace(emptyObject, newChars);
String replace2 = replace1.replace(emptyArray, newChars);
ResponseBody body = ResponseBody.create(contentType, replace2);
return response.newBuilder().body(body).build();
}
}
return response;
}
}
ResponseInterceptor是對(duì)后臺(tái)返回的結(jié)果預(yù)處理
接下來介紹重要的部分了
ui
個(gè)人認(rèn)為些項(xiàng)目之前先寫好BaseActivity 和BaseFragment很重要 這個(gè)寫得好 接下來你在寫的過程中會(huì)感覺無比的輕松模捂。
BaseActivity
/**
* hepeng Created on 2016/10/8.
* 類描述： activity的超類
*/
public abstract class BaseActivity extends RxAppCompatActivity implements View.OnClickListener {
protected String TAG = this.getClass().getSimpleName();
protected ActivityComponent mActivityComponent;
protected SVProgressHUD loading;
private CompositeSubscription mCompositeSubscription;
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
AppManager.getAppManager().addActivity(this);
setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_PORTRAIT); // 屏幕豎屏
setContentView(initContentView());
loading = new SVProgressHUD(this);
ButterKnife.bind(this);
initAppComponent();
initInjector();
initUiAndListener();
initData();
}
/**
* 設(shè)置view
*/
public abstract int initContentView();
/**
* init UI && Listener
*/
public abstract void initUiAndListener();
/**
* init Data
*/
public abstract void initData();
/**
* init ActivityModule
*/
protected ActivityModule getActivityModule() {
return new ActivityModule(this);
}
/**
* init AppComponent
*/
private void initAppComponent() {
mActivityComponent =DaggerActivityComponent.builder().activityModule(getActivityModule()).appComponent(getAppComponent()).build();
}
/**
* initInjector的默認(rèn)實(shí)現(xiàn) 子類需要時(shí)重寫即可
*/
protected void initInjector() {
}
/**
* get AppComponent
*/
protected AppComponent getAppComponent() {
return ((App) getApplication()).getAppComponent();
}
/**
* http請(qǐng)求的訂閱設(shè)置安全的CompositeSubscription
*/
protected synchronized void addSubscription(Subscription subscription) {
if (mCompositeSubscription == null) {
mCompositeSubscription = new CompositeSubscription();
}
mCompositeSubscription.add(subscription);
}
/**
* 跳轉(zhuǎn)一個(gè)界面不傳遞數(shù)據(jù)
*
* @param clazz 要啟動(dòng)的Activity
*/
protected void startActivity(Class<? extends BaseActivity> clazz) {
Intent intent = new Intent();
intent.setClass(this, clazz);
startActivity(intent);
}
@Override
protected void onDestroy() {
if (mCompositeSubscription != null) {
mCompositeSubscription.unsubscribe();
}
AppManager.getAppManager().finishActivity(this);
super.onDestroy();
}
/**
* 判斷觸摸時(shí)間派發(fā)間隔
*/
@Override
public boolean dispatchTouchEvent(MotionEvent ev) {
if (ev.getAction() == MotionEvent.ACTION_DOWN) {
if (FastDoubleClickUtils.isFastDoubleClick()) {
return true;
}
}
return super.dispatchTouchEvent(ev);
}
}
在onCreate方法中初始化了ContentView Dialog(即SVProgressHUD ) ButterKinfe的注冊(cè)等
重寫dispatchTouchEvent方法是為了防止用戶連續(xù)點(diǎn)擊。
startActivity方法是對(duì)intent跳轉(zhuǎn)頁面的封裝蜘矢。
看具體的activity 拿NickNameActivity來舉例這個(gè)Activity的功能是展示并修改用戶的昵稱
NickNameActivity
/**
* hepeng Created on 2016/10/20.
* 類名稱：
*/
public class NickNameActivity extends BaseActivity {
@BindView(R.id.et_nick_name)
ClearEditText vEtNickName;
@Inject
ApiService mApi;
private String oldNickName;
public static void startActivity(Context mContext, String nickName) {
Intent intent = new Intent(mContext, NickNameActivity.class);
intent.putExtra("nickName", nickName);
mContext.startActivity(intent);
}
@Override
public int initContentView() {
return R.layout.activity_nick_name;
}
@Override
public void initUiAndListener() {
setTitle("昵稱");
}
@Override
protected void initInjector() {
super.initInjector();
mActivityComponent.inject(this);
}
@Override
public void initData() {
oldNickName = getIntent().getStringExtra("nickName");
if (StringUtil.checkStr(oldNickName)) {
vEtNickName.setText(oldNickName);
vEtNickName.setSelection(vEtNickName.getText().toString().length());//設(shè)置光標(biāo)位置在文本框末尾
}
requestGetNickName();
}
private void requestGetNickName() {
HttpSubscriber<NickNameBean> subscriber = new HttpSubscriber<NickNameBean>() {
@Override
public void onNext(NickNameBean nickNameBean) {
if (nickNameBean != null) {
oldNickName = nickNameBean.nickname;
}
}
@Override
public void finish() {
}
};
Subscription subscription = mApi.queryMemberNickName(subscriber);
addSubscription(subscription);
}
@OnClick(R.id.btn_save)
public void onClick() {
if (checkInput()) {
requestChangeNickName();
}
}
private void requestChangeNickName() {
loading.showWithStatus();
HttpSubscriber<SuccessBean> subscriber = new HttpSubscriber<SuccessBean>() {
@Override
public void onNext(SuccessBean changeNickNameBean) {
EventBus.getDefault().post(new UserModifyEvent());
if (changeNickNameBean != null) {
if (StringUtil.checkStr(changeNickNameBean.sucmsg))
T.showShort(changeNickNameBean.sucmsg);
}
}
@Override
public void finish() {
loading.dismiss();
NickNameActivity.this.finish();
}
};
Subscription subscription = mApi.modifyNickName(subscriber, vEtNickName.getText().toString().trim());
addSubscription(subscription);
}
private boolean checkInput() {
if (vEtNickName.getText().toString().trim().equals("")) {
T.showShort(getString(R.string.tip_null_nick_name));
vEtNickName.setText("");
vEtNickName.requestFocus();
return false;
}
if (vEtNickName.getText().toString().trim().equals(oldNickName)) {
T.showShort("您還沒有修改過您的昵稱");
vEtNickName.requestFocus();
return false;
}
return true;
}
}
先是控件和ApiService的注入
@BindView(R.id.et_nick_name) ClearEditText vEtNickName;
@Inject ApiService mApi;
intent傳值方式狂男，實(shí)現(xiàn)了頁面之間的解耦
public static void startActivity(Context mContext, String nickName) {
Intent intent = new Intent(mContext, NickNameActivity.class);
intent.putExtra("nickName", nickName);
mContext.startActivity(intent);
}
其他頁面如過想啟動(dòng)這個(gè)Activity只需要在自身的點(diǎn)擊事件里加上就可以了
NickNameActivity.startActivity(this, nickName);
如果是不需要傳遞參數(shù)的啟動(dòng)用BaseActivity里封裝的，ps:這里只是舉個(gè)例子哈硼端，我這個(gè)頁面當(dāng)然是需要一個(gè)參數(shù)的并淋。
startActivity(NickNameActivity.class);
接下來的幾個(gè)方法分別是
initContentView
initUiAndListener
initInjector
initData
見名知意，我想就不用介紹了珍昨。
requestGetNickName和requestChangeNickName方法分別完成了一次網(wǎng)絡(luò)請(qǐng)求县耽。
一個(gè)頁面就這么愉快的結(jié)束了，并且線程很安全（addSubscription方法不要忘記調(diào)用镣典，線程安全的關(guān)鍵）兔毙。
BaseFragment和Activity很相似，我也不介紹了兄春。
Adapter 我用的是ComomAdapter 和CommonViewHolder (不知是哪位大神首創(chuàng)澎剥，寫的不錯(cuò)，拿來就用了)大家可以參考赶舆。
CommonViewHolder
public class CommonViewHolder {
private SparseArray<View> mViews;
private int mPosition;
private View mConvertView;
public CommonViewHolder( Context context, int layoutId, int position) {
this.mPosition = position;
this.mViews = new SparseArray<>();
this.mConvertView = LayoutInflater.from(context).inflate(layoutId,null);
mConvertView.setTag(this);
}
public static CommonViewHolder get(Context context,View convertView, ViewGroup parent, int layoutId, int postion) {
if (convertView == null) {
return new CommonViewHolder(context, layoutId, postion);
} else {
CommonViewHolder holder = (CommonViewHolder) convertView.getTag();
holder.mPosition = postion;
return holder;
}
}
/**
* 通過viewId獲取控件
*/
public <T extends View> T getView(int viewId) {
View view = mViews.get(viewId);
if (view == null) {
view = mConvertView.findViewById(viewId);
mViews.put(viewId, view);
}
return (T) view;
}
/**
* 返回下標(biāo)
*/
public int getPosition() {
return mPosition;
}
public View getConvertView() {
return mConvertView;
}
public CommonViewHolder setText(int viewId, String text) {
TextView tv = getView(viewId);
tv.setText(checkStr(text) ? text : "");
return this;
}
/**
* 設(shè)置顯示隱藏的方法
*/
public CommonViewHolder setVisible(int viewId, boolean isVisible) {
View view = getView(viewId);
if (isVisible){
view.setVisibility(View.VISIBLE);
}else {
view.setVisibility(View.GONE);
}
return this;
}
// 判斷字符串的合法性
public boolean checkStr(String str) {
if (null == str) {
return false;
}
if ("".equals(str.trim())) {
return false;
}
return true;
}
}
CommonAdapter
public abstract class CommonAdapter<T> extends BaseAdapter {
protected Context mContext;
protected List<T> mDatas;
protected int layoutId;
public CommonAdapter(int layoutId, Context mContext) {
this.layoutId = layoutId;
this.mContext = mContext;
}
public void bindData(List<T> data) {
mDatas = data;
notifyDataSetChanged();
}
public void addAll(List<T> datas) {
if (mDatas != null) {
mDatas.addAll(datas);
notifyDataSetChanged();
}
}
public void clear() {
if (mDatas != null) {
mDatas.clear();
notifyDataSetChanged();
}
}
public void remove(T data) {
if (mDatas != null && mDatas.contains(data)) {
mDatas.remove(data);
notifyDataSetChanged();
}
}
@Override
public int getCount() {
if (mDatas != null) {
return mDatas.size() > 0 ? mDatas.size() : 0;
}
return 0;
}
@Override
public T getItem(int position) {
if (mDatas != null) {
return mDatas.get(position);
}
return null;
}
@Override
public long getItemId(int position) {
return position;
}
public List<T> getData() {
return mDatas;
}
@Override
public View getView(int position, View convertView, ViewGroup parent) {
CommonViewHolder holder = CommonViewHolder.get(mContext, convertView, parent, layoutId, position);
convert(holder, mDatas.get(position));
return holder.getConvertView();
}
public abstract void convert(CommonViewHolder holder, T t);
}
用法
class StudyAdapter extends CommonAdapter<StudyBean> {
public StudyAdapter(Context mContext) {
super(R.layout.item_study, mContext);
}
@Override
public void convert(CommonViewHolder holder, StudyBean bean) {
if (bean != null) {
holder.setText(R.id.tv_study_title, bean.title);
holder.setText(R.id.tv_study_spell, bean.title_py);
GlideLoader.load(bean.logo_url, StudyActivity.this, holder.getView(R.id.iv_study_icon));
holder.getConvertView().setOnClickListener(
v -> WebViewActivity.startActivity(
StudyActivity.this, bean.title,
bean.url)
);
}
}
}
Utils包
Glide作為圖片加載也是好用的不行哑姚，之前用過ImageLoader和Picasso祭饭。Glide的介紹可以看Glide網(wǎng)站
這里我封裝了一個(gè)工具類，大家喜歡可以拿去用
/**
* hepeng Created on 2016/10/12.
* 類名稱：
*/
public class GlideLoader {
/**
* @param url url
* @param object must be Activity Fragment or Context
* @param imageView target
*/
public static void load(String url, Object object, ImageView imageView) {
if (object == null) {
return;
}
if (!StringUtil.checkStr(url)) {
return;
}
if (!url.contains("http")) {
url = Constants.M_IP + url;
}
if (object instanceof Fragment) {
Glide.with(((Fragment) object))
.load(url).into(imageView);
} else if (object instanceof Activity) {
Glide.with(((Activity) object))
.load(url).into(imageView);
} else if (object instanceof Context) {
Glide.with(((Context) object))
.load(url).into(imageView);
} else {
throw new RuntimeException("parameter exception");
}
}
}
舉一個(gè)在fragment中使用的例子
GlideLoader.load(bannersBean.image, HomeFragment.this, imageView);
關(guān)于utils好用的一大堆了叙量，下面列出個(gè)人的utils倡蝙，想用哪個(gè)網(wǎng)上收類名就好啦
總結(jié)
好吧，差不多已經(jīng)大致的介紹了一遍了绞佩。由于介紹用的是公司的項(xiàng)目不方便放出源碼寺鸥，還請(qǐng)見諒。
以后有什么經(jīng)驗(yàn)品山，我會(huì)繼續(xù)分享的胆建。
作者：流風(fēng)夜雪
郵箱：csycsy2510316@163.com
發(fā)布日期：2016-11-16
更新日期：2016-11-21
版權(quán)聲明：禁止轉(zhuǎn)載，歡迎交流肘交。
附錄
MVP項(xiàng)目地址1：GeekNews
MVP項(xiàng)目地址2：TLint for 虎撲體育 基于Dagger2+RxJava+Retrofit開發(fā)
