[go] go 언어의 메시지 처리

08 Dec 2023

Go 언어는 효율적이고 빠른 메시지 처리를 지원하는 언어로, 여러 유형의 메시지를 처리하는 데 사용됩니다. Go 언어의 강력한 특징과 함께 어떻게 메시지를 처리하는지 살펴봅시다.

1. 메시지 큐 사용하기

Go 언어에서 메시지를 처리하는 일반적인 방법은 메시지 큐를 사용하는 것입니다. 메시지 큐는 비동기적으로 메시지를 보내고 받을 수 있으며, 서로 다른 시스템 간에 안정적으로 통신할 수 있는 방법을 제공합니다. RabbitMQ나 Apache Kafka와 같은 메시지 큐 시스템을 Go 언어에서 사용할 수 있습니다.

예시 코드:

package main

import (
    "log"
    "github.com/streadway/amqp"
)

func main() {
    // RabbitMQ에 연결
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatalf("연결 실패: %s", err)
    }
    defer conn.Close()

    // 채널 열기
    ch, err := conn.Channel()
    if err != nil {
        log.Fatalf("채널 열기 실패: %s", err)
    }
    defer ch.Close()

    // 메시지 큐 선언
    q, err := ch.QueueDeclare(
        "hello", // 큐 이름
        false,   // durable
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    if err != nil {
        log.Fatalf("큐 선언 실패: %s", err)
    }

    // 메시지 전송
    body := "Hello, RabbitMQ!"
    err = ch.Publish(
        "",
        q.Name,
        false,
        false,
        amqp.Publishing{
            ContentType: "text/plain",
            Body:        []byte(body),
        })
    if err != nil {
        log.Fatalf("메시지 전송 실패: %s", err)
    }
    log.Println("메시지 전송 성공")
}

2. 고루틴을 활용한 병렬 처리

Go 언어는 고루틴을 활용하여 간단하게 병렬 처리를 할 수 있습니다. 고루틴은 경량 스레드로, 여러 개의 고루틴을 사용하여 메시지를 동시에 처리할 수 있습니다. 따라서 고루틴을 이용한 병렬 처리는 Go 언어에서 메시지 처리를 효율적으로 수행하는 방법 중 하나입니다.

예시 코드:

package main

import (
    "fmt"
    "time"
)

func processMessage(msg string) {
    // 메시지를 처리하는 작업
    fmt.Println("메시지 처리 중:", msg)
    time.Sleep(1 * time.Second) // 가정: 메시지 처리에 1초 소요
    fmt.Println("메시지 처리 완료:", msg)
}

func main() {
    messages := []string{"msg1", "msg2", "msg3"}

    for _, msg := range messages {
        go processMessage(msg) // 고루틴을 사용하여 각 메시지를 병렬로 처리
    }

    time.Sleep(3 * time.Second) // 모든 메시지가 처리될 때까지 대기
}

결론

Go 언어는 메시지 큐를 활용한 효율적인 메시지 처리와 고루틴을 사용한 병렬 처리 등을 통해 메시지 처리를 간편하고 빠르게 수행할 수 있습니다. 다양한 방법을 사용하여 Go 언어로 메시지를 효율적으로 처리할 수 있으며, 이를 통해 효율적이고 안정적인 시스템을 구축할 수 있습니다.

내용을 구체화하기 위해 아래 두 가지 방법을 사용했습니다:

RabbitMQ를 사용한 메시지 큐 예시 코드
고루틴을 활용한 병렬 처리에 대한 예시 코드