Golang与RabbitMQ实现分布式日志收集和分析的细节、技巧和最佳实践

func main() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    channel, err := conn.Channel()
    if err != nil {
        log.Fatal(err)
    }
    defer channel.Close()

    queue, err := channel.QueueDeclare(
        "logs", // 队列名
        true,   // 是否持久化
        false,  // 是否自动删除
        false,  // 是否排他性
        false,  // 是否为阻塞模式
        nil,    // 额外的属性
    )
    if err != nil {
        log.Fatal(err)
    }

    // 将日志发送到队列中
    logrus.SetOutput(channel)
    logrus.Info("This is a log message")
}

func main() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    channel, err := conn.Channel()
    if err != nil {
        log.Fatal(err)
    }
    defer channel.Close()

    queue, err := channel.QueueDeclare(
        "logs", // 队列名
        true,   // 是否持久化
        false,  // 是否自动删除
        false,  // 是否排他性
        false,  // 是否为阻塞模式
        nil,    // 额外的属性
    )
    if err != nil {
        log.Fatal(err)
    }

    msgs, err := channel.Consume(
        queue.Name, // 队列名
        "",         // 消费者名
        true,       // 是否自动确认
        false,      // 是否非独占性
        false,      // 是否阻塞模式
        false,      // 是否等待
        nil,        // 额外参数
    )
    if err != nil {
        log.Fatal(err)
    }

    done := make(chan bool)

    go func() {
        for msg := range msgs {
            log.Println(string(msg.Body))
        }
    }()

    log.Println("Waiting for logs. To exit, press CTRL+C")
    <-done
}