如何从Dapr InvocationException中获取.NET微服务的原始异常对象？

1. 被调用方统一异常处理，标准化输出格式 #

首先在被调用服务中，需要把异常序列化为包含异常类型全名、消息、堆栈跟踪的结构化数据，先定义一个异常信息DTO：

public class ExceptionDetails
{
    public string ExceptionType { get; set; }
    public string Message { get; set; }
    public string StackTrace { get; set; }
}

接着添加全局异常处理中间件，捕获异常后返回结构化数据并设置对应HTTP状态码：

public class ExceptionHandlingMiddleware
{
    private readonly RequestDelegate _next;

    public ExceptionHandlingMiddleware(RequestDelegate next)
    {
        _next = next;
    }

    public async Task InvokeAsync(HttpContext context)
    {
        try
        {
            await _next(context);
        }
        catch (Exception ex)
        {
            var exceptionDetails = new ExceptionDetails
            {
                ExceptionType = ex.GetType().FullName,
                Message = ex.Message,
                StackTrace = ex.StackTrace
            };

            context.Response.ContentType = "application/json";
            context.Response.StatusCode = ex is ArgumentException || ex is InvalidOperationException 
                ? StatusCodes.Status400BadRequest 
                : StatusCodes.Status500InternalServerError;
            
            await context.Response.WriteAsJsonAsync(exceptionDetails);
        }
    }
}

最后在Program/Startup中注册中间件：

app.UseMiddleware<ExceptionHandlingMiddleware>();

2. 调用方解析InvocationException，还原原始异常 #

在调用方捕获InvocationException后，读取响应中的结构化数据，通过反射还原原始异常对象：

try
{
    var result = await _daprClient.InvokeMethodAsync<MyRequest, MyResponse>("target-service", "api/endpoint", request);
}
catch (InvocationException ex)
{
    if (ex.Response != null)
    {
        var exceptionDetails = await ex.Response.Content.ReadFromJsonAsync<ExceptionDetails>();
        if (exceptionDetails != null)
        {
            // 根据异常类型全名获取Type对象
            var exceptionType = Type.GetType(exceptionDetails.ExceptionType);
            if (exceptionType != null && typeof(Exception).IsAssignableFrom(exceptionType))
            {
                // 反射创建原始异常实例
                var originalException = (Exception)Activator.CreateInstance(
                    exceptionType, 
                    exceptionDetails.Message);
                // 手动设置堆栈跟踪（可选）
                var stackTraceField = typeof(Exception).GetField("_stackTraceString", BindingFlags.Instance | BindingFlags.NonPublic);
                stackTraceField?.SetValue(originalException, exceptionDetails.StackTrace);
                
                // 抛出或处理还原后的原始异常
                throw originalException;
            }
        }
    }
    // 解析失败时抛出原异常
    throw;
}

关键注意事项 #

• 被调用方和调用方必须引用相同的异常类型定义（建议放在共享类库中），否则Type.GetType无法找到对应类型。
• 自定义异常需要包含接收消息参数的构造函数，否则反射实例化会失败。
• 双方需统一异常序列化/反序列化的格式约定，避免解析失败。

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