android - rxjava merge 返回Object對象數據如何緩存
問題描述
使用 rxjava 的 merge 方法將兩個 api 返回的數據對象結合得到 Object,然后我想使用 SharedPreferences 方法緩存Object。
我嘗試按照網上的方法保存Objcet,卻沒有效果。請大伙幫忙看看。
Bean:
public class LifeSuggestionResult implements Serializable{ ... }public class WeatherFuture implements Serializable { ... }
ObjectUtil( 使用 SharedPreferences 保存和獲取 Object):
public class ObjectUtil { public static void setObject(String key, Object object, Context context) {SharedPreferences.Editor editor = PreferenceManager.getDefaultSharedPreferences(context).edit();ByteArrayOutputStream baos = new ByteArrayOutputStream();ObjectOutputStream out = null;try { out = new ObjectOutputStream(baos); out.writeObject(object); String objectVal = new String(Base64.encode(baos.toByteArray(), Base64.DEFAULT)); editor.putString(key, objectVal); editor.commit();} catch (IOException e) { e.printStackTrace();} finally { try {if (baos != null) { baos.close();}if (out != null) { out.close();} } catch (IOException e) {e.printStackTrace(); }} } public static <T> T getObject(String key, Context context) {SharedPreferences sp = PreferenceManager.getDefaultSharedPreferences(context);if (sp.contains(key)) { String objectVal = sp.getString(key, null); byte[] buffer = Base64.decode(objectVal, Base64.DEFAULT); ByteArrayInputStream bais = new ByteArrayInputStream(buffer); ObjectInputStream ois = null; try {ois = new ObjectInputStream(bais);T t = (T) ois.readObject();return t; } catch (StreamCorruptedException e) {e.printStackTrace(); } catch (IOException e) {e.printStackTrace(); } catch (ClassNotFoundException e) {e.printStackTrace(); } finally {try { if (bais != null) {bais.close(); } if (ois != null) {ois.close(); }} catch (IOException e) { e.printStackTrace();} }}return null; }}
rxjava部分:
public void getCurrentWeather(final String city) {Observable<WeatherFuture> weatherFutureObservable = new WeatherService().getFutureWeather(city, 'zh-Hans', 'c');Observable<LifeSuggestionResult> lifeSuggestionResultObservable = new WeatherService().getAirQuality(city, 'zh-Hans', 'city');Observable.merge(weatherFutureObservable, lifeSuggestionResultObservable).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<Object>() { @Override public void onCompleted() { } @Override public void onNext(Object o) {setWeatherInfo(o); } @Override public void onError(Throwable e) { }}); } public void setWeatherInfo(Object o) { if (o instanceof WeatherFuture) { ObjectUtil.setObject('WeatherFuture', o, MainActivity.this); ... }} else if (o instanceof LifeSuggestionResult) { ObjectUtil.setObject('LifeSuggestion', o, MainActivity.this); ... }
問題解答
回答1:給你一個思路,使用排除法1、在其他地方單獨使用ObjectUtil,看是否可以存儲和取出一個假數據Object2、在onNext中打印出Object的內容,看是否是預期的Object3、假如兩者都沒問題,那就看你的setWeatherInfo方法是否有問題
相關文章:
1. javascript - 如何使用nodejs 將.html 文件轉化成canvas2. 如何解決docker宿主機無法訪問容器中的服務?3. angular.js - 輸入郵箱地址之后, 如何使其自動在末尾添加分號?4. javascript - Web微信聊天輸入框解決方案5. 在mac下出現了兩個docker環境6. javascript - 后臺管理系統左側折疊導航欄數據較多,怎么樣直接通過搜索去定位到具體某一個菜單項位置,并展開當前菜單7. java如何生成token?8. python - Scrapy存在內存泄漏的問題。9. CSS3 畫如下圖形10. angular.js - $stateChangeSuccess事件在狀態跳轉的時候不執行?
