在Azure Service Fabric中启动有状态服务时加载和使用数据

问题描述

我正在创建一个包含3个服务，两个无状态服务（stateless1和stateless2）和一个有状态（有状态）服务的Azure Service Fabric应用。

有状态服务具有3个分区。

有状态服务应在启动时通过调用stateless1来加载数据，具体取决于分区号。当stateless2调用有状态时，应从该分区的IReliableDictionary中获取数据并返回。

所有示例都显示了如何在有状态控制器中进行GetorAddAsync IReliableDictionary。

我尝试了以下操作：

• 我尝试在stateful.cs中初始化IReliableDictionary。我收到一个空指针异常。
• 我在有状态的startup.cs中尝试过。我收到Statemanger不可读的错误。
• 我还重写了RunAsync并初始化了字典。字典正在正确加载。但是当我在控制器中找到字典时，它是空的。

stateful.cs中的代码是

protected override async Task RunAsync(CancellationToken cancellationToken)
{

    var wsDictionary = await this.StateManager.GetorAddAsync<IReliableDictionary<string,string>>("mydictionary");

    Uri serviceName = new Uri($"{Context.CodePackageActivationContext.ApplicationName}/Stateless1");
    Uri proxyAddress = this.GetProxyAddress(serviceName);
    string PartitionName = await GetPartitionName();
    string proxyUrl = $"{proxyAddress}/api/PartitionInfo/Partition/{PartitionName}/GetEntries";
    StringContent content = new StringContent($"{{'name' : '{PartitionName}'}}",Encoding.UTF8,"application/json");
    content.Headers.ContentType = new MediaTypeHeaderValue("application/json");
    using (HttpResponseMessage response = await httpClient.GetAsync(proxyUrl))
    {
        List<string> entries= await response.Content.ReadAsAsync<List<string>>();
        CancellationToken ct = new CancellationToken();
        using (ITransaction tx = this.StateManager.CreateTransaction())
        {
            foreach (string entry in entries)
            {
                await wsDictionary.AddOrUpdateAsync(tx,entry,(key,value) => value);
                var result = await wsDictionary.TryGetValueAsync(tx,entry);
                ServiceEventSource.Current.ServiceMessage(this.Context,"ENtry for Partition {0} is {1}",PartitionName,result.HasValue ? result.Value.ToString() : "No Entry found");
            }
        }
    }
}

控制器中的代码为

CancellationToken ct = new CancellationToken();
IReliableDictionary<string,string> wsDictionary = await this.StateManager.GetorAddAsync<IReliableDictionary<string,string>>("mydictionary");
using (ITransaction tx = this.StateManager.CreateTransaction())
{
    
    if (await wsDictionary.ContainsKeyAsync(tx,name))
    {
        List<keyvaluePair<string,string>> kvpList = new List<keyvaluePair<string,string>>()
        {
            new keyvaluePair<string,string>(name,"name exists")
        };
        return this.Json(kvpList);
    }
    else
    {
        return null;
    }
}

什么是错误以及如何纠正？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）