AWS SNS消息发布延迟过高问题求助

1. 替换同步HTTP客户端为异步实现 #

你当前使用的SNS同步客户端默认依赖同步HTTP客户端，SocketInputStream.read的阻塞延迟是同步IO的典型问题。建议切换为异步HTTP客户端，用非阻塞IO处理网络请求，避免单个慢请求阻塞线程：

protected val client: SnsClient = SnsClient.builder
    .endpointOverride(URI.create(endpoint))
    .region(region)
    .httpClientBuilder(NettyNioAsyncHttpClient.builder()) // 配置异步HTTP客户端
    .overrideConfiguration(
        ClientOverrideConfiguration
            .builder()
            .addMetricPublisher(metricsPublisher)
            .build()
    )
    .build()

2. 调整HTTP客户端连接池与超时参数 #

默认连接池配置可能无法应对突发请求，导致连接等待或复用不足，可调整以下参数优化：

val httpClient = NettyNioAsyncHttpClient.builder()
    .maxConcurrency(100) // 根据实例规格增大并发连接数
    .connectionTimeout(Duration.ofSeconds(2)) // 缩短连接超时时间
    .socketTimeout(Duration.ofSeconds(5)) // 设置Socket超时，避免长时间阻塞
    .build()

protected val client: SnsClient = SnsClient.builder
    .endpointOverride(URI.create(endpoint))
    .region(region)
    .httpClient(httpClient)
    .overrideConfiguration(...)
    .build()

3. 验证Endpoint配置合理性 #

确认endpointOverride使用的是同区域SNS官方Endpoint，避免跨区域或自定义Endpoint引入额外网络跳转。如果是自定义Endpoint，检查其背后的代理、防火墙规则是否存在链路瓶颈。

4. 自定义SDK重试策略 #

默认重试策略对延迟峰值的处理不够优化，可针对超时类错误配置快速重试：

val retryPolicy = RetryPolicy.builder()
    .numRetries(3)
    .retryCondition(RetryCondition.defaultRetryCondition())
    .backoffStrategy(BackoffStrategy.exponentialBackoff())
    .build()

protected val client: SnsClient = SnsClient.builder
    .endpointOverride(URI.create(endpoint))
    .region(region)
    .overrideConfiguration(
        ClientOverrideConfiguration.builder()
            .addMetricPublisher(metricsPublisher)
            .retryPolicy(retryPolicy)
            .build()
    )
    .httpClientBuilder(NettyNioAsyncHttpClient.builder())
    .build()

5. 优化EC2实例网络配置 #

• 查看CloudWatch中的NetworkIn/NetworkOut、TCP_Timeouts指标，确认是否存在带宽瓶颈或TCP连接异常；
• 确保EC2实例启用Enhanced Networking（r6a实例默认支持），并更新网络驱动至最新版本；
• 检查VPC子网的路由表、安全组配置，确保与SNS服务的通信无额外中转。

6. 批量发布消息（业务允许的情况下） #

将多条消息批量发布，减少单次请求频次，降低网络交互开销：

val publishRequests = listOf(
    PublishRequest.builder().topicArn("topic-arn").message("msg1").build(),
    PublishRequest.builder().topicArn("topic-arn").message("msg2").build()
)
client.batchPublish(BatchPublishRequest.builder().publishRequests(publishRequests).build())

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