TPL ActionBlock出现异常后无法处理消息，如何恢复？

问题本质 #

TPL Dataflow的ActionBlock<T>设计上是故障即终止：当处理委托（HandleNotification）抛出未捕获异常时，块会立即进入完成状态（IsCompleted=true）并永久拒绝新消息（IsDecliningPermanently=true），且无法直接重启或恢复原块实例。

另外要纠正一个误区：你当前包裹Post的try-catch捕获不到HandleNotification内部的异常——Post仅会在块拒绝接收消息时抛出异常，处理逻辑的异常会被封装到ActionBlock.Completion任务中，不会直接在Post时抛出。

解决方案 #

1. 捕获处理逻辑内部的异常（最优方案） #

核心思路：不让异常逃出HandleNotification，这样ActionBlock永远不会进入故障状态，持续处理后续消息。

改造HandleNotification方法，把所有业务逻辑包裹在try-catch中：

private void HandleNotification(PresentationListNotification notification)
{
    try
    {
        // 原有的处理逻辑，包括操作TaskCompletionSource的代码
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "处理通知[{NotificationId}]出错: {Message}", 
            notification.Id, ex.Message);
        
        // 可选：根据业务需求，添加重试逻辑或死信队列处理
    }
}

这个方案从根源避免了ActionBlock故障，是最稳妥的处理方式。

2. 故障后重新创建ActionBlock实例 #

如果无法避免HandleNotification抛出异常（或业务需要允许块故障后恢复），则需在块故障时重新初始化新的ActionBlock实例。

可以封装一个管理块状态的逻辑：

private ActionBlock<PresentationListNotification> _actionBlock;

// 初始化/重建ActionBlock的方法
private void ResetActionBlock()
{
    _actionBlock = new ActionBlock<PresentationListNotification>(HandleNotification);
    // 可选：监控块的Completion状态，故障时自动重建
    _ = MonitorBlockCompletion();
}

// 监控块的完成状态，故障时触发重建
private async Task MonitorBlockCompletion()
{
    try
    {
        await _actionBlock.Completion;
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "ActionBlock故障，正在重建");
        ResetActionBlock();
        // 可选：如果有未处理的消息，此处需重新提交到新块
    }
}

// 提交通知的入口方法
public void SendNotification(PresentationListNotification notification)
{
    // 检查块是否不可用，是则重建
    if (_actionBlock == null || _actionBlock.IsCompleted || _actionBlock.IsDecliningPermanently)
    {
        ResetActionBlock();
    }

    try
    {
        var posted = _actionBlock.Post(notification);
        if (!posted)
        {
            _logger.Warn("通知[{NotificationId}]提交失败，块当前拒绝接收消息", notification.Id);
            // 可选：将消息暂存到队列，后续重试
        }
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "提交通知[{NotificationId}]时发生异常", notification.Id);
    }
}

注意：此方案可能会丢失未处理的消息，若需保证消息不丢失，需额外维护一个待处理消息队列，在块重建后重新提交未处理的消息。

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