.NET分布式Orleans计时器和提醒功能实现
Timer是什么
Timer 是一种用于创建定期粒度行为的机制。
与标准的 .NET System.Threading.Timer 类相似，Orleans 的 Timer 允许在一段时间后执行特定的操作，或者在特定的时间间隔内重复执行操作。
它在分布式系统中具有重要作用，特别是在处理需要周期性执行的任务时非常有用。
Timer的注意事项
计时器回调不会改变空闲激活的状态，不能用于推迟其他空闲激活的停用。
Grain.RegisterTimer 中传递的时间段取决于上次回调完成到下一次回调开始的时间，因此回调的频率会受到执行时间的影响。
每次 asyncCallback 调用都会作为单独轮次的激活，并且不会与同一激活的其他轮次同时运行。
代码示例
public class PlayerGrain : Grain, IPlayerGrain
{
public Task<string> GetPlayerInfo()
{
var timer = RegisterTimer(DoSomething, null, TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(2));
return Task.FromResult($"Player ID: {this.GetPrimaryKeyString()}");
}
private async Task DoSomething(object state)
{
// 在这里定义要执行的操作
await Task.Delay(5000);
Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} Timer Triggered: {this.GetPrimaryKeyString()}");
}
}
Reminder与Timer的区别
提醒（Reminder）是一种在 Orleans 中用于处理周期性任务的机制，与计时器类似，但具有一些重要区别：
永久性触发：提醒是永久性的，除非明确取消，否则会在几乎所有情况下（包括部分或完整群集重启）继续触发。
定义的持久性：提醒的定义会写入存储，但具体的事件及其时间不会。这意味着如果群集在提醒应该触发时关闭，它将错过该提醒，只会在下次提醒的触发时被重新激活。
关联于Grain：提醒是与Grain关联的，而不是与任何特定激活Grain。如果提醒的触发时，粒度没有与之关联的激活，则会创建该Grain，并在下次触发时重新激活。
消息传递：提醒的传递通过消息发生，受到与所有其他粒度方法相同的交错语义的约束。
适用场景：提醒通常不适用于高频计时器，其周期应该以分钟、小时或天为单位。相比之下，提醒更适用于周期性任务的处理，例如定期执行清理任务或发送通知等。
如果想使用reminder，需要安装nuget包
<PackageReference Include="Microsoft.Orleans.Reminders" Version="8.0.0" />
并开启reminder
silBuilder.UseInMemoryReminderService();
Grain需要实现接口 IRemindable ，并使用this.RegisterOrUpdateReminder 注册reminder
public interface IPlayerGrain : IGrainWithStringKey, IRemindable
{
Task<string> GetPlayerInfo();
}
public class PlayerGrain : Grain, IPlayerGrain
{
public Task<string> GetPlayerInfo()
{
this.RegisterOrUpdateReminder("myReminder", TimeSpan.FromSeconds(5), TimeSpan.FromMinutes(1));
return Task.FromResult($"Player ID: {this.GetPrimaryKeyString()}");
}
public Task ReceiveReminder(string reminderName, TickStatus status)
{
Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} Reminder Triggered: {this.GetPrimaryKeyString()}");return Task.CompletedTask;
}
}
Timer 和 Reminder 场景
使用定时器（Timer）的场景：
- 对激活状态的要求不高：如果激活被停用或发生故障时，计时器停止运行不会产生重大影响，或者这种行为可接受。
- 较小的分辨率：如果需要较小的时间间隔来执行任务，例如以秒或分钟为单位。
- 计时器回调与 Grain 生命周期相关：如果需要在 Grain 的生命周期事件（如OnActivateAsync()）或者调用粒度方法时启动计时器回调。
使用提醒（Reminder）的场景：
- 持久性要求：当需要确保周期性行为在激活和任何故障中都存在时，提醒是一个更好的选择。因为提醒是永久性的，除非明确取消，否则会在几乎所有情况下继续触发。
- 较大的时间间隔：当执行不常见的任务，例如以分钟、小时或天为单位的周期性任务时，提醒更为适合。
依赖注入创建Timer与Reminder
将 ITimerRegistry 或 IReminderRegistry 注入粒度的构造函数中，也可以创建Timer与Reminder
public PlayerGrain(ITimerRegistry timerRegistry,
IReminderRegistry reminderRegistry,
IGrainContext grainContext)
{
timerRegistry.RegisterTimer(grainContext,DoSomething,null, TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(2));
reminderRegistry.RegisterOrUpdateReminder(grainContext.GrainId,"testreminder",TimeSpan.FromSeconds(5), TimeSpan.FromMinutes(1));
}
到此这篇关于.NET分布式Orleans - 4 - 计时器和提醒的文章就介绍到这了,更多相关.NET计时器和提醒内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
asp.net core MVC 过滤器之ActionFilter过滤器(2)
这篇文章主要为大家详细介绍了asp.net core MVC过滤器之ActionFilter过滤器，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-08-08
以下是对JSON序列化与反序列化进行了详细的分析介绍，需要的朋友可以过来参考下2013-07-07
这篇文章主要给大家总结介绍了关于.Net防sql注入的几种方法，文中通过示例代码介绍的非常详细，对大家学习或者使用.Net具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2019-06-06
asp.net jquery无刷新分页插件(jquery.pagination.js)
采用Jquery无刷新分页插件jquery.pagination.js 实现无刷新分页效果:本示例Handler中采用StringBuilder的append方法追加HTML，小数据量可以，但是大数据或是布局常变，建议返回JSON格式的数据，性能和灵活性更好,望使用者好好把握2013-01-01
这篇文章介绍了.NET Core分布式链路追踪框架的基本实现原理，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-03-03
简化用户操作界面，添加功能一般没法简化，但是如果是在GridView做显示，编辑，更新与删除，会让用户在编辑，需要点击编辑铵钮，再进行编辑，或是取消编辑，下面是改进的方法做了演示动画，感兴趣的朋友可以了解下2013-01-01
这篇文章主要介绍了asp.net C#实现解压缩文件的方法,分别讲述了三种不同的实现方法,是非常实用的技巧,需要的朋友可以参考下2014-11-11
这篇文章主要为大家详细介绍了ASP.NET使用WebService实现天气预报功能的相关资料，感兴趣的小伙伴们可以参考一下2016-08-08
前段时间网站被挂马，数据库表中很多文本字段都被加上了一段js脚本。修复完程序漏洞之后便开始着手清理这些被注入的数据，其间参考了一些网上的方法，大都是写一个存储过程进行一个表一个表逐一清理。2011-10-10
VS2015内置的C#版本为6.0，提供了一些新特性，这篇文章主要为大家详细介绍了VS2015中C#版本6.0的8种新特性，感兴趣的小伙伴们可以参考一下2016-06-06
最新评论