AWS - 使用 @connections websocket 回调 url 从后端发送响应（单向） - API Gateway websocket 协议

Posted 2023-03-28

【中文标题】AWS - 使用 @connections websocket 回调 url 从后端发送响应（单向） - API Gateway websocket 协议

【英文标题】：AWS - Using @connections websocket call back url to send response from back-end(one-way) - API Gateway websocket protocol

【发布时间】：2019-10-25 13:20:05

【问题描述】：

我一直在努力通过 aws 提供的回调 url (https://******.execute-api.us-east-1.amazonaws.com/test/@connections) 向连接的客户端发送响应.

在我的后端有下面的代码来发送响应，这是一种通信方式。

    AwsClientBuilder.EndpointConfiguration config =
            new AwsClientBuilder.EndpointConfiguration("https://*********.execute-api.us-east-1.amazonaws.com/test", "us-east-1");
    AmazonApiGatewayManagementApi client = AmazonApiGatewayManagementApiClientBuilder.standard()
            .withEndpointConfiguration(config).build();


    PostToConnectionRequest request = new PostToConnectionRequest();
    request.withConnectionId("bGYcWek5oAMCKwA=");
    Charset charset = Charset.forName("UTF-8");
    CharsetEncoder encoder = charset.newEncoder();
    ByteBuffer buff = null;
    try 
        buff = encoder.encode(CharBuffer.wrap("Hello from lambda"));
     catch (CharacterCodingException e) 
        log.error("Error while encoding", e);
    
    request.withData(buff);
    PostToConnectionResult result = client.postToConnection(request);
    log.info("Result of websocket send:\n" + result);

获取服务：AmazonApiGatewayManagementApi；状态码：403；错误代码：InvalidSignatureException异常。

注意：我已经完成了所有设置，例如证书和 aws 访问密钥。

正如 aws 文档中提到的，我尝试过使用 awscurl ，它正在工作。我能够在 websocket 连接的客户端上看到响应。 https://docs.amazonaws.cn/en_us/apigateway/latest/developerguide/apigateway-how-to-call-websocket-api-connections.html

【参考方案1】：

您需要提供您的AWS_ACCESS_KEY_ID 和AWS_SECRET_ACCESS_KEY 以形成BasicAWSCredentials。

BasicAWSCredentials awsCreds = new BasicAWSCredentials("AWS_ACCESS_KEY_ID", "AWS_SECRET_ACCESS_KEY");
AmazonApiGatewayManagementApi client = AmazonApiGatewayManagementApiClientBuilder.standard().withCredentials(new AWSStaticCredentialsProvider(awsCreds)).withEndpointConfiguration(config).build();