1.Actor编写

Wesley13
• 阅读 713
ESGrain
生命周期

Ray中ESGrain继承自Grain扩展了Grain的生命周期。Grain的生命周期参见文档附录:1-Grain生命周期-译注.md

ESGrain重写了Grain的OnActivateAsync方法。ESGrain的初始化过程如下:

  • 初始化ESGrain中的State
    • 调用ReadSnapshotAsync()读快照。
    • 如果没有获得快照,调用InitState()根据InitState()中代码初始化ESGrain,InitState()是虚方法,可以被具体的ESGrain重写,以自定义初始化。
  • 读取事件库,重放事件,获得最新的State。

1.Actor编写


小技巧:在实际开发中,可以重写InitState(),在其中根据关系型数据库中的数据自定义state的初始化。


使用
  1. State

    ESGrain的数据存储在State中,当ESGrain被激活后State数据存储在内存中,持久化会存储为快照。定义ESGrain时,需要定义State,实现IState接口,序列化默认使用protocol buffer,State类要添加protocol buffer特性。IState接口定义的是State的基础部分,即示例中的base部分,base之外的是当前actor需要的要存储的数据。

    示例代码:

     [ProtoContract(ImplicitFields = ImplicitFields.AllFields)]
     public class AccountState : IState<string>
     {
         #region base
         public string StateId { get; set; }
         public uint Version { get; set; }
         public uint DoingVersion { get; set; }
         public DateTime VersionTime { get; set; }
         #endregion
         public decimal Balance { get; set; }
     }
    
  2. Event

    ESGrain之间通过Event传递数据,Event编写请参考Event编写.md

  3. EventHandles

    使用ESGrain引发事件,一般出于两种考虑:1.传递数据到Handler;2.修改State中的数据。修改ESGrain中的数据通过EventHandle中的代码实现。

    使用:

    • 实现IEventHandle

    • 在Apply中实现定义要处理的事件。

      示例代码:

      public class AccountEventHandle : IEventHandle
      {
        public void Apply(object state, IEvent evt)
        {
            if (state is AccountState actorState)
            {
                switch (evt)
                {
                    case AmountAddEvent value: AmountAddEventHandle(actorState, value); break;
                    case AmountTransferEvent value: AmountTransferEventHandle(actorState, value); break;
                    default: break;
                }
            }
        }
        private void AmountTransferEventHandle(AccountState state, AmountTransferEvent evt)
        {
            state.Balance = evt.Balance;
        }
        private void AmountAddEventHandle(AccountState state, AmountAddEvent evt)
        {
            state.Balance = evt.Balance;
        }
      }
      

    • State中的数据存储在内存中,大量的数据存在State中,在某种角度可以将State看做内存数据库。
    • Ray中,修改State的数据要通过EventHandle实现(只有一种方式)。

  4. ESGrain种类

    Ray默认提供了MongoESGrain和SqlGrain两类。

    ESGrain<K, S, W>说明:

    • K:StateId的类型。
    • S:ESGrain的State。
    • W:MessageInfo。
完整ESGrain示例

编写ESGrain时

  • 明确RabbitPub。

  • 明确MongoStorage。

  • 继承MongoESGrain或SqlGrain。

  • 实现ESGrain接口。

  • 如果需要重写OnActivateAsync。

  • 编写感兴趣的Actor方法

  • 如果需要发送事件:1.定义事件;2.编写EventHandler。

    [RabbitMQ.RabbitPub("Account", "account")] [MongoStorage("Test", "Account")] public sealed class Account : MongoESGrain<String, AccountState, IGrains.MessageInfo>, IAccount { protected override string GrainId => this.GetPrimaryKeyString(); static IEventHandle _eventHandle = new AccountEventHandle(); protected override IEventHandle EventHandle => _eventHandle; public override Task OnActivateAsync() { return base.OnActivateAsync(); } public Task Transfer(string toAccountId, decimal amount) { var evt = new AmountTransferEvent(toAccountId, amount, this.State.Balance - amount); return RaiseEvent(evt).AsTask(); } public Task AddAmount(decimal amount, string uniqueId = null) { var evt = new AmountAddEvent(amount, this.State.Balance + amount); return RaiseEvent(evt, uniqueId: uniqueId).AsTask(); } [AlwaysInterleave] public Task GetBalance() { return Task.FromResult(this.State.Balance); } }


ESRepGrain

ESGrain默认是主Actor,当单个Actor压力过大时,可以实现该actor的副本actor,副本actor主要用来处理:1.读的操作;2.其他非写的异步操作。

主actor与副本actor之间保持同步的机制:
  1. 主actor引发事件,在CoreHandler里将消息传递给副本actor,在副本actor里面重放该事件。
  2. 主actor与副本actor持久化的是同一个快照库、事件库。也会从同一个库里激活。
生命周期

与主actor类似。

使用

与ESGrain类似,对比如下:

ESGrain

ESRepGrain

明确RabbitPub

不需要

明确MongoStorage

明确MongoStorage

继承MongoESGrain或SqlGrain

继承MongoESRepGrain或SqlRepGrain

实现ESGrain接口

自定义的副本Actor接口

如果需要重写OnActivateAsync

如果需要重写OnActivateAsync

编写感兴趣的Actor方法

编写感兴趣的Actor方法

如果需要发送事件:1.定义事件;2.编写EventHandler

不会引发事件

示例
[MongoStorage("Test", "Account")]
public sealed class AccountRep : MongoESRepGrain<String, AccountState, MessageInfo>, IAccountRep
{
     protected override string GrainId => this.GetPrimaryKeyString();

     static IEventHandle _eventHandle = new AccountEventHandle();
     protected override IEventHandle EventHandle => _eventHandle;

     public Task<decimal> GetBalance()
     {
         return Task.FromResult(this.State.Balance);
     }
}

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Stella981 Stella981
3年前
Opencv中Mat矩阵相乘——点乘、dot、mul运算详解
Opencv中Mat矩阵相乘——点乘、dot、mul运算详解2016年09月02日00:00:36 \牧野(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fme.csdn.net%2Fdcrmg) 阅读数:59593
Stella981 Stella981
3年前
Android蓝牙连接汽车OBD设备
//设备连接public class BluetoothConnect implements Runnable {    private static final UUID CONNECT_UUID  UUID.fromString("0000110100001000800000805F9B34FB");
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
ES6 新增的数组的方法
给定一个数组letlist\//wu:武力zhi:智力{id:1,name:'张飞',wu:97,zhi:10},{id:2,name:'诸葛亮',wu:55,zhi:99},{id:3,name:'赵云',wu:97,zhi:66},{id:4,na
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这