如何解决在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 举报,一经查实,本站将立刻删除。