如何在多台横向扩展的EC2服务器上向所有用户推送信息？

嘿，我完全懂你的痛点——单服务器上用SocketIO跑实时推送顺风顺水，但一到多服务器横向扩展就卡壳了，还误以为AWS的推送服务只针对移动设备，别慌，这事儿有成熟的解决方案！

1. 最适配的核心方案：用ElastiCache Redis做SocketIO跨节点事件同步 #

SocketIO默认是单节点内存存储连接和事件，多服务器节点之间没法共享事件，所以核心是加一个全局消息中间件让所有节点同步事件，而Amazon ElastiCache for Redis是最适合这个场景的选择——SocketIO官方就支持Redis适配器，能轻松实现跨节点事件广播。

具体操作步骤： #

• 部署ElastiCache Redis集群：在AWS控制台创建ElastiCache的Redis集群（建议选主从模式或集群模式，保证高可用），记下集群的端点地址和端口。
• 修改SocketIO服务代码：安装SocketIO的Redis适配器包，让所有服务器节点连接到同一个Redis实例，这样一个节点收到的变更事件会通过Redis广播到所有节点，所有在线用户都能收到推送。
  举个Node.js的代码示例：

  const { Server } = require('socket.io');
  const { createAdapter } = require('@socket.io/redis-adapter');
  const { createClient } = require('redis');
  
  // 初始化SocketIO服务
  const io = new Server();
  // 连接到ElastiCache Redis实例
  const pubClient = createClient({ url: 'redis://你的ElastiCache端点地址:6379' });
  const subClient = pubClient.duplicate();
  
  // 连接成功后设置适配器
  Promise.all([pubClient.connect(), subClient.connect()]).then(() => {
    io.adapter(createAdapter(pubClient, subClient));
  });
  
  // 后续的事件监听和推送逻辑和单服务器时一致
  io.on('connection', (socket) => {
    // 比如用户订阅某类记录列表
    socket.on('subscribe-list', (listType) => {
      socket.join(`list:${listType}`);
    });
    // 当有变更时，向对应列表的所有订阅者推送摘要
    io.to(`list:${listType}`).emit('record-changed', changeSummary);
  });
  

• 部署SocketIO服务：用ECS（弹性容器服务）或EKS（弹性Kubernetes服务）来托管你的SocketIO服务，这样可以根据负载自动横向扩展实例数量；前端用户连接时，用Application Load Balancer（ALB）转发WebSocket请求——ALB原生支持WebSocket协议，还能自动分发流量到后端实例。

2. 替代方案：Amazon SNS + WebSocket（适合已有SNS生态的场景） #

你之前误解了AWS推送服务的能力：Amazon SNS不仅支持移动推送，还支持WebSocket、HTTP/S等多种订阅端点。如果你的系统已经在使用SNS，可以用这个方案：

• 创建一个SNS主题，对应你要推送的记录类型；
• 让每台SocketIO服务器作为订阅者（订阅SNS主题的WebSocket或HTTP端点）；
• 当有数据变更时，后端服务将变更摘要发布到对应SNS主题，所有订阅的SocketIO服务器都会收到消息，再推送给各自连接的用户。

不过这个方案比Redis适配器稍复杂，更适合已经融入SNS生态的场景，一般优先推荐Redis方案。

3. 关于无服务器的补充说明 #

你提到数据流庞大所以不考虑无服务器，这个判断很准确：无服务器（比如Lambda + API Gateway WebSocket）更适合短连接或低并发场景，大量长连接会触发频繁的冷启动，而且计费模式（按请求时长）也不如长期运行的ECS/EKS实例划算，你的选择是对的。

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