ToB企服应用市场:ToB评测及商务社交产业平台

标题: .NET分布式Orleans - 5 - 持久化 [打印本页]

作者: 嚴華 时间: 2024-5-15 13:03
标题: .NET分布式Orleans - 5 - 持久化
在分布式体系中，数据的持久化是至关重要的一环。
Orleans 7 引入了强大的持久化功能，使得在分布式环境下管理数据变得更加轻松和可靠。
本文将先容什么是 Orleans 7 的持久化，如何设置它以及相应的代码示例。
什么是 Orleans 7 的持久化？

Orleans 7 的持久化是指将 Orleans 中的状态数据持久化到外部存储介质，以便在应用步伐重新启动或节点故障时能够恢复数据。
这对于构建可靠的分布式体系至关重要，由于它确保了数据的持久性和同等性。
持久化使得 Orleans 可以在不丢失数据的情况下处理节点故障或应用步伐的重新启动。
它还可以用于支持扩展性和负载均衡，由于数据可以在集群中的差别节点上进行分布式存储。
Orleans 7 的持久化怎么设置？

持久化目前支持以下数据库：

SQL Server
MySQL/MariaDB
PostgreSQL
Oracle

我们拿SQL Server举例，首先必要安装基础包

Install-Package Microsoft.Orleans.Persistence.AdoNet

复制代码

按照以下链接，创建对应的数据库表
https://learn.microsoft.com/zh-cn/dotnet/orleans/host/configuration-guide/adonet-configuration
并进行ADO.NET配置

var invariant = "System.Data.SqlClient";
var connectionString = "Data Source=localhost\\SQLEXPRESS;Initial Catalog=orleanstest;User Id=sa;Password=1234;";
// Use ADO.NET for clustering
siloHostBuilder.UseAdoNetClustering(options =>
{
options.Invariant = invariant;
options.ConnectionString = connectionString;
}).ConfigureLogging(logging => logging.AddConsole()); ;
siloHostBuilder.Configure<ClusterOptions>(options =>
{
options.ClusterId = "my-first-cluster";
options.ServiceId = "SampleApp";
});
// Use ADO.NET for persistence
siloHostBuilder.AddAdoNetGrainStorage("GrainStorageForTest", options =>
{
options.Invariant = invariant;
options.ConnectionString = connectionString;
});

复制代码

如何利用

可利用IPersistentState 的实例作为构造函数参数注入到 grain 中。
并可以利用 PersistentStateAttribute 属性批注这些参数，以标识要注入的状态的名称，以及提供该状态的存储提供步伐的名称。

public class ProfileState
{
public string Name { get; set; }
public Date DateOfBirth { get; set; }
}
public interface IUserGrain : IGrainWithStringKey
{
Task<string> GetNameAsync();
Task SetNameAsync(string name);
}
public class UserGrain : Grain, IUserGrain
{
private readonly IPersistentState<ProfileState> _profile;
public UserGrain([PersistentState("profile", "GrainStorageForTest")] IPersistentState<ProfileState> profile)
{
_profile = profile;
}
public async Task<string> GetNameAsync()
{
await _profile.ReadStateAsync();
return await Task.FromResult(_profile.State.Name);
}
public async Task SetNameAsync(string name)
{
_profile.State.Name = name;
await _profile.WriteStateAsync();
}
}

复制代码

也可以利用Grain 为 grain 添加存储

[StorageProvider(ProviderName="store1")]
public class MyGrain : Grain<MyGrainState>, /*...*/
{
/*...*/
}

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)