Actor-ES框架:Actor编写-ESGrain与ESRepGrain
ESGrain
生命周期
Ray中ESGrain继承自Grain扩展了Grain的生命周期。Grain的生命周期参加文档附录:1-Grain生命周期-译注.md
ESGrain重写了Grain的OnActivateAsync方法。ESGrain的初始化过程如下:
初始化ESGrain中的State
调用ReadSnapshotAsync()读快照。
如果没有获得快照,调用InitState()根据InitState()中代码初始化ESGrain,InitState()是虚方法,可以被具体的ESGrain重写,以自定义初始化。
读取事件库,重放事件,获得最新的State。
小技巧:在实际开发中,可以重写InitState(),在其中根据关系型数据库中的数据自定义state的初始化。
使用
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; } }
Event
ESGrain之间通过Event传递数据,Event编写请参考Event编写.md
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实现(只有一种方式)。
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<decimal> GetBalance()
{
return Task.FromResult(this.State.Balance);
}
}
ESRepGrain
ESGrain默认是主Actor,当单个Actor压力过大时,可以实现该actor的副本actor,副本actor主要用来处理:1.读的操作;2.其他非写的异步操作。
主actor与副本actor之间保持同步的机制:
主actor引发事件,在CoreHandler里将消息传递给副本actor,在副本actor里面重放该事件。
主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);
}
}
原文地址:http://www.cnblogs.com/CharlesZHENG/p/8438057.html
.NET社区新闻,深度好文,欢迎访问公众号文章汇总 http://www.csharpkit.com
Actor-ES框架:Actor编写-ESGrain与ESRepGrain相关推荐
- java actor akka_Akka框架简介
Akka是JAVA虚拟机平台上构建高并发.分布式和容错应用的工具包和运行时.Akka用Scala语言编写,同时提供了Scala和Java的开发接口.Akka处理并发的方法基于Actor模型,Actor ...
- 下一代的 Actor 模型框架 Proto Actor
ProtoAct 是下一代的 Actor 模型框架,提供了 .NET 和 Go 语言的实现,默认支持分布式,提供管理和监控功能.在过去几年,我们经常看到两种 Actor 模型方法相互竞争,首先是经典的 ...
- [UE][UE5]Gameplay框架,Actor,pawn,playerController(玩家控制器),Character(角色)之间的关系
[UE][UE5]Gameplay框架,actor,pawn,playerController,Character之间的关系 Actor,pawn,playerController(玩家控制器),Ch ...
- Orleans 分布式 计算框架-Actor模型的一种实现
写在前面 Orleans是基于Actor模型思想的.NET领域的框架,它提供了一种直接而简单的方法来构建分布式大规模计算应用程序,而无需学习和应用复杂的并发或其他扩展模式.我在2015年下半年开始应用 ...
- PC微信hook基础框架代码编写-->获取微信日志
PC微信hook基础框架代码编写-->获取微信日志 一. 封装微信hook框架和一些基本功能 1. 新建一个dll工程 2. 新建一个CHook类 并编写对应的函数 3. 新建一个CTools工 ...
- 使用Java框架Pronghorn编写快速的应用程序
1973年, 卡尔·休伊特 ( Carl Hewitt)提出了一个受量子力学启发的想法. 他想开发能够并行执行任务,在包含自己的本地内存和处理器的同时无缝通信的计算机. 天生就是演员模型 ,并且有了一 ...
- 主流大数据技术全体系参数与搭建与后台代码工程框架的编写(百分之70)
之前查阅源码啊,性能测试啊调优啊..基本告一段落,项目也接近尾声,那么整理下spark所有配置参数与优化策略,方便以后开发与配置: Spark安装配置与代码框架 spark-default.conf ...
- AndriodStudio 开发环境下实现Xposed模块开发入门。Xposed框架模块编写教程
前言: Xposed框架是一款开源框架,其功能是可以在不修改APK的情况下影响程序运行(修改系统)的框架服务,基于它可以制作出许多功能强大的模块,且在功能不冲突的情况下同时运作.Xposed 就好比是 ...
- 机器学习框架_编写生产级机器学习框架的经验教训
机器学习框架 My wonderful colleagues at Atomwise and I have written a production-level PyTorch framework f ...
最新文章
- iOS开发-由浅至深学习block
- 送你一份机器/深度学习自学指南(附视频amp;速成方案)
- mysql编码是乱码_mysql中文乱码 常见编码问题解决方法分享
- 数据结构与算法随学随记
- Cloud Computing:云网端融合的简介、层次、典型代表、未来趋势之详细攻略
- csv 导 mysql
- scala 字符串转换数组_如何在Scala中将字节数组转换为字符串?
- ios更新了系统无服务器,iPhone更新iOS 12.0.1系统失败怎么办?
- javaSE---最大值最小值和冒泡排序及随机数的讲解
- ERROR 1010 (HY000): Error dropping database (can't rmdir './bolgdb/', errno: 17)
- 开启灯光就是近光吗_自动大灯会自动调远近光吗
- usb dongle android,在Android應用中使用libCEC + USB加密狗
- java字符串练习题_java练习题——字符串
- Android应用开发性能优化的知识点
- 【完结!】数据挖掘从入门到放弃(五)seaborn 的数据可视化
- ar 华为路由器 端口映射_华为AR1220-S路由器WEB界面鸡肋使用命令映射多端口方法...
- 转盘抽奖图片html,html转盘抽奖
- 2.3 构建C语言入职教程
- unet医学肺部ct图分割简单记录
- java计算机毕业设计数字家谱管理系统设计与实现MyBatis+系统+LW文档+源码+调试部署