WPF MVVM架构下使用gRPC如何在运行时管理用户输入的连接凭据

方案核心思路 #

提前向DI容器注册gRPC通道持有者和客户端工厂服务，不在应用启动阶段实例化通道和客户端，等用户提交连接凭据后再触发通道初始化，所有客户端都通过持有器复用同一个通道实例。

具体实现步骤 #

1. 定义并注册gRPC通道持有服务 #

定义专门的服务类用来存储、管控gRPC通道实例，应用启动时就将其注册为单例到DI容器：

public interface IGrpcChannelProvider
{
    // 对外暴露已初始化的通道
    GrpcChannel Channel { get; }
    // 初始化通道的方法，用户提交凭据后调用
    void Initialize(string ip, int port);
    // 检查通道是否已完成初始化
    bool IsInitialized { get; }
}

public class GrpcChannelProvider : IGrpcChannelProvider
{
    private GrpcChannel _channel;
    public GrpcChannel Channel => _channel ?? throw new InvalidOperationException("gRPC通道未初始化，请先输入服务端连接凭据");
    public bool IsInitialized => _channel != null;

    public void Initialize(string ip, int port)
    {
        if (IsInitialized) return; // 避免重复初始化
        // 加密连接可在此处调整地址前缀、添加证书配置
        _channel = GrpcChannel.ForAddress($"http://{ip}:{port}");
    }
}

应用启动阶段DI注册逻辑：

services.AddSingleton<IGrpcChannelProvider, GrpcChannelProvider>();

2. 注册gRPC客户端工厂 #

不要直接注册客户端实例，注册带通道依赖的工厂委托，所有客户端自动复用通道持有者的实例：

// 按业务需要注册对应gRPC客户端
services.AddTransient(sp => 
{
    var provider = sp.GetRequiredService<IGrpcChannelProvider>();
    return new UserService.UserServiceClient(provider.Channel);
});

services.AddTransient(sp => 
{
    var provider = sp.GetRequiredService<IGrpcChannelProvider>();
    return new OrderService.OrderServiceClient(provider.Channel);
});

3. 启动窗口连接逻辑处理 #

启动窗口的ViewModel直接注入IGrpcChannelProvider，用户提交连接信息、校验格式合法后，调用初始化方法，完成后再跳转主窗口：

// 启动窗口连接按钮点击逻辑示例
private void OnConnectClicked()
{
    // 省略IP、端口格式校验逻辑
    _grpcChannelProvider.Initialize(InputIp, InputPort);
    // 初始化完成后跳转主窗口
    NavigateToMainWindow();
}

若需要支持后续切换服务端地址，可给IGrpcChannelProvider新增Reset()方法清空现有通道，重新调用初始化即可，已注册的客户端工厂下次请求时会自动使用新通道生成客户端。

4. 业务层调用适配 #

业务ViewModel直接注入对应的gRPC客户端即可，调用前增加初始化状态校验避免异常：

public class UserViewModel : ObservableObject
{
    private readonly UserService.UserServiceClient _userClient;
    private readonly IGrpcChannelProvider _channelProvider;

    public UserViewModel(UserService.UserServiceClient userClient, IGrpcChannelProvider channelProvider)
    {
        _userClient = userClient;
        _channelProvider = channelProvider;
    }

    public async Task LoadUserList()
    {
        if(!_channelProvider.IsInitialized)
        {
            // 提示用户先完成服务端连接
            return;
        }
        // 正常调用gRPC接口
        var response = await _userClient.ListUserAsync(new ListUserRequest());
    }
}

扩展优化点 #

• 如果需要支持通道重连、健康检查，可以在GrpcChannelProvider里加对应的逻辑，统一处理所有客户端的连接问题，不用每个客户端单独处理
• 如果有大量gRPC客户端，可以写个扩展方法批量注册，不用每个都手动写工厂委托
• 凭据如果需要带token之类的鉴权信息，可以把Initialize方法的参数扩展，把凭证加到Channel的拦截器中统一携带

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