Rails ActionCable高流量下订阅偶发失败问题排查求助

一、Redis适配器相关排查 #

• 调整Redis连接池配置：默认Action Cable的Redis连接池可能无法承载高流量，在config/cable.yml中增大pool参数（例如设为pool: 50，可根据服务器资源调整，建议值大于并发连接数的1/5），避免连接池耗尽导致订阅请求阻塞。
• 清理僵尸频道：定期检查Redis中action_cable/*前缀的频道，确认是否存在未正常销毁的僵尸频道。同时排查stream_for current_user生成的频道是否异常——比如高流量下current_user是否偶发为空，导致生成无效频道。
• 监控Redis性能：用redis-cli info stats查看pubsub_channels、used_memory_peak等指标，确认Redis是否存在内存不足、CPU过载的情况，这类问题会直接影响pubsub消息处理，导致订阅确认延迟或失败。

二、Action Cable服务器配置优化 #

• 调高worker池大小：在config/cable.yml中设置worker_pool_size: 8（默认是4，高流量下可调整至8-16），确保有足够的worker进程处理订阅请求。
• 配置订阅超时：在config/initializers/cable.rb中添加ActionCable.server.config.subscription_timeout = 30（单位秒），避免订阅请求无限阻塞，让客户端能及时处理失败逻辑。
• 校验current_user获取逻辑：在PerfTestChannel的subscribed方法中添加日志，打印current_user.id和请求ID，排查高并发下是否存在session丢失、用户ID为空的情况——这类异常会直接导致订阅失败。

三、Nginx-Ingress的WebSocket优化 #

• 补全WebSocket代理配置：确保nginx-ingress配置包含以下必要项，避免高流量下WebSocket升级异常：

  proxy_http_version 1.1;
  proxy_set_header Upgrade $http_upgrade;
  proxy_set_header Connection "upgrade";
  

• 增大nginx连接数：在nginx主配置中调整worker_connections 10240;，同时将worker_processes设为服务器CPU核心数，确保能承载足够的WebSocket连接。
• 开启会话粘性：WebSocket需要会话粘性，在ingress注解中添加以下配置，避免订阅请求被分发到不同的Action Cable节点：

  nginx.ingress.kubernetes.io/affinity: "cookie"
  nginx.ingress.kubernetes.io/session-cookie-name: "route"
  nginx.ingress.kubernetes.io/session-cookie-expires: "172800"
  nginx.ingress.kubernetes.io/session-cookie-max-age: "172800"
  

四、客户端与频道代码优化 #

• 优化客户端重试逻辑：将当前每秒两次的频繁重试改为指数退避，避免加重服务器负载：

  App.cable.subscriptions.create({ channel: 'PerfTestChannel' }, {
    retryCount: 0,
    rejected() {
      const delay = Math.min(1000 * Math.pow(2, this.retryCount), 30000);
      this.retryCount += 1;
      setTimeout(() => {
        App.cable.subscriptions.remove(this);
        App.cable.subscriptions.create({ channel: 'PerfTestChannel' }, this);
      }, delay);
    }
  });
  

• 减少频道端数据库查询：在客户端传递用户ID，避免频道中重复查询current_user（高流量下复杂查询会阻塞订阅）：

  // 客户端传递已获取的用户ID
  App.cable.subscriptions.create({ channel: 'PerfTestChannel', user_id: window.currentUserId }, ...)
  

  # 频道直接使用传递的ID
  class PerfTestChannel < ApplicationCable::Channel
    def subscribed
      user = User.find_by(id: params[:user_id])
      stream_for user if user.present?
    end
  end
  

五、日志与监控排查 #

• 开启Action Cable debug日志：在config/environments/production.rb中设置config.action_cable.log_level = :debug，查看订阅请求的完整流程，包括Redis交互、确认消息发送等细节。
• 排查Redis慢查询：开启Redis慢查询日志，确认是否存在pubsub相关的慢操作，导致订阅确认延迟。
• 监控连接与订阅指标：用Prometheus+Grafana等工具监控action_cable_connections_total、action_cable_subscriptions_total等指标，排查是否存在连接泄漏、订阅堆积的情况。

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