Reliable Services 通知

通知可让客户端跟踪对它们感兴趣的对象所进行的更改。 两种类型的对象支持通知：可靠状态管理器和可靠字典。

使用通知的常见原因如下：

• 生成副本状态的具体化视图（例如次要索引）或聚合筛选视图。 可靠字典中所有键的排序索引便是其中一个例子。
• 发送监视数据，例如过去一小时内添加的用户数目。

通知会在应用操作的过程中触发。 对于主要副本，在执行 transaction.CommitAsync() 或 this.StateManager.GetOrAddAsync() 过程中，操作将在仲裁确认之后应用。 对于次要副本，操作在复制队列数据处理期间应用。 因此，应该尽快处理通知，且同步事件不应包含任何耗费资源的操作。 否则，可能会对事务处理时间和副本生成带来负面影响。

可靠状态管理器通知

可靠状态管理器为以下事件提供通知：

• 事务
  • 提交
• 状态管理器
  • 重新生成
  • 添加可靠状态
  • 删除可靠状态

可靠状态管理器会跟踪当前正在进行的事务。 唯一会导致通知触发的事务状态更改是提交事务。

可靠状态管理器会维护可靠状态的集合，例如可靠字典和可靠队列。 可靠状态管理器会在此集合更改时触发通知：添加或删除可靠状态，或者重新生成整个集合时。 可靠状态管理器集合会在以下三种情况下重新生成：

• 恢复：当副本启动时，它会从磁盘恢复其先前的状态。 恢复结束时，它会使用 NotifyStateManagerChangedEventArgs 触发事件，其中包含一组已恢复的可靠状态。
• 完整副本：必须先生成副本，它才能加入配置集。 有时，这需要将主要副本中可靠状态管理器状态的完整副本应用到空闲的次要副本。 次要副本上的可靠状态管理器会使用 NotifyStateManagerChangedEventArgs 触发事件，其中包含一组它从主要副本获取的可靠状态。
• 还原：在灾难恢复方案中，副本的状态可通过 RestoreAsync 从备份还原。 在这种情况下，主要副本上的可靠状态管理器会使用 NotifyStateManagerChangedEventArgs 触发事件，其中包含一组它从备份还原的可靠状态。

若要注册事务通知和/或状态管理器通知，需要在可靠状态管理器上注册 TransactionChanged 或 StateManagerChanged 事件。 注册这些事件处理程序的常见位置是有状态服务的构造函数。 在构造函数上注册时，也不会错过 IReliableStateManager 生存期内的更改所导致的任何通知。

public MyService(StatefulServiceContext context)
    : base(MyService.EndpointName, context, CreateReliableStateManager(context))
{
    this.StateManager.TransactionChanged += this.OnTransactionChangedHandler;
    this.StateManager.StateManagerChanged += this.OnStateManagerChangedHandler;
}

TransactionChanged 事件处理程序使用 NotifyTransactionChangedEventArgs 来提供有关事件的详细信息。 它包含用于指定更改类型的操作属性（例如，NotifyTransactionChangedAction.Commit）。 也包含提供对已更改事务的引用的事务属性。

以下是 TransactionChanged 事件处理程序示例。

private void OnTransactionChangedHandler(object sender, NotifyTransactionChangedEventArgs e)
{
    if (e.Action == NotifyTransactionChangedAction.Commit)
    {
        this.lastCommitLsn = e.Transaction.CommitSequenceNumber;
        this.lastTransactionId = e.Transaction.TransactionId;

        this.lastCommittedTransactionList.Add(e.Transaction.TransactionId);
    }
}

StateManagerChanged 事件处理程序使用 NotifyStateManagerChangedEventArgs 来提供有关事件的详细信息。 NotifyStateManagerChangedEventArgs 有两个子类：NotifyStateManagerRebuildEventArgs 和 NotifyStateManagerSingleEntityChangedEventArgs。 使用 NotifyStateManagerChangedEventArgs 中的操作属性将 NotifyStateManagerChangedEventArgs 转换为正确的子类：

• NotifyStateManagerChangedAction.Rebuild：NotifyStateManagerRebuildEventArgs
• NotifyStateManagerChangedAction.Add 和 NotifyStateManagerChangedAction.Remove：NotifyStateManagerSingleEntityChangedEventArgs

以下是 StateManagerChanged 通知处理程序示例。

public void OnStateManagerChangedHandler(object sender, NotifyStateManagerChangedEventArgs e)
{
    if (e.Action == NotifyStateManagerChangedAction.Rebuild)
    {
        this.ProcessStateManagerRebuildNotification(e);

        return;
    }

    this.ProcessStateManagerSingleEntityNotification(e);
}

可靠字典通知

可靠字典为以下事件提供通知：

• 重新生成：在 ReliableDictionary 从过去恢复或复制的本地状态或备份恢复其状态后调用。
• 清除：在通过 ClearAsync 方法清除 ReliableDictionary 的状态后调用。
• 添加：在向 ReliableDictionary 添加项之后调用。
• 更新：在更新 IReliableDictionary 中的项之后调用。
• 删除：在删除 IReliableDictionary 中的项之后调用。

若要获取可靠字典通知，需在 DictionaryChanged 上注册 IReliableDictionary 事件处理程序。 注册这些事件处理程序的常见位置是在 ReliableStateManager.StateManagerChanged 添加通知中。 在将 IReliableDictionary 添加到 IReliableStateManager 时注册，可确保不会错过任何通知。

private void ProcessStateManagerSingleEntityNotification(NotifyStateManagerChangedEventArgs e)
{
    var operation = e as NotifyStateManagerSingleEntityChangedEventArgs;

    if (operation.Action == NotifyStateManagerChangedAction.Add)
    {
        if (operation.ReliableState is IReliableDictionary<TKey, TValue>)
        {
            var dictionary = (IReliableDictionary<TKey, TValue>)operation.ReliableState;
            dictionary.RebuildNotificationAsyncCallback = this.OnDictionaryRebuildNotificationHandlerAsync;
            dictionary.DictionaryChanged += this.OnDictionaryChangedHandler;
        }
    }
}

上述代码会设置 IReliableNotificationAsyncCallback 接口以及 DictionaryChanged。 由于 NotifyDictionaryRebuildEventArgs 包含需要以异步方式枚举的 IAsyncEnumerable 接口，因此会通过 RebuildNotificationAsyncCallback 而不是 OnDictionaryChangedHandler 来触发重新生成通知。

public async Task OnDictionaryRebuildNotificationHandlerAsync(
    IReliableDictionary<TKey, TValue> origin,
    NotifyDictionaryRebuildEventArgs<TKey, TValue> rebuildNotification)
{
    this.secondaryIndex.Clear();

    var enumerator = e.State.GetAsyncEnumerator();
    while (await enumerator.MoveNextAsync(CancellationToken.None))
    {
        this.secondaryIndex.Add(enumerator.Current.Key, enumerator.Current.Value);
    }
}

DictionaryChanged 事件处理程序使用 NotifyDictionaryChangedEventArgs 来提供有关事件的详细信息。 NotifyDictionaryChangedEventArgs 有五个子类。 使用 NotifyDictionaryChangedEventArgs 中的操作属性将 NotifyDictionaryChangedEventArgs 转换为正确的子类：

• NotifyDictionaryChangedAction.Rebuild：NotifyDictionaryRebuildEventArgs
• NotifyDictionaryChangedAction.Clear：NotifyDictionaryClearEventArgs
• NotifyDictionaryChangedAction.Add：NotifyDictionaryItemAddedEventArgs
• NotifyDictionaryChangedAction.Update：NotifyDictionaryItemUpdatedEventArgs
• NotifyDictionaryChangedAction.Remove：NotifyDictionaryItemRemovedEventArgs

public void OnDictionaryChangedHandler(object sender, NotifyDictionaryChangedEventArgs<TKey, TValue> e)
{
    switch (e.Action)
    {
        case NotifyDictionaryChangedAction.Clear:
            var clearEvent = e as NotifyDictionaryClearEventArgs<TKey, TValue>;
            this.ProcessClearNotification(clearEvent);
            return;

        case NotifyDictionaryChangedAction.Add:
            var addEvent = e as NotifyDictionaryItemAddedEventArgs<TKey, TValue>;
            this.ProcessAddNotification(addEvent);
            return;

        case NotifyDictionaryChangedAction.Update:
            var updateEvent = e as NotifyDictionaryItemUpdatedEventArgs<TKey, TValue>;
            this.ProcessUpdateNotification(updateEvent);
            return;

        case NotifyDictionaryChangedAction.Remove:
            var deleteEvent = e as NotifyDictionaryItemRemovedEventArgs<TKey, TValue>;
            this.ProcessRemoveNotification(deleteEvent);
            return;

        default:
            break;
    }
}

建议

• 尽快完成通知事件。
• 不要执行任何耗费资源的操作（例如 I/O 操作）作为同步事件的一部分。
• 处理事件之前，先检查操作类型。 未来可能会添加新的操作类型。

需谨记以下几点：

• 通知会在执行操作的过程中触发。 例如，在还原操作的最后一个步骤触发还原通知。 处理通知事件之前，不会完成还原。
• 由于通知会在应用操作的过程中触发，因此，客户端只会看见本地提交操作的通知。 而且因为操作只保证会在本地提交（亦即记录），所以它们不一定可在未来恢复。
• 在恢复路径上，会针对每个应用的操作触发单个通知。 这表示，如果事务 T1 包含 Create(X)、Delete(X) 和 Create(X)，将依次收到一个针对 X 创建的通知，一个针对删除的通知，然后再收到一个针对创建的通知。
• 对于包含多个操作的事务，操作将按用户在主要副本上收到它们的顺序应用。
• 在处理错误进度的过程中，某些操作在次要副本上可能会撤消。 通知会针对这类恢复操作加以触发，将副本状态回滚到稳定的时间点。 恢复通知的一个重要区别，是具有重复键的事件会聚合在一起。 例如，如果恢复事务 T1，会看到一条针对 Delete(X) 的通知。

后续步骤

• Reliable Collections
• Reliable Services 快速启动
• Reliable Services 备份和还原（灾难恢复）
• Reliable Collections 的开发人员参考