.NET分布式Orleans计时器和提醒功能实现_Asp.net

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));
}