Kubernetes多副本部署Blazor托管WASM应用引发SignalR Hub问题

一、先修复SignalR连接错误 #

1. WebSocket连接失败 #

K8s环境下WebSocket需要Ingress支持，以Nginx Ingress为例，需添加以下注解确保WebSocket转发正常：

annotations:
  nginx.ingress.kubernetes.io/websocket-services: "你的服务名称"
  nginx.ingress.kubernetes.io/proxy-read-timeout: "3600"  # 需大于SignalR的KeepAliveInterval（15分钟）
  nginx.ingress.kubernetes.io/proxy-send-timeout: "3600"
  nginx.ingress.kubernetes.io/proxy-connect-timeout: "60"

同时检查错误信息中的域名www,xxx.com，确认是输入错误（逗号应为点号），确保域名解析正常。

2. ServerSentEvents单独指定报错 #

浏览器环境下SignalR不允许仅指定SSE作为传输方式，需搭配LongPolling：

hubConnection = new HubConnectionBuilder()
    .WithUrl(navigationManager.ToAbsoluteUri("/hubs/chathub"), options =>
    {
        options.Transports = HttpTransportType.ServerSentEvents | HttpTransportType.LongPolling;
    })
    .WithAutomaticReconnect()
    .Build();

3. LongPolling 404错误 #

检查Ingress路径规则，确保/hubs/*请求被正确转发到服务：

spec:
  rules:
  - http:
      paths:
      - path: /hubs
        pathType: Prefix
        backend:
          service:
            name: 你的服务名称
            port:
              number: 80

同时确认服务端MapHub<ChatHub>("hubs/chathub")的路径配置与客户端一致。

二、无Broker实现服务器间消息同步（基于K8s StatefulSet） #

利用K8s StatefulSet的稳定Pod域名，让每个服务实例之间建立内部SignalR连接，实现消息转发：

1. 新增内部同步Hub #

创建用于实例间通信的ClusterSyncHub：

public class ClusterSyncHub : Hub
{
    private readonly IHubContext<ChatHub> _chatHubContext;

    public ClusterSyncHub(IHubContext<ChatHub> chatHubContext)
    {
        _chatHubContext = chatHubContext;
    }

    // 接收其他实例的消息，转发给本地客户端
    public async Task RelayMessage(string message)
    {
        await _chatHubContext.Clients.All.SendAsync("ReceiveMessage", message);
    }
}

2. 修改业务Hub，添加消息转发逻辑 #

在原ChatHub中，发送消息时同时转发到其他实例：

public class ChatHub : Hub
{
    private readonly IHubContext<ClusterSyncHub> _clusterSyncHubContext;

    public ChatHub(IHubContext<ClusterSyncHub> clusterSyncHubContext)
    {
        _clusterSyncHubContext = clusterSyncHubContext;
    }

    public async Task SendMessage(string message)
    {
        // 发给当前实例的客户端
        await Clients.All.SendAsync("ReceiveMessage", message);
        // 转发给集群内其他实例
        await _clusterSyncHubContext.Clients.All.SendAsync("RelayMessage", message);
    }
}

3. 注册内部Hub与集群同步托管服务 #

在服务端Program.cs中添加：

// 注册内部同步Hub
builder.Services.AddHostedService<ClusterSyncHostedService>();
app.MapHub<ClusterSyncHub>("/hubs/clustersync");

4. 实现集群同步托管服务 #

该服务在实例启动时，连接到集群内其他实例的ClusterSyncHub：

public class ClusterSyncHostedService : IHostedService
{
    private readonly IConfiguration _config;
    private List<HubConnection> _instanceConnections = new();

    public ClusterSyncHostedService(IConfiguration config)
    {
        _config = config;
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        var serviceName = _config["ClusterServiceName"]; // K8s Headless Service名称
        var namespaceName = _config["ClusterNamespace"] ?? "default";
        var replicaCount = int.Parse(_config["ReplicaCount"]); // 副本数，从配置或环境变量获取
        var currentPodIndex = int.Parse(Environment.GetEnvironmentVariable("POD_INDEX") ?? "0"); // 当前Pod序号，通过K8s Downward API注入

        for (int i = 0; i < replicaCount; i++)
        {
            if (i == currentPodIndex) continue; // 跳过自身实例

            var targetPodUrl = $"http://{serviceName}-{i}.{serviceName}.{namespaceName}.svc.cluster.local/hubs/clustersync";
            var connection = new HubConnectionBuilder()
                .WithUrl(targetPodUrl)
                .WithAutomaticReconnect()
                .Build();

            await connection.StartAsync(cancellationToken);
            _instanceConnections.Add(connection);
        }
    }

    public async Task StopAsync(CancellationToken cancellationToken)
    {
        foreach (var conn in _instanceConnections)
        {
            await conn.StopAsync(cancellationToken);
            await conn.DisposeAsync();
        }
    }
}

5. K8s部署配置 #

使用StatefulSet部署服务（确保Pod有稳定域名），并通过Downward API注入POD_INDEX环境变量：

apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: signalr-service
spec:
  replicas: 3
  serviceName: signalr-headless-service
  template:
    spec:
      containers:
      - name: signalr-app
        image: your-image:tag
        env:
        - name: POD_INDEX
          valueFrom:
            fieldRef:
              fieldPath: metadata.labels['statefulset.kubernetes.io/pod-name']
              # 或通过subpath截取序号，比如signalr-service-0 → 0
        # 其他容器配置
  serviceName: signalr-headless-service
---
apiVersion: v1
kind: Service
metadata:
  name: signalr-headless-service
spec:
  clusterIP: None
  selector:
    app: signalr-app
  ports:
  - port: 80
    targetPort: 80

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