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']