如何为.NET Framework中gRPC服务的所有调用添加元数据？

我刚好处理过.NET Framework下gRPC全局元数据的问题，之前踩过和你一样的坑——拦截器里操作请求头没找对方法，其实核心是要正确处理CallOptions的不可变性，以及覆盖所有调用类型的拦截方法。下面给你一步步的解决方案：

1. 创建全局元数据拦截器类 #

首先要自定义一个继承自Interceptor的拦截器，重写对应调用类型的方法，在这些方法里合并全局元数据和单个调用的自定义元数据，再传递给后续调用。

public class GlobalMetadataInterceptor : Interceptor
{
    private readonly Metadata _globalMetadata;

    public GlobalMetadataInterceptor(Metadata globalMetadata)
    {
        _globalMetadata = globalMetadata ?? throw new ArgumentNullException(nameof(globalMetadata));
    }

    // 拦截一元调用（最常用的调用类型）
    public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(
        TRequest request,
        ClientInterceptorContext<TRequest, TResponse> context,
        AsyncUnaryCallContinuation<TRequest, TResponse> continuation)
    {
        // 合并全局元数据与调用自带的元数据，避免覆盖业务自定义的头
        var combinedMetadata = new Metadata();
        foreach (var entry in context.Options.Headers)
        {
            combinedMetadata.Add(entry);
        }
        foreach (var entry in _globalMetadata)
        {
            combinedMetadata.Add(entry);
        }

        // CallOptions是不可变类型，必须用WithHeaders创建新实例
        var newOptions = context.Options.WithHeaders(combinedMetadata);
        var newContext = new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, newOptions);

        return continuation(request, newContext);
    }

    // 拦截服务器流式调用（按需重写，覆盖所有调用类型）
    public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(
        TRequest request,
        ClientInterceptorContext<TRequest, TResponse> context,
        AsyncServerStreamingCallContinuation<TRequest, TResponse> continuation)
    {
        var combinedMetadata = MergeMetadata(context.Options.Headers);
        var newOptions = context.Options.WithHeaders(combinedMetadata);
        var newContext = new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, newOptions);

        return continuation(request, newContext);
    }

    // 同理，可重写AsyncClientStreamingCall、AsyncDuplexStreamingCall方法覆盖其他调用类型
    private Metadata MergeMetadata(Metadata existingHeaders)
    {
        var combinedMetadata = new Metadata();
        foreach (var entry in existingHeaders)
        {
            combinedMetadata.Add(entry);
        }
        foreach (var entry in _globalMetadata)
        {
            combinedMetadata.Add(entry);
        }
        return combinedMetadata;
    }
}

2. 注册拦截器到gRPC通道 #

在创建gRPC通道时，将自定义拦截器添加到通道配置中，这样所有通过该通道创建的客户端发起的调用，都会自动带上全局元数据。

// 定义你的全局标准元数据
var globalMetadata = new Metadata
{
    { "X-App-Identifier", "DotNetFramework-GRPC-Client" },
    { "X-Global-Token", "YourGlobalAuthToken" }
};

// 创建拦截器实例
var metadataInterceptor = new GlobalMetadataInterceptor(globalMetadata);

// 创建带拦截器的gRPC通道
var channel = GrpcChannel.ForAddress("https://your-grpc-server-domain", new GrpcChannelOptions
{
    Interceptors = { metadataInterceptor }
});

// 使用该通道创建gRPC客户端
var yourServiceClient = new YourGrpcService.YourGrpcServiceClient(channel);

3. 关键注意事项 #

• CallOptions是不可变类型：不能直接修改原context.Options.Headers，必须通过WithHeaders方法创建新的CallOptions实例。
• 覆盖所有调用类型：如果你的业务用到了服务器流式、客户端流式或双向流式调用，一定要对应重写拦截器里的方法，否则这些类型的请求不会带上全局元数据。
• 元数据合并顺序：上面的代码会保留单个调用的自定义元数据，再追加全局元数据；如果需要全局元数据优先级更高，可以调整合并顺序（先加全局，再加原有）。

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