承接上篇從零開始的Android新項目5 - Repository層(上) Retrofit么伯、Repository組裝疟暖，本文繼續(xù)介紹Realm、緩存，以及統(tǒng)一的異常處理設(shè)計俐巴。
Realm
Realm在移動端數(shù)據(jù)庫中也算是比較有名的一款了骨望，以其跨平臺和驚人的速度而聞名。啊欣舵，對了擎鸠，還有文檔多。
這里要黑的就是文檔問題邻遏，Realm雖然乍一看文檔很多糠亩，但是老實說，寫的挺亂的准验。不過總體來說赎线，實踐和應(yīng)用中感覺還不錯，性能好糊饱，也比較方便垂寥，比起不穩(wěn)定的DBFlow和麻煩至極的GreenDao來好了太多了，唯一的美中不足就是so比較大另锋，會增大包的體積1MB滞项。
引入
從Realm 0.90開始，用法與之前有了改變：
在root的build.gralde中:
buildscript {
repositories {
jcenter()
}
dependencies {
classpath "io.realm:realm-gradle-plugin:0.90.1"
}
}
然后在對應(yīng)需要應(yīng)用到Realm的夭坪，比如data module的build.gradle:
apply plugin: 'realm-android'
即可使用Realm文判。
使用
使用起來也很方便，比如我們想要緩存用戶的信息
public class UserPo extends RealmObject {
@PrimaryKey
public String id;
public String name;
public String headerUrl;
public long updateTime;
}
這樣就對應(yīng)了一個表室梅，其主鍵為id戏仓，另外有3列name, headerUrl, 以及updateTime。
如果想要查詢亡鼠，只需要：
UserPo user = getRealm().where(UserPo.class)
.equalTo("id", userId)
.findFirst();
如果要寫入一條記錄：
User user = new UserPo();
user.setName(userInfoEntity.getNickName());
user.setId(userInfoEntity.getUserId());
user.setHeaderUrl(userInfoEntity.getHeaderImageUrl());
user.setUpdateTime(System.currentTimeMillis());
getRealm().beginTransaction();
getRealm().copyToRealmOrUpdate(user);
getRealm().commitTransaction();
就是這么簡單赏殃。
如果想要直接和Retrofit一起應(yīng)用，去進(jìn)行串行化间涵，可以參考該Gist仁热。
// 結(jié)合 Realm, Retrofit 和 RxJava (使用了Retrolambda以簡化符號)的例子。
// 讀取所有Person勾哩，然后與從GitHub獲取的最新狀態(tài)merge到一起
Realm realm = Realm.getDefaultInstance();
GitHubService api = retrofit.create(GitHubService.class);
realm.where(Person.class).isNotNull("username").findAllAsync().asObservable()
.filter(persons.isLoaded)
.flatMap(persons -> Observable.from(persons))
.flatMap(person -> api.user(person.getGithubUserName())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(user -> showUser(user));
更多詳情可以去官網(wǎng)看抗蠢，migration/relationship等等支持應(yīng)有盡有，我只能說思劳，文檔實在太長太長了迅矛。
內(nèi)存
內(nèi)存，也就是直接使用變量存儲在對應(yīng)repository中敢艰，如果非空則優(yōu)先直接返回內(nèi)存中的變量诬乞。
LruCache
LruCache限定了最大的entry數(shù)量册赛，近期最少使用算法保證了淘汰機(jī)制的合理性钠导。使用場景如用戶信息緩存震嫉，會淘汰那些最近沒有訪問過的用戶的信息緩存。使用可參考Google官網(wǎng)：LruCache牡属。
變量存儲
變量存儲很簡單票堵，直接在Repository實現(xiàn)類中直接變量存儲上一次的返回結(jié)果，在下一次請求的時候優(yōu)先使用內(nèi)存緩存逮栅。使用場景如請求后直接刷新本地的變量悴势，下次調(diào)用repository方法使用啊concat先返回內(nèi)存里的變量，然后再使用網(wǎng)絡(luò)數(shù)據(jù)進(jìn)行刷新措伐。
統(tǒng)一異常處理
作為Repository層特纤，本身不會，也不應(yīng)該去處理任何異常和錯誤（比如請求的錯誤碼）侥加，一切都將作為Exception異常拋給上層去做統(tǒng)一處理捧存，而RxJava的onError機(jī)制也幫助我們能優(yōu)雅地去做這件事。
Observable.error
類似在上一篇中提到的方法担败，我們可以使用Observable.error返回異常昔穴，供上層根據(jù)該異常做對應(yīng)處理。無論是網(wǎng)絡(luò)異常提前，數(shù)據(jù)庫異常吗货，亦或是服務(wù)器response異常等等，都可以進(jìn)行分類創(chuàng)建對應(yīng)的Exception類狈网，拋給上層宙搬。
public static <T> Observable<T> extractData(Observable<MrResponse> observable, Class<T> clazz) {
return observable.flatMap(response -> {
if (response == null) {
return Observable.error(new NetworkConnectionException());
} else if (response.getStatusCode() == ResponseException.STATUS_CODE_SUCCESS) {
return Observable.just(mGson.fromJson(mGson.toJson(response.data), clazz));
} else {
Logger.e(TAG, response.data);
return Observable.error(new ResponseException(response));
}
});
}
Subscriber.onError
我們使用Subscriber的基類來處理通用錯誤，其他所有Subscriber繼承它:
public class MrSubscriber<T> extends DefaultSubscriber<T> {
@Override
public void onError(Throwable e) {
super.onError(e);
if (!handleCommonResponseError((Exception) e)) {
if (e != null && e.getMessage() != null) {
Logger.w(TAG, e.getMessage());
}
showErrorMessage(new DefaultErrorBundle((Exception) e));
}
}
}
protected void showErrorMessage(ErrorBundle errorBundle) {
String errorMessage = ErrorMessageFactory.create(this, errorBundle.getException());
showErrorMessage(errorMessage);
}
protected void showErrorMessage(String errorMessage) {
ToastUtils.show(this, errorMessage);
}
DefaultErrorBundle是exception的wrapper孙援，管理了其錯誤害淤。
public class DefaultErrorBundle implements ErrorBundle {
private static final String DEFAULT_ERROR_MSG = "Unknown error";
private final Exception exception;
public DefaultErrorBundle(Exception exception) {
this.exception = exception;
}
@Override
public Exception getException() {
return exception;
}
@Override
public String getErrorMessage() {
return (exception != null) ? this.exception.getMessage() : DEFAULT_ERROR_MSG;
}
}
ErrorMessageFactory是錯誤消息工廠，根據(jù)exception創(chuàng)建對應(yīng)的錯誤消息提示拓售，讓用戶不至于碰到錯誤莫名其妙窥摄。
/**
* Factory used to create error messages from an Exception as a condition.
*/
public class ErrorMessageFactory {
private static final String TAG = "ErrorMessageFactory";
private ErrorMessageFactory() {
//empty
}
/**
* Creates a String representing an error message.
*
* @param context Context needed to retrieve string resources.
* @param exception An exception used as a condition to retrieve the correct error message.
* @return {@link String} an error message.
*/
public static String create(Context context, Exception exception) {
if (StringUtils.isNotEmpty(exception.getMessage())) {
Logger.e(TAG, exception.getMessage());
}
String message = context.getString(R.string.exception_message_generic);
if (exception instanceof NetworkConnectionException) {
message = context.getString(R.string.exception_message_no_connection);
} else if (exception instanceof NotFoundException) {
message = context.getString(R.string.exception_message_not_found);
} else if (exception instanceof ResponseException) {
message = exception.getMessage();
} else if (exception instanceof HttpException) {
message = exception.getMessage();
}
return message;
}
}
handleCommonResponseError
通常，服務(wù)器會返回錯誤信息础淤，我們需要根據(jù)一些code進(jìn)行對應(yīng)處理崭放，MrSubscriber的onError就調(diào)用了handleCommonResponseError來處理這些通用錯誤：
protected boolean handleCommonResponseError(Exception exception) {
boolean handled = false;
if (exception instanceof ResponseException) {
ResponseException responseException = (ResponseException) exception;
switch (responseException.getStatusCode()) {
case ResponseException.ERROR_CODE_NEED_LOGIN:
handled = true;
getUserSystem().setVuser("");
getNavigator().navigateToLoginPage(this);
break;
case ResponseException.ERROR_CODE_NEED_PERFECT_PROFILE:
handled = true;
if (responseException.getVuser() != null) {
getUserSystem().setVuser(responseException.getVuser().getVuser());
}
getNavigator().navigateToPerfectProfile(this);
break;
case ResponseException.ERROR_CODE_NEED_THIRD_PARTY_BIND:
handled = true;
getNavigator().navigateToThirdPartyBind(this);
break;
}
}
return handled;
}
Log & 上報
出錯了當(dāng)然要上報啦，bugly鸽凶、友盟币砂，本地寫文件打zip包上傳，Logger做的就是寫文件log了玻侥，這些常見的app都會去做决摧，這里就不贅述了。
總結(jié)和下集預(yù)告
本系列兩篇文章描述了Android項目中，Repository層的設(shè)計與實現(xiàn)掌桩，也可以理解它為data或者model層边锁。一個好的Repository層和上層相對獨(dú)立，內(nèi)聚完成業(yè)務(wù)邏輯的數(shù)據(jù)部分波岛，即便內(nèi)部有修改茅坛，比如添加了緩存，對外仍然保持一致则拷。而好的異常處理設(shè)計一方面讓代碼中不會充斥著雜七雜八的 try & catch贡蓖，另一方，恰當(dāng)?shù)腻e誤展示也讓用戶知道究竟出了什么錯煌茬，不至于莫名其妙斥铺。
下一次不知是何時相見，希望能為大家?guī)砦覀冺椖恐惺褂肦eact Native進(jìn)行混合開發(fā)的苦與甜坛善。
另外仅父，打個小廣告，本司的新產(chǎn)品Crew已經(jīng)在各大Android應(yīng)用市場上線浑吟，專注于職場垂直社交笙纤。一搜和興趣相投的人聊天。iOS版本正在審核中组力。
2個字找到志趣相投的職場伙伴省容，秒搜陌生人同類，智能自動破冰燎字。多關(guān)鍵字疊加腥椒，高效率鎖定職場同僚。精準(zhǔn)匹配興趣對象候衍，超輕聊天笼蛛，更能一鍵組建群聊，加入一群人的狂歡蛉鹿。
demo沒空寫了滨砍，反正我也沒混淆，直接反編譯來黑我吧妖异。哈哈惋戏。有bug或者功能上的意見建議歡迎直接反饋給我。
