如何实现Rails应用向Node.js WebSocket服务器传输数据？

嘿，刚好能帮你解决这个问题！我来一步步梳理Rails怎么和Node.js WebSocket服务器配合，实现数据库操作后通知客户端的场景～

你的需求本质是「Rails触发数据库事件 → 通知Node.js WebSocket服务器 → Node.js推送给在线客户端」，核心要解决的是Rails到Node.js的消息传递问题，这里有两种常用方案，我分别给你讲清楚：

这个方案是Rails在数据库操作完成后，通过HTTP POST请求把消息发给Node.js的专用接口，Node.js收到后再推给所有在线客户端。

1. 搭建Node.js WebSocket服务器（带HTTP接收接口） #

用ws库（Node.js最常用的WebSocket工具）搭建服务器，同时新增一个HTTP接口专门接收Rails的通知：

const WebSocket = require('ws');
const http = require('http');
const server = http.createServer();
const wss = new WebSocket.Server({ server });

// 存储所有在线的WebSocket客户端
const connectedClients = new Set();

// 处理客户端连接
wss.on('connection', (ws) => {
  connectedClients.add(ws);
  console.log('新客户端上线');

  // 客户端断开时从集合中移除，避免内存泄漏
  ws.on('close', () => {
    connectedClients.delete(ws);
    console.log('客户端下线');
  });
});

// 新增HTTP接口，接收Rails的通知请求
server.on('request', (req, res) => {
  if (req.method === 'POST' && req.url === '/send-notification') {
    let requestBody = '';
    req.on('data', (chunk) => {
      requestBody += chunk.toString();
    });

    req.on('end', () => {
      try {
        const { apiKey, payload } = JSON.parse(requestBody);
        
        // 安全验证：一定要用环境变量存密钥，别硬编码！
        if (apiKey !== process.env.WS_SERVER_API_KEY) {
          res.writeHead(403);
          return res.end('无权访问');
        }

        // 把消息推送给所有在线客户端
        connectedClients.forEach(client => {
          if (client.readyState === WebSocket.OPEN) {
            client.send(JSON.stringify(payload));
          }
        });

        res.writeHead(200);
        res.end('通知已推送');
      } catch (err) {
        res.writeHead(400);
        res.end('无效的请求格式');
      }
    });
  } else {
    res.writeHead(404);
    res.end('接口不存在');
  }
});

const PORT = process.env.WS_PORT || 8080;
server.listen(PORT, () => {
  console.log(`WebSocket服务器运行在端口 ${PORT}`);
});

2. Rails端触发通知（用模型回调+异步任务） #

别在回调里同步发HTTP请求，会阻塞用户的请求响应！用Rails的Active Job把通知任务丢到后台处理：

首先创建一个异步任务：

# app/jobs/websocket_notification_job.rb
class WebSocketNotificationJob < ApplicationJob
  queue_as :default

  def perform(payload)
    require 'httparty'

    response = HTTParty.post(
      "#{ENV['WS_SERVER_URL']}/send-notification",
      body: {
        apiKey: ENV['WS_SERVER_API_KEY'],
        payload: payload
      }.to_json,
      headers: { 'Content-Type' => 'application/json' }
    )

    # 记录日志方便排查问题
    if response.success?
      Rails.logger.info "WebSocket通知发送成功: #{payload}"
    else
      Rails.logger.error "WebSocket通知发送失败: #{response.body}"
      # 可选：添加重试逻辑，比如 retry_on 异常类型
    end
  end
end

然后在你的业务模型里加回调，触发这个异步任务：

class Post < ApplicationRecord
  # 在创建/更新数据库记录后触发
  after_commit :trigger_websocket_notification, on: [:create, :update]

  private

  def trigger_websocket_notification
    WebSocketNotificationJob.perform_later(
      event_type: 'post_updated',
      data: { id: id, title: title, content: content } # 这里放你要推给客户端的数据
    )
  end
end

如果你的项目并发量高，或者希望Rails和Node.js彻底解耦，用Redis的发布订阅做中间件是更好的选择：Rails往Redis的指定频道发消息，Node.js订阅这个频道，收到消息后直接推给客户端。

1. Rails端发布消息到Redis #

# 模型回调里的方法
def trigger_websocket_notification
  redis = Redis.new(url: ENV['REDIS_URL'])
  redis.publish(
    'post_updates', # Redis频道名，自己定义即可
    {
      event_type: 'post_updated',
      data: { id: id, title: title }
    }.to_json
  )
end

2. Node.js端订阅Redis频道并推送 #

修改之前的Node.js代码，加上Redis订阅逻辑：

const WebSocket = require('ws');
const http = require('http');
const redis = require('redis');
const server = http.createServer();
const wss = new WebSocket.Server({ server });
const connectedClients = new Set();

// 处理WebSocket客户端连接逻辑和之前一致
wss.on('connection', (ws) => {
  connectedClients.add(ws);
  ws.on('close', () => connectedClients.delete(ws));
});

// 订阅Redis频道
const redisSubscriber = redis.createClient({ url: process.env.REDIS_URL });
redisSubscriber.subscribe('post_updates');

redisSubscriber.on('message', (channel, message) => {
  // 收到Redis消息后推给所有在线客户端
  connectedClients.forEach(client => {
    if (client.readyState === WebSocket.OPEN) {
      client.send(message);
    }
  });
});

// 启动服务器逻辑和之前一致
const PORT = process.env.WS_PORT || 8080;
server.listen(PORT, () => {
  console.log(`WebSocket服务器运行在端口 ${PORT}`);
});

• 安全问题：无论是HTTP接口还是Redis，都要做好身份验证，密钥一定要存在环境变量里，绝对不能硬编码到代码中。
• 错误处理：比如Rails发消息失败时的重试机制、Node.js客户端断开后的资源清理，这些细节要加到代码里，避免内存泄漏或者消息丢失。
• 部署细节：Node.js服务器要和Rails服务器在同一个内网（或者用公网域名），确保能互相访问；Redis如果是多服务共用的，要做好权限控制。

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