如何在 Golang 框架中配置 Amazon SQS 消息队列？

import (
    "context"
    "fmt"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/sqs"
)

func sendMessage(queueURL string, messageBody string) error {
    // 创建一个新的 AWS 会话，它将用于创建 SQS 客户端
    sess, err := session.NewSession()
    if err != nil {
        return fmt.Errorf("failed to create new session: %v", err)
    }

    // 创建一个 SQS 客户端
    client := sqs.New(sess)

    // 将消息发送到队列
    _, err = client.SendMessageWithContext(context.Background(), &sqs.SendMessageInput{
        MessageBody: aws.String(messageBody),
        QueueUrl:    aws.String(queueURL),
    })
    if err != nil {
        return fmt.Errorf("failed to send message: %v", err)
    }

    return nil
}

import (
    "context"
    "fmt"
    "time"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/sqs"
)

func receiveMessage(queueURL string) (*sqs.Message, error) {
    // 创建一个新的 AWS 会话，它将用于创建 SQS 客户端
    sess, err := session.NewSession()
    if err != nil {
        return nil, fmt.Errorf("failed to create new session: %v", err)
    }

    // 创建一个 SQS 客户端
    client := sqs.New(sess)

    // 从队列接收消息，等待最长 10 秒
    result, err := client.ReceiveMessageWithContext(context.Background(), &sqs.ReceiveMessageInput{
        QueueUrl:        aws.String(queueURL),
        WaitTimeSeconds: aws.Int64(10),
    })
    if err != nil {
        return nil, fmt.Errorf("failed to receive message: %v", err)
    }

    // 返回接收到的第一条消息，如果没有消息则返回 nil
    if len(result.Messages) > 0 {
        return result.Messages[0], nil
    }

    return nil, nil
}