Golang RabbitMQ: 实现可靠消息传递、系统监控和告警的架构设计与实现

package main

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

// 发布消息到RabbitMQ
func publishMessage() error {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        return err
    }

    defer conn.Close()

    ch, err := conn.Channel()
    if err != nil {
        return err
    }

    defer ch.Close()

    q, err := ch.QueueDeclare(
        "myqueue", // 队列名称
        false,     // 是否持久化
        false,     // 是否自动删除
        false,     // 是否具有排他性
        false,     // 是否阻塞
        nil,       // 额外的属性
    )
    if err != nil {
        return err
    }

    body := "Hello RabbitMQ!"

    err = ch.Publish(
        "",     // 交换器
        q.Name, // 路由键
        false,  // 强制
        false,  // 立即发送
        amqp.Publishing{
            ContentType: "text/plain",
            Body:        []byte(body),
        })

    if err != nil {
        return err
    }

    fmt.Println("消息已成功发送到RabbitMQ！")

    return nil
}

// 消费消息
func consumeMessage() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatalf("%s: %s", "无法连接到RabbitMQ", err)
    }

    defer conn.Close()

    ch, err := conn.Channel()
    if err != nil {
        log.Fatalf("%s: %s", "无法创建频道", err)
    }

    defer ch.Close()

    q, err := ch.QueueDeclare(
        "myqueue", // 队列名称
        false,     // 是否持久化
        false,     // 是否自动删除
        false,     // 是否具有排他性
        false,     // 是否阻塞
        nil,       // 额外的属性
    )
    if err != nil {
        log.Fatalf("%s: %s", "无法声明队列", err)
    }

    msgs, err := ch.Consume(
        q.Name, // 队列名称
        "",     // 消费者标识符
        true,   // 自动应答
        false,  // 独占
        false,  // 同一连接
        false,  // 额外的属性
        nil,    // 消费者回调函数
    )
    if err != nil {
        log.Fatalf("%s: %s", "无法注册消费者", err)
    }

    forever := make(chan bool)

    go func() {
        for d := range msgs {
            log.Printf("收到消息：%s", d.Body)
        }
    }()

    fmt.Println("等待接收消息...")

    <-forever
}

func main() {
    // 发布消息到RabbitMQ
    err := publishMessage()
    if err != nil {
        log.Fatal(err)
    }

    // 消费消息
    consumeMessage()
}

global:
  scrape_interval: 15s
  evaluation_interval: 15s

scrape_configs:
  - job_name: 'rabbitmq'
    static_configs:
      - targets: ['rabbitmq:15672']
    metrics_path: /metrics
    params:
      vhost: ['/']

alerting:
  alertmanagers:
  - static_configs:
    - targets: ['alertmanager:9093']