专栏首页圣杰的专栏Orleans 知多少 | 4. 有状态的Grain

Orleans 知多少 | 4. 有状态的Grain

引言

Orleans 的优势之一就是:支持有状态服务的水平扩展。那这一节我们就来看看如何来了解下有状态的Grain。

第一个有状态的Grain

先来看下上节中定义的Grain:SessionControlGrain

public class SessionControlGrain : Grain, ISessionControlGrain
{
    private List<string> LoginUsers { get; set; } = new List<string>();

    public Task Login(string userId)
    {
        //获取当前Grain的身份标识(因为ISessionControlGrain身份标识为string类型,GetPrimaryKeyString());
        var appName = this.GetPrimaryKeyString();

        LoginUsers.Add(userId);

        Console.WriteLine($"Current active users count of {appName} is {LoginUsers.Count}");
        return Task.CompletedTask;
    }

    public Task Logout(string userId)
    {
        //获取当前Grain的身份标识
        var appName = this.GetPrimaryKey();
        LoginUsers.Remove(userId);

        Console.WriteLine($"Current active users count of {appName} is {LoginUsers.Count}");
        return Task.CompletedTask;
    }

    public Task<int> GetActiveUserCount()
    {
        return Task.FromResult(LoginUsers.Count);
    }
}

上面的Grain中定义属性private List<string> LoginUsers { get; set; } = new List<string>();用来保存登录状态,其是保存在内存中的,一旦服务奔溃或重启,维护的状态数据就会丢失。 很显然,这在真实应用场景中不被允许。

在第一节中,已经对有状态和无状态有了解释,关键的区别在于:状态数据的是否持久化。因此上面针对ISessionControlGrain的实现SessionControlGrain是无状态的。

那接下来就来看看如何用有状态的Grain来实现!

针对统计登录用户的需求来说,其中的状态数据就是在线用户列表,所以可以直接定义一个LoginState来将行为和数据解耦。

/// <summary>
/// 登录状态
/// </summary>
public class LoginState
{
    public List<string> LoginUsers { get; set; } = new List<string>();

    public int Count => LoginUsers.Count;
}

紧接着就可以重新实现一个ISessionControlGrain,如下:

/// <summary>
/// 有状态的Grain
/// </summary>
public class SessionControlStateGrain : Grain<LoginState>, ISessionControlGrain
{
    public Task Login(string userId)
    {
        var appName = this.GetPrimaryKeyString();
        this.State.LoginUsers.Add(userId);
        this.WriteStateAsync();

        Console.WriteLine($"Current active users count of {appName} is {this.State.Count}");
        return Task.CompletedTask;
    }

    public Task Logout(string userId)
    {
        //获取当前Grain的身份标识
        var appName = this.GetPrimaryKey();
        this.State.LoginUsers.Remove(userId);
        this.WriteStateAsync();

        Console.WriteLine($"Current active users count of {appName} is {this.State.Count}");
        return Task.CompletedTask;
    }

    public Task<int> GetActiveUserCount()
    {
        return Task.FromResult(this.State.Count);
    }
}

对比两个Grain的实现,有状态的Grain主要有以下变化:

  1. 继承自Grain<T>,其中T用来指定当前Grain的附属状态对象。
  2. Grain中通过this.State来操作状态
  3. 通过调用this.WriteStateAsync();来显式持久化状态。

那Grain的状态保存到哪里去了呢?

Grain 状态仓库(Grain Storage)

持久化方式

开发环境下,可使用内存作为Grain的状态仓库。仅需在构建Orleans Silo时配置AddMemoryGrainStorageAsDefault()即可,如下所示:

return Host.CreateDefaultBuilder()
    .UseOrleans((builder) =>
        {
            builder.UseLocalhostClustering()
                .AddMemoryGrainStorageAsDefault()
                .Configure<ClusterOptions>(options =>
                {
                    options.ClusterId = "Hello.Orleans";
                    options.ServiceId = "Hello.Orleans";
                })
                .Configure<EndpointOptions>(options => options.AdvertisedIPAddress = IPAddress.Loopback)
                .ConfigureApplicationParts(parts =>
                    parts.AddApplicationPart(typeof(ISessionControlGrain).Assembly).WithReferences());
        }
    )

存在内存中,只是为了方便开发,显然在生产环境中是万万不可的。因此,可选择其他存储介质进行持久化。比如数据库等,Orleans 官方维护的状态持久化提供者有以下几种:

当然除此之外,社区也维护系列开源项目支持将状态数据持久化到其他介质。 接下来就来讲解如何持久化状态数据到SQL Server 数据库。

持久化到 SQL Server

SqlServer的配置并没有想象的那样简单,根据官方文档: Configuring ADO.NET ProvidersADO.NET Database Configuration,你会发现需要执行以下几步:

  1. Orleans Server 端添加对Microsoft.Orleans.Persistence.AdoNet NuGet包的引用
  2. 添加SQL Server 客户端驱动System.Data.SqlClient NuGet包的引用
  3. 创建SQL Server数据库,可使用VS 自带的localdb。
  4. 依次执行以下脚本,SQLServer-Main.sqlSQLServer-Persistence.sql 创建用于存储相关状态表。
  5. 添加配置代码

为了简化配置,我做了一个简单的包装项目Orleans.AdoNet.Extensions,以简化SqlServer、MySql、Oracle和PostgreSql 的配置。以Sql Server 为例,仅需:

  1. 通过Nuget包管理器安装Orleans.AdoNet.SqlServer
  2. 安装后会打开一个readme.txt,复杂全部,并执行到数据库
  3. 服务端添加以下配置即可。
Host.CreateDefaultBuilder()
    .UseOrleans((builder) =>
     {
         var connectionString =
             @"Data Source=(localdb)\MSSQLLocalDB;Initial Catalog=Hello.Orleans;Integrated Security=True;Pooling=False;Max Pool Size=200;MultipleActiveResultSets=True";
         
        //use AdoNet for Persistence
        builder.AddSqlServerGrainStorageAsDefault(options =>
        {
            options.ConnectionString = connectionString;
            options.UseJsonFormat = true;
        }); 

重新运行项目,查询数据库,你会发现状态数据,实际上是持久化到Storage表中了。如下图所示:

代码已上传至stategrain:Orleans/Hello.Orleans

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Orleans 知多少 | 2. 核心概念一览

    上面已经提到,Grain是Virtual Actor的具体表现。那如何理解Grain呢。

    Edison.Ma
  • Orleans 知多少 | 2. 核心概念一览

    上面已经提到,Grain是Virtual Actor的具体表现。那如何理解Grain呢。

    圣杰
  • Orleans 知多少 | 3. Hello Orleans

    是的,Orleans v3.0.0 已经发布了,并已经完全支持 .NET Core 3.0。 所以,Orleans 系列是时候继续了,抱歉,让大家久等了。 ...

    圣杰
  • 【翻译】Orleans 3.0 发布

    这是Orleans团队的帖子。Orleans是用于使用.NET构建分布式应用程序的跨平台框架。有关更多信息,请参见 https://github.com/dot...

    HueiFeng
  • Orleans 3.0 为我们带来了什么

    原文:https://devblogs.microsoft.com/dotnet/orleans-3-0/

    Edison.Ma
  • .NET分布式框架 | Orleans 知多少

    公司物联网项目集成Orleans以支持高并发的分布式业务,对于Orleans也是第一次接触,本文就分享下个人对Orleans的理解。

    Edison.Ma
  • 容灾与集群(1)

    在上一篇:微软分布式云计算框架Orleans(1):Hello World,我们大概了解了Orleans如何运用,当然上一篇的例子可以说是简单且无效的,...

    逸鹏
  • Newbe.Claptrap 框架入门,第四步 —— 利用 Minion,商品下单

    接上一篇 Newbe.Claptrap 框架入门,第三步 —— 定义 Claptrap,管理商品库存 ,我们继续要了解一下如何使用 Newbe.Claptrap...

    newbe36524
  • Newbe.Claptrap 框架入门,第三步 —— 定义 Claptrap,管理商品库存

    接上一篇 Newbe.Claptrap 框架入门,第二步 —— 简单业务,清空购物车 ,我们继续要了解一下如何使用 Newbe.Claptrap 框架开发业务。...

    newbe36524
  • Orleans 知多少 | Orleans 中文文档上线

    Orleans建立在.NET开发人员生产力的基础上,并将其带入了分布式应用程序的世界,例如云服务。 Orleans可从单个本地服务器扩展到云中全局分布的高可用性...

    圣杰
  • 十万同时在线用户,需要多少内存?——Newbe.Claptrap 框架水平扩展实验

    Newbe.Claptrap 项目是笔者正在构建以反应式、Actor模式和事件溯源为理论基础的一套服务端开发框架。本篇我们将来了解一下框架在水平扩展方面的能力。

    newbe36524
  • Newbe.Claptrap 框架入门,第二步 —— 简单业务,清空购物车

    接上一篇 Newbe.Claptrap 框架入门,第一步 —— 创建项目,实现简易购物车 ,我们继续要了解一下如何使用 Newbe.Claptrap 框架开发业...

    newbe36524
  • .NET分布式大规模计算利器-Orleans(一)

    Orleans是基于Actor模型思想的.NET领域的框架,它提供了一种直接而简单的方法来构建分布式大规模计算应用程序,而无需学习和应用复杂的并发或其他扩展模式...

    Edison.Ma
  • 一起用HTML5 canvas做一个简单又骚气的粒子引擎

    这个简单的引擎里需要有三种元素:世界(World)、发射器(Launcher)、粒子(Grain)。总得来说就是:发射器存在于世界之中,发射器制造粒子,世界和发...

    Jation
  • 一起用 HTML5 Canvas 做一个简单又骚气的粒子引擎

    前言 好吧,说是“粒子引擎”还是大言不惭而标题党了,离真正的粒子引擎还有点远。废话少说,先看 Demo:http://ol.weixin.qq.com/publ...

    腾讯Bugly
  • 关于版权行业的现状你知道多少?又有多少是你不知道的?

    小墨第一次对版权这个东西有认知的时候,大概是在学生时代的高中阶段,那时候语文老师要求每个同学都必备一本《中国汉语词典》,第一次听闻这部词汇巨作的小墨不大能理解这...

    墨者安全科技
  • .NET的Actor模型:Orleans

    Orleans是微软推出的类似Scala Akka的Actor模型,Orleans是一个建立在.NET之上的,设计的目标是为了方便程序员开发需要大规模扩展的云服...

    张善友
  • Dapr Actor 的微服务架构

    Dapr中的Actor模型,和Orleans的Virtual Actor一脉相传, 圣杰写过一篇文章Orleans 知多少 | .NET Core 分布式框架介...

    张善友
  • Flurry 分析 API 中文教程(Flurry Analytics API)

    API 地址:https://api-metrics.flurry.com/public/v1/data/

    他叫自己MR.张

扫码关注云+社区

领取腾讯云代金券