时间戳

首页 > 解决方案 > AWS API Gateway Web Socket Api - 向所有连接的客户端广播消息

javascript - AWS API Gateway Web Socket Api - 向所有连接的客户端广播消息

问题描述

我使用 API Gateway 创建了一个 Web Socket Api，并且能够将客户端连接到它。

此外，我可以通过指定它ConnectionId并使用以下代码向连接的客户端发送消息：

const AWS = require('aws-sdk');
let apiGatewayManagementApi = new AWS.ApiGatewayManagementApi({
  apiVersion: '2018-11-29',
  endpoint: 'https://XXXXXXXXX.execute-api.sa-east-1.amazonaws.com/dev/',
  region: 'sa-east-1'
});
const params = {
  ConnectionId: 'YYYYYYYYYYYYY',
  Data: 'test'
};
apiGatewayManagementApi.postToConnection(params, function (err, data) {
  if (err) {
    console.log(err, err.stack); // an error occurred
  } else {
    console.log(data);           // successful response
  }
});

问题是我不需要区分客户端，因此我不想跟踪每个客户端的 ConnectionId，但是如果我在发送消息时将其删除，则会收到以下错误：Missing required key 'ConnectionId' in params

有没有办法向所有连接的客户端发送消息（不指定任何 ConnectionId）？

标签： javascriptwebsocketaws-lambdaaws-sdkaws-api-gateway

解决方案

不幸的是，您必须指定 ConnectionId。我见过的一种模式是在$connect事件中将连接信息持久化到 DynamoDB；那么你可以做这样的事情：

const connections = await getAllConnections();
const promises = connections.map(c => apiGwMgmtApi.postToConnection({ ConnectionId: c.connectionId, Data: 'test' }).promise());
await Promise.all(promises);

推荐阅读