Golang에서 RabbitMQ를 사용한 다중 메시지 모드 비교 및 선택
- WBOY원래의
- 2023-09-28 12:10:441267검색
Golang에서 RabbitMQ를 사용한 다중 메시지 모드 비교 및 선택
소개:
분산 시스템에서 메시지 큐는 메시지의 송신자와 수신자를 분리하는 데 사용되는 일반적인 통신 메커니즘입니다. 현재 가장 인기 있는 메시지 대기열 중 하나인 RabbitMQ는 개발자가 선택할 수 있는 다양한 메시지 모드를 제공합니다. 이 기사에서는 RabbitMQ의 4가지 클래식 메시지 모드인 단순 대기열, 작업 대기열, 게시/구독 모드 및 주제 모드를 비교하고 해당 특성과 적용 가능한 시나리오를 분석하고 Golang 샘플 코드를 제공합니다.
1. Simple Queue
Simple Queue는 소비자에게 메시지를 보내는 RabbitMQ의 가장 기본적인 메시징 모드입니다. 메시지는 대기열로 전송되고 소비자가 차례로 읽습니다.
특징:
- 메시지는 한 명의 소비자만 소비할 수 있습니다.
- 동일한 대기열을 듣는 소비자가 여러 명인 경우 메시지는 소비자에게 균등하게 배포됩니다.
- 처리 속도가 빠른 소비자는 더 많은 메시지를 소비하게 됩니다.
적용 가능한 시나리오:
- 로그 수집, 작업 배포 등과 같이 작업이나 메시지를 여러 작업 단위로 배포해야 하는 응용 시나리오.
샘플 코드:
package main
import (
"log"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
q, err := ch.QueueDeclare(
"simple_queue",
false,
false,
false,
false,
nil,
)
failOnError(err, "Failed to declare a queue")
msgs, err := ch.Consume(
q.Name,
"",
true,
false,
false,
false,
nil,
)
failOnError(err, "Failed to register a consumer")
forever := make(chan bool)
go func() {
for d := range msgs {
log.Printf("Received a message: %s", d.Body)
}
}()
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
<-forever
}2. 작업 대기열(Work Queue)
작업 대기열 모드는 여러 소비자를 사용하여 대기열의 메시지를 공동으로 처리하는 메시지 부하 분산 메커니즘입니다. 작업 대기열 모드를 사용하면 메시지가 대기열로 전송되어 소비자가 순서대로 가져와 처리합니다.
기능:
- 메시지는 한 명의 소비자만 처리할 수 있습니다.
- 각 소비자가 처리하는 작업은 상대적으로 동일합니다. 즉, 처리 속도가 빠른 소비자가 더 많은 메시지를 처리합니다.
적용 가능한 시나리오:
- 이미지 처리, 비디오 트랜스코딩 등과 같은 백그라운드 작업 처리
샘플 코드:
package main
import (
"log"
"os"
"strconv"
"strings"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
q, err := ch.QueueDeclare(
"work_queue",
true,
false,
false,
false,
nil,
)
failOnError(err, "Failed to declare a queue")
body := bodyFrom(os.Args)
err = ch.Publish(
"",
q.Name,
false,
false,
amqp.Publishing{
DeliveryMode: amqp.Persistent,
ContentType: "text/plain",
Body: []byte(body),
})
failOnError(err, "Failed to publish a message")
log.Printf(" [x] Sent %s", body)
}
func bodyFrom(args []string) string {
var s string
if (len(args) < 2) || os.Args[1] == "" {
s = "Hello, World!"
} else {
s = strings.Join(args[1:], " ")
}
return strconv.Itoa(os.Getpid()) + ":" + s
}3. 게시/구독 모드(Publish/Subscribe)
게시/구독 모드에서는 모든 구독자에게 메시지가 방송됩니다. 모든 구독자는 동일한 메시지를 받게 됩니다.
특징:
- 모든 메시지는 모든 구독자에게 방송됩니다.
- 구독자마다 메시지 처리 논리가 다를 수 있습니다.
적용 가능한 시나리오:
- 로그 방송, 알림 방송 등과 같은 방송 메시지
샘플 코드:
package main
import (
"log"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
err = ch.ExchangeDeclare(
"logs",
"fanout",
true,
false,
false,
false,
nil,
)
failOnError(err, "Failed to declare an exchange")
q, err := ch.QueueDeclare(
"",
false,
false,
true,
false,
nil,
)
failOnError(err, "Failed to declare a queue")
err = ch.QueueBind(
q.Name,
"",
"logs",
false,
nil,
)
failOnError(err, "Failed to bind a queue")
msgs, err := ch.Consume(
q.Name,
"",
true,
false,
false,
false,
nil,
)
failOnError(err, "Failed to register a consumer")
forever := make(chan bool)
go func() {
for d := range msgs {
log.Printf("Received a message: %s", d.Body)
}
}()
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
<-forever
}4. 토픽 모드(Topic)
토픽 모드는 토픽의 와일드카드 규칙을 기반으로 토픽과 일치하는 구독자에게 메시지를 보내는 좀 더 복잡한 메시지 모드입니다.
특징:
- 메시지는 주제 일치 규칙을 통해 라우팅됩니다.
- 와일드카드 형식으로 주제 일치를 지원합니다.
- 다양한 구독자가 관심 있는 주제에 따라 구독할 수 있습니다.
적용 가능한 시나리오:
- 주제 기반 메시지 필터링 및 라우팅이 필요한 시나리오.
샘플 코드:
package main
import (
"log"
"os"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
err = ch.ExchangeDeclare(
"direct_logs",
"direct",
true,
false,
false,
false,
nil,
)
failOnError(err, "Failed to declare an exchange")
severity := severityFrom(os.Args)
body := bodyFrom(os.Args)
err = ch.Publish(
"direct_logs",
severity,
false,
false,
amqp.Publishing{
ContentType: "text/plain",
Body: []byte(body),
},
)
failOnError(err, "Failed to publish a message")
log.Printf(" [x] Sent %s", body)
}
func severityFrom(args []string) string {
var severity string
if len(args) < 3 || os.Args[2] == "" {
severity = "info"
} else {
severity = os.Args[2]
}
return severity
}
func bodyFrom(args []string) string {
var s string
if len(args) < 4 || os.Args[3] == "" {
s = "Hello, World!"
} else {
s = strings.Join(args[3:], " ")
}
return s
}요약:
RabbitMQ는 고성능 메시지 대기열 시스템으로서 다양한 시나리오의 요구 사항을 충족하는 풍부한 메시지 모드를 갖추고 있습니다. 실제 비즈니스 요구에 따라 해당 메시지 모드를 선택할 수 있습니다. 이 기사에서는 단순 대기열, 작업 대기열, 게시/구독 모드 및 주제 모드의 네 가지 일반적인 메시지 모드를 비교하고 해당 Golang 샘플 코드를 제공합니다. 개발자는 필요에 따라 분산 시스템을 구축하기 위해 적절한 메시지 모드를 선택할 수 있습니다.
위 내용은 Golang에서 RabbitMQ를 사용한 다중 메시지 모드 비교 및 선택의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!