如何在Orleans启动时过滤MySQL中不属于当前应用的Reminder Grain

可以通过以下几种方式实现启动时过滤不属于当前应用的Reminder Grain：

1. 自定义Reminder存储提供器 #

默认MySQL Reminder存储会加载所有记录，你可以继承MySqlReminderTable并重写读取方法，在加载阶段筛选出当前应用相关的Reminder。

示例代码：

public class FilteredMySqlReminderTable : MySqlReminderTable
{
    private readonly string _appIdentifier;

    public FilteredMySqlReminderTable(IOptions<MySqlReminderTableOptions> options, ILogger<MySqlReminderTable> logger, string appIdentifier) 
        : base(options, logger)
    {
        _appIdentifier = appIdentifier;
    }

    public override async Task<List<ReminderEntry>> ReadRows(uint begin, uint end)
    {
        var allReminders = await base.ReadRows(begin, end);
        // 根据GrainId中的应用标识过滤，需确保不同应用的GrainId带有唯一标识
        return allReminders.Where(r => r.GrainId.ToString().Contains(_appIdentifier)).ToList();
    }

    // 按需重写ReadRow、ReadAllRows等其他读取方法
}

在Silo配置中替换默认存储实现：

siloBuilder.UseReminderService(options =>
{
    options.UseMySql("your-mysql-connection-string");
})
.ConfigureServices(services =>
{
    services.AddSingleton<IReminderTable>(sp => 
        new FilteredMySqlReminderTable(
            sp.GetRequiredService<IOptions<MySqlReminderTableOptions>>(),
            sp.GetRequiredService<ILogger<MySqlReminderTable>>(),
            "YourAppUniqueMarker"));
});

2. 应用级存储隔离 #

最彻底的方案是为每个应用分配独立的MySQL数据库或Reminder表，从根源上避免不同应用的Reminder数据混合，无需额外过滤逻辑。

3. 捕获并忽略未知Grain类型异常 #

如果无法修改存储结构，可以通过全局异常处理捕获并忽略因未知Grain类型引发的异常，防止Silo崩溃：

siloBuilder.AddStartupTask(async (silo, ct) =>
{
    var grainRuntime = silo.Services.GetRequiredService<IGrainRuntime>();
    grainRuntime.UnobservedTaskException += (sender, args) =>
    {
        if (args.Exception is OrleansException ex && 
            (ex.Message.Contains("Cannot find an implementation class for grain interface") || 
             ex.Message.Contains("Cannot find the directory for grain class")))
        {
            args.SetObserved();
        }
    };
});

注意：此方式仅抑制异常，未真正过滤Reminder，可能存在资源消耗隐患，优先推荐前两种方案。

内容的提问来源于stack exchange，提问作者szabim3