Rails应用如何作为WebSocket客户端连接外部服务器？

嗨，这个问题确实挺戳中ActionCable的盲区——它的文档几乎全是讲怎么让Rails当WebSocket服务端给前端发消息，但要让Rails反过来当客户端连外部WS服务器，我们有几种实用的方案，给你一步步拆解：

如果外部服务器是普通的WebSocket服务（不一定是ActionCable），推荐用websocket-client-simple这个轻量的Ruby库，它能轻松处理长连接、消息收发这些核心需求。

步骤1：安装依赖 #

把gem加到你的Gemfile里：

gem 'websocket-client-simple'

然后跑bundle install完成安装。

步骤2：编写客户端服务类 #

在Rails里创建一个专门的服务类来管理WebSocket连接，比如app/services/external_websocket_client.rb：

# app/services/external_websocket_client.rb
require 'websocket-client-simple'

class ExternalWebsocketClient
  def initialize
    @external_ws_url = 'ws://your-external-server.com/your-ws-endpoint'
    establish_connection
  end

  private

  def establish_connection
    @ws = WebSocket::Client::Simple.connect(@external_ws_url)

    # 连接成功后的回调
    @ws.on :open do
      Rails.logger.info "✅ 成功连接到外部WebSocket服务器"
      # 如果服务器需要认证，这里可以发送认证消息
      @ws.send(JSON.generate({ auth_token: 'your-secret-token' }))
    end

    # 接收消息的回调
    @ws.on :message do |msg|
      Rails.logger.info "📥 收到外部WS消息：#{msg.data}"
      # 这里写你的消息处理逻辑——比如存数据库、广播给Rails前端等
      process_incoming_message(msg.data)
    end

    # 连接关闭的回调
    @ws.on :close do |e|
      Rails.logger.warn "❌ 与外部WS断开连接：#{e.reason}"
      # 可选：自动重连，避免断连后就停了
      retry_connection
    end

    # 错误处理回调
    @ws.on :error do |e|
      Rails.logger.error "❌ WS客户端出错：#{e.message}"
    end
  end

  def process_incoming_message(raw_data)
    # 示例：解析JSON消息并处理
    parsed_data = JSON.parse(raw_data)
    # 比如把数据存到数据库
    # ExternalData.create!(content: parsed_data)
    # 或者通过ActionCable广播给Rails前端
    # ActionCable.server.broadcast('external_data_channel', parsed_data)
  end

  def retry_connection
    Rails.logger.info "🔄 5秒后尝试重连..."
    sleep 5
    establish_connection
  end
end

步骤3：启动客户端 #

要让这个客户端在Rails启动后自动运行，而且不阻塞主线程，我们可以在初始化器里加一段代码，比如config/initializers/start_external_ws.rb：

# config/initializers/start_external_ws.rb
Rails.application.config.after_initialize do
  # 用后台线程启动WS客户端，避免卡住Rails启动流程
  Thread.new do
    ExternalWebsocketClient.new
  end
end

如果外部服务器本身就是用ActionCable搭建的，那可以直接用Rails自带的ActionCable::Client来连接，这样能直接兼容ActionCable的频道机制：

# app/services/action_cable_external_client.rb
require 'action_cable/client'

class ActionCableExternalClient
  def initialize
    @external_cable_url = 'ws://your-actioncable-server.com/cable'
    connect_to_channel
  end

  private

  def connect_to_channel
    @client = ActionCable::Client.new(@external_cable_url)

    # 订阅目标频道
    @client.subscribe('ExternalDataChannel') do |data|
      Rails.logger.info "📥 通过ActionCable客户端收到消息：#{data}"
      # 处理消息逻辑
    end

    # 给频道发送消息（如果需要的话）
    @client.perform('ExternalDataChannel', 'send_message', { content: '来自Rails客户端的问候' })
  end
end

启动方式和方案一一样，放在后台线程里即可。

• 线程安全：如果你的客户端需要和Rails的数据库等资源交互，要注意线程安全，避免出现竞态条件。
• 资源清理：在Rails关闭时（比如部署重启），记得优雅关闭WebSocket连接，避免资源泄漏。
• 重连策略：不要盲目重连，可以加个重试次数限制，避免给外部服务器造成压力。
• 认证机制：根据外部服务器的要求，选择合适的认证方式——比如在握手时加HTTP头，或者发送初始认证消息。

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