GitLab CI中使用Go SDK调用LocalStack SQS无法接收消息求助

问题现象 #

本地环境测试正常，可正常发送并接收SQS消息；但在GitLab CI runner中，能成功获取队列URL、发送消息（返回有效MessageID），但接收消息时始终返回空数组，导致测试失败。

针对性解决方法 #

1. 移除消息延迟配置 #

代码中SendMessageInput设置了DelaySeconds: 10，这会让消息10秒后才进入可见状态。本地测试可能因环境特性或隐性等待正常运行，但CI中测试是同步执行的，发送后立刻接收必然拿不到消息。

修改后的发送消息代码：

sMInput := &sqs.SendMessageInput{
    // 删除DelaySeconds字段或设置为0
    MessageAttributes: map[string]types.MessageAttributeValue{
        "Title": {
            DataType:    aws.String("String"),
            StringValue: aws.String("The Whistler"),
        },
        "Author": {
            DataType:    aws.String("String"),
            StringValue: aws.String("John Grisham"),
        },
        "WeeksOn": {
            DataType:    aws.String("Number"),
            StringValue: aws.String("6"),
        },
    },
    MessageBody: aws.String("Information about current NY Times fiction bestseller for week of 12/11/2016."),
    QueueUrl:    queueURL,
}

2. 增加接收重试机制 #

LocalStack的SQS模拟实现存在异步写入延迟，CI环境资源有限时更明显。发送消息后不要立刻接收，增加循环重试逻辑：

var msgResult *sqs.ReceiveMessageOutput
var err error
maxRetries := 5
retryInterval := time.Second * 2

for i := 0; i < maxRetries; i++ {
    msgResult, err = client.ReceiveMessage(context.TODO(), gMInput)
    if err != nil {
        t.Error("接收消息出错:", err)
        return
    }
    if len(msgResult.Messages) > 0 {
        break
    }
    time.Sleep(retryInterval)
    fmt.Printf("第%d次重试接收消息...\n", i+1)
}

if len(msgResult.Messages) == 0 {
    t.Error("重试多次后仍未收到消息")
    return
}

3. 确保LocalStack在CI中完全启动 #

GitLab CI中启动LocalStack后，必须等待服务就绪再执行测试。在.gitlab-ci.yml中添加健康检查：

test:
  stage: test
  services:
    - name: localstack/localstack:latest
      alias: localstack
  script:
    # 等待SQS服务就绪
    - until curl -s http://localstack:4566/_localstack/health | grep -q '"sqs": "running"'; do echo "等待LocalStack启动..."; sleep 2; done
    # 运行Go测试
    - go test ./... -v

4. 验证SQS客户端的CI环境配置 #

确保Go的AWS客户端正确指向LocalStack端点，且禁用真实AWS签名验证：

func setup() {
    cfg, err := config.LoadDefaultConfig(context.TODO(),
        config.WithRegion("us-east-1"),
        config.WithEndpointResolverWithOptions(aws.EndpointResolverWithOptionsFunc(
            func(service, region string, options ...interface{}) (aws.Endpoint, error) {
                // CI中使用服务别名localstack而非localhost
                return aws.Endpoint{
                    URL:           "http://localstack:4566",
                    SigningRegion: "us-east-1",
                }, nil
            },
        )),
        config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider("dummy", "dummy", "dummy")),
    )
    if err != nil {
        panic(err)
    }
    client = sqs.NewFromConfig(cfg)
}

5. 预先创建测试队列 #

在CI脚本中提前创建测试队列，避免测试执行时队列未初始化：

# 使用LocalStack CLI创建队列
- awslocal sqs create-queue --queue-name testing-queue

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