0

我在 Xamarin 应用程序中使用 Akavache 有以下代码，但它的行为不像我认为的那样。可能是我对它应该是怎样的误解，但这让我发疯。

因此，在我的视图模型中，我正在调用 FetchNewsCategories 并为该项目指定 5 分钟的缓存。我期望发生的是，如果缓存项不存在，它将调用 fetchFunc（即 FetchNewsCategoriesAsync），但如果我在 5 分钟的缓存超时内多次调用该服务，它应该只给我缓存的项目而不是服务器调用。在我尝试过的所有情况下，它都会继续进行其余调用，并且永远不会给我缓存的项目。我也用 GetAndFetchLatest 试过这个，如果有一个缓存的项目，它不会进行其余的调用，但它也不会在视图模型的订阅事件中进行调用。有什么想法我在这里做错了吗？

编辑：我在 Android (Nexus 5 KitKat API19) 上测试了相同的代码，它运行完美。我要重置我的 IOS 模拟器，看看是不是出了问题。

新闻服务.cs

public static async Task<ServiceResponse<List<ArticleCategoryInfo>>> FetchNewsCategoriesAsync(BlogSourceType blogSource)
    {
        return await ServiceClient.POST<List<ArticleCategoryInfo>>(Config.ApiUrl + "news/categories", new
        {
            ModuleId = Int32.Parse(Config.Values[blogSource == BlogSourceType.News ? ConfigKeys.KEY_NEWS_MODULE_ID : ConfigKeys.KEY_BLOG_MODULE_ID])
        });
    }

public static IObservable<ServiceResponse<List<ArticleCategoryInfo>>> FetchNewsCategories(BlogSourceType blogSource)
    {
        var cache = BlobCache.LocalMachine;
        var cachedCategories = cache.GetOrFetchObject("categories" + blogSource,
                    async () => await FetchNewsCategoriesAsync(blogSource),
                    DateTime.Now.AddMinutes(5));

        return cachedCategories;
    }

NewsViewModel.cs

public async Task LoadCategories()
{
var cachedCategories = NewsService.FetchNewsCategories(blogSource);

cachedCategories.Subscribe((obj) => { Device.BeginInvokeOnMainThread(() => DisplayCategories(obj.Result,"Subscribe"));});
return;
}

private void DisplayCategories(IList<ArticleCategoryInfo> categories, string source)
    {
        Categories.Clear();
        System.Diagnostics.Debug.WriteLine("Redisplaying categories from " + source);
        foreach (var item in categories)
        {
            Categories.Add(item);
        }
    }
4

1 回答 1

0

只是想将我的解决方案添加到我上面遇到的问题中，以供有此问题的其他人参考。

ServiceResponse我试图缓存的对象中有一个HttpResponseMessage我怀疑导致序列化错误的对象，可能是循环引用，因此它从未被缓存并最终每次都调用端点。我最终在那个属性上放了一个[IgnoreDataMemberAttribute]，所以它没有被序列化，问题就消失了。

我最终以以下方式处理订阅以处理错误并确保绑定到IsBusy属性的活动指示器已正确更新。

public async Task LoadActivities(bool refresh)
    {

        IsBusy = true;

        if (refresh) OlderThanJournalId = int.MaxValue;

        var cached = ActivityService.FetchJournalItems(GroupId, OlderThanJournalId, refresh);

        cached.Subscribe((result) => { Device.BeginInvokeOnMainThread(() => { 
            DisplayActivities(result); 
        }); }, (err) => HandleError(err), () => IsBusy = false);

    }

public void HandleError(Exception ex) {
        IsBusy = false;
        DialogService.ShowErrorToast(AppResources.ErrorMessage, "Unable to load activity stream.");
        System.Diagnostics.Debug.WriteLine(ex.Message);
    }

private void DisplayActivities(ServiceResponse<List<JournalItem>> response)
    {
        if (!response.IsConnected) {
            DialogService.ShowInfoToast(AppResources.ErrorMessage, AppResources.NotConnected);
            return;
        }
        if (!response.Authorized) {
            App.LoginManager.Logout();
        }
        Activities.Clear();
        foreach (var item in response.Result)
        {
            Activities.Add(item);
        }
    }

BeginInvokeOnMainThread用于确保在 UI 中可以看到 DisplayActivities 中的 ObservableCollection 的更新。

于 2016-11-10T16:00:19.513 回答