使用Vapor 4结合Soto SDK调用SES服务发邮件遇错误求助

这个错误的核心是你传递给SES客户端的EventLoop，和客户端初始化时依赖的EventLoopGroup不属于同一个实例。AsyncHTTPClient强制要求所有网络操作必须在它自身管理的EventLoopGroup内执行，一旦检测到外部EventLoop，就会触发这个预检查失败。

1. 配置阶段：复用Vapor的EventLoopGroup初始化SES客户端 #

在configure.swift中，必须绑定Vapor自带的EventLoopGroup和共享HTTPClient，避免创建独立的EventLoop实例：

import Vapor
import SotoSES

func configure(_ app: Application) throws {
    // 从环境变量/配置文件读取AWS配置（推荐用环境变量管理敏感信息）
    let awsConfig = AWSClientConfig(
        region: .usEast1, // 替换为你的SES服务区域
        credentialsProvider: .environment
    )
    
    // 关键：复用Vapor的EventLoopGroup和共享HTTPClient
    let awsClient = AWSClient(
        credentialProvider: awsConfig.credentialsProvider,
        httpClientProvider: .shared(app.http.client.shared),
        eventLoopGroup: app.eventLoopGroup
    )
    
    // 将SES客户端注册到Vapor服务容器
    app.services.register(SES(client: awsClient))
    
    try routes(app)
}

2. 路由阶段：使用请求绑定的EventLoop执行SES操作 #

在路由处理函数中，直接使用当前请求的req.eventLoop，确保和客户端的EventLoopGroup匹配：

import Vapor
import SotoSES

func routes(_ app: Application) throws {
    app.post("send-email") { req async throws -> HTTPStatus in
        // 从服务容器获取SES客户端实例
        let ses = req.application.ses
        
        // 构建SES邮件请求参数
        let emailRequest = SES.SendEmailRequest(
            destination: SES.Destination(toAddresses: ["target@example.com"]),
            message: SES.Message(
                body: SES.Body(
                    html: SES.Content(data: "<h1>Vapor SES测试邮件</h1>"),
                    text: SES.Content(data: "这是一封通过Vapor+SES发送的测试邮件")
                ),
                subject: SES.Content(data: "Vapor SES测试")
            ),
            source: "verified-sender@example.com" // 替换为你已在SES验证的发件地址
        )
        
        // 关键：用req.eventLoop执行SES请求，保证EventLoop归属正确
        _ = try await ses.sendEmail(emailRequest, on: req.eventLoop)
        
        return .ok
    }
}

3. 常见排查点 #

• 禁止手动创建独立的MultiThreadedEventLoopGroup给SES客户端，必须复用Vapor的app.eventLoopGroup
• 不要在路由中调用EventLoopGroup.next()获取随机EventLoop，直接用req.eventLoop是最安全的选择
• 确保Soto版本和Vapor 4的AsyncHTTPClient版本兼容，可通过Package.swift锁定兼容版本

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