go如何使用rabbitMQ

使用 RabbitMQ 的 Go 客户端可以轻松地在 Go 应用程序中集成 RabbitMQ。

首先，需要安装 RabbitMQ，然后在 Go 应用程序中使用 RabbitMQ 的 Go 客户端库。可以使用以下命令下载并安装 Go 客户端库：

go get github.com/streadway/amqp

然后，在 Go 应用程序中使用以下代码连接到 RabbitMQ 并发送消息：

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()

    q, err := ch.QueueDeclare(
        "hello", // queue name
        false,   // durable
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    if err != nil {
        log.Fatalf("failed to declare a queue: %v", err)
    }

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

这个示例代码连接到本地 RabbitMQ 实例，声明一个名为 "hello" 的队列，然后发布一个消息到队列中。

当然，在实际的应用程序中，需要根据实际需求进行更改。