Golang开发：构建高可用的分布式消息队列

分布式消息队列是现代分布式系统中广泛使用的一种通信模式。它允许不同的组件之间通过发送和接收消息进行异步通信，从而达到解耦和提高系统可靠性的目的。本文将介绍如何使用Golang开发一个高可用的分布式消息队列，以及提供一些具体的代码示例。

package main

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

func main() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatalf("Failed to connect to RabbitMQ: %v", err)
    }
    defer conn.Close()

    ch, err := conn.Channel()
    if err != nil {
        log.Fatalf("Failed to open a channel: %v", err)
    }
    defer ch.Close()
}

msg := amqp.Publishing{
    ContentType: "text/plain",
    Body:        []byte("Hello, RabbitMQ!"),
}
err = ch.Publish(
    "",     // exchange
    "queue", // routing key
    false,  // mandatory
    false,  // immediate
    msg)
if err != nil {
    log.Fatalf("Failed to publish a message: %v", err)
}

msgs, err := ch.Consume(
    "queue", // queue
    "",      // consumer
    true,    // auto-ack
    false,   // exclusive
    false,   // no-local
    false,   // no-wait
    nil,     // args
)
if err != nil {
    log.Fatalf("Failed to register a consumer: %v", err)
}

for msg := range msgs {
    log.Printf("Received a message: %s", msg.Body)
}