Go에서 Google Cloud Pub/Sub 사용: 전체 가이드

클라우드 컴퓨팅의 등장으로 점점 더 많은 기업과 개발자가 클라우드 서비스를 사용하여 애플리케이션을 구축하기 시작했습니다. 이러한 클라우드 서비스에서 Message Queue는 대량의 데이터를 전송하고 처리하는 데 널리 사용됩니다. Google Cloud Pub/Sub는 Google Cloud Platform에서 개발된 다양한 애플리케이션을 위한 효율적이고 안정적이며 사용하기 쉬운 메시징 서비스입니다. 이 문서에서는 Go 언어로 Google Cloud Pub/Sub를 사용하는 방법을 소개합니다.

Google Cloud Pub/Sub 개요

Google Cloud Pub/Sub는 Google Cloud에서 안정적인 실시간 애플리케이션을 구축하는 데 필요한 인프라를 제공하도록 설계된 완전 관리형 메시징 서비스입니다. 발행과 구독 간에 메시지를 전달할 수 있는 발행/구독 모델입니다. Google Cloud는 백그라운드에서 모든 메시지 전송 및 관리를 처리하므로 API를 호출하여 메시지를 보내고 받기만 하면 됩니다.

Go 언어로 Google Cloud Pub/Sub 사용

Go 언어로 Google Cloud Pub/Sub를 사용하려면 다음 세 단계를 완료해야 합니다.

1. Google Cloud Pub/Sub 프로젝트 생성 및 승인 설정
2. Google Cloud Pub/ 사용 Sub API 주제 생성 및 구독
3. Go 언어로 Google Cloud Pub/Sub 라이브러리를 사용하여 메시지 보내고 받기

1단계: Google Cloud Pub/Sub 프로젝트 생성 및 승인 설정

Google Cloud Console에서 프로젝트 생성, 유료 계정으로 결제하고 Cloud Pub/Sub API를 활성화합니다. 그런 다음 서비스 계정을 만들고 해당 역할을 'Pub/Sub 관리자' 및 'Pub/Sub 게시자'로 설정합니다. 또한 Go에서 Google Cloud Pub/Sub를 사용할 때 인증할 서비스 계정에 대한 키를 만들어야 합니다.

2단계: Google Cloud Pub/Sub API를 사용하여 주제 생성 및 구독

Google Cloud Pub/Sub의 콘솔 또는 API를 사용하여 주제 및 구독을 생성합니다. 주제는 메시지를 보낼 수 있는 발신자 또는 게시자를 나타냅니다. 구독은 주제로부터 메시지를 받을 수 있는 수신자 또는 구독자를 나타냅니다. 주제와 구독은 모두 고유한 이름으로 식별되며 동일한 Google Cloud 프로젝트의 어느 곳에서나 사용할 수 있습니다. Google Cloud의 클라이언트 라이브러리를 사용하면 주제와 구독을 쉽게 만들고 관리할 수 있습니다. Go에서는 Google Cloud Pub/Sub 라이브러리를 사용하여 주제와 구독을 만들 수 있습니다.

3단계: Go 언어로 Google Cloud Pub/Sub 라이브러리를 사용하여 메시지를 보내고 받습니다.

Go 프로젝트에서 Google Cloud Pub/Sub 라이브러리를 사용하여 메시지를 보내고 받습니다. 메시지를 보내기 전에 PublishRequest를 만들고 구독 이름과 메시지를 설정하세요. Publish 메서드는 구독한 주제에 메시지를 보냅니다. 메시지를 받기 전에 구독을 만들고 수신 메서드를 사용하여 주제에서 메시지를 기다립니다. 마지막으로 Decode 메서드가 호출되어 수신된 메시지를 디코딩합니다. 다음은 메시지 전송 및 수신을 위한 Go 샘플 코드입니다.

package main

import (
    "context"
    "fmt"

    "cloud.google.com/go/pubsub"
)

func main() {
    // Set Google Cloud credentials and project ID
    ctx := context.Background()
    projectID := "your-project-id"
    client, err := pubsub.NewClient(ctx, projectID)
    if err != nil {
        fmt.Println(err)
    }
    
    // Create topic and subscription
    topicName := "test-topic"
    subscriptionName := "test-subscription"
    topic, err := client.CreateTopic(ctx, topicName)
    if err != nil {
        fmt.Println(err)
    }
    _, err = client.CreateSubscription(ctx, subscriptionName, pubsub.SubscriptionConfig{
        Topic: topic,
    })
    if err != nil {
        fmt.Println(err)
    }

    // Send message to topic
    message := "test message"
    result := topic.Publish(ctx, &pubsub.Message{
        Data: []byte(message),
    })
    _, err = result.Get(ctx)
    if err != nil {
        fmt.Println(err)
    }

    // Receive message from subscription
    sub := client.Subscription(subscriptionName)
    err = sub.Receive(ctx, func(ctx context.Context, msg *pubsub.Message) {
        fmt.Printf("Received message: %s
", string(msg.Data))
        msg.Ack()
    })
    if err != nil {
        fmt.Println(err)
    }
}

결론

Google Cloud Pub/Sub는 Google Cloud Platform에 구축된 다양한 애플리케이션을 위한 효율적이고 안정적이며 사용하기 쉬운 메시징 서비스입니다. Go 언어로 Google Cloud Pub/Sub를 사용하려면 Google Cloud Pub/Sub 프로젝트 생성 및 승인 설정, Google Cloud Pub/Sub API를 사용하여 주제 및 구독 생성, Google Cloud Pub/Sub 사용의 세 단계를 완료해야 합니다. Go 언어 라이브러리는 메시지를 보내고 받습니다. Google Cloud Pub/Sub를 사용하면 메시징을 크게 단순화하고 애플리케이션의 안정성과 효율성을 높일 수 있습니다.

위 내용은 Go에서 Google Cloud Pub/Sub 사용: 전체 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!