Go의 AMQP 연결은 글로벌이어야 합니까, 아니면 각 메시지에 대해 생성되어야 합니까?

AMQP 다이얼에서 연결 관리

Go에서 amqp.Dial 함수는 AMQP 서버에 대한 연결을 설정하는 데 사용됩니다. 하지만 메시지를 보낼 때마다 amqp.Dial 함수를 호출해야 하는지, 아니면 전역적으로 선언하여 여러 작업에 재사용할 수 있는지에 대한 우려가 있습니다.

전역 연결 관리

공식 문서에서 언급했듯이 TCP 연결은 설정하는 데 리소스 집약적일 수 있습니다. 성능을 최적화하기 위해 AMQP에는 채널 개념이 도입되어 단일 연결을 통해 여러 채널을 생성할 수 있습니다.

따라서 일반적으로 AMQP 연결은 전역 변수로 한 번만 생성하는 것이 좋습니다. 모든 후속 작업에 이를 재사용합니다. 이렇게 하면 매번 새로운 연결 설정과 관련된 오버헤드가 줄어듭니다.

스레드 안전성

amqp.Dial 함수는 스레드로부터 안전하며 여러 고루틴에서 동시에 호출할 수 있습니다. 이를 통해 필요한 경우 경합 조건 없이 여러 연결을 생성할 수 있습니다.

연결 실패 처리

연결 실패를 적절하게 처리하려면 Connection을 사용할 수 있습니다. 연결이 닫힐 때 알림을 받을 채널을 등록하는 NotifyClose 메서드입니다. 이를 통해 필요에 따라 감지하고 다시 연결할 수 있습니다.

제공된 예에서 코드는 채널을 수신하고 오류 발생 시 연결을 다시 설정하려고 시도합니다. 그러나 기존 연결을 끊고 메시지를 게시하려고 하면 오류가 발생합니다. 이는 기존 채널이 여전히 닫힌 연결에 대한 참조를 보유하고 있기 때문일 수 있습니다.

이 문제를 해결하려면 예기치 않은 동작을 방지하기 위해 연결을 다시 설정할 때 모든 활성 채널도 닫아야 합니다.

오류 처리의 예

다음은 연결 실패 처리를 통합한 예입니다.

<code class="go">import (
    "context"
    "log"
    "sync"
    "time"

    "github.com/streadway/amqp"
)

var (
    connOnce sync.Once
    conn     *amqp.Connection
)

func main() {
    connOnce.Do(func() {
        var err error
        conn, err = amqp.Dial("amqp://guest:guest@localhost:5672/")
        if err != nil {
            log.Panicf("Failed to connect: %v", err)
        }
    })

    c := make(chan *amqp.Error)
    conn.NotifyClose(c)

    go func() {
        for {
            err := <-c
            log.Println("reconnect: " + err.Error())
            connOnce.Do(func() {
                var err error
                conn, err = amqp.Dial("amqp://guest:guest@localhost:5672/")
                if err != nil {
                    log.Panicf("Failed to connect: %v", err)
                }
            })
            conn.NotifyClose(c)
            // Give time for any pending messages to be delivered
            // after reconnection
            time.Sleep(5 * time.Second)
        }
    }()

    // Create channels and perform operations here
    // ...

    // Close the connection when done
    defer conn.Close()
}</code>

이 예에서는 sync.Once를 사용하여 전역 연결이 생성됩니다. 한 번만 초기화되도록 입력하세요. Connection.NotifyClose 메서드는 연결 실패를 모니터링하고 필요에 따라 연결을 다시 설정하는 데 사용됩니다.

위 내용은 Go의 AMQP 연결은 글로벌이어야 합니까, 아니면 각 메시지에 대해 생성되어야 합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!