如何在 Golang 框架中集成 RabbitMQ 消息队列？-Golang-PHP中文网

如何在 Golang 框架中集成 RabbitMQ 消息队列？

PHPz

发布： 2024-07-04 14:12:01

原创

1063人浏览过

如何在 go 框架中集成 rabbitmq 消息队列？安装 rabbitmq：安装 erlang 和 rabbitmq。创建 go 项目：创建一个新的 go 项目，并初始化 go 模块。安装 rabbitmq amqp 客户端库：使用 go get 命令安装。连接到 rabbitmq 服务器：使用 amqp 包连接到服务器。创建频道并声明队列：创建频道并声明一个名为 “my-queue” 的队列。准备消息：准备要发送的消息体。发布消息到队列：使用 ch.publish 函数发布消息。实战案例：演示

如何在 Golang 框架中集成 RabbitMQ 消息队列？

如何在 Golang 框架中集成 RabbitMQ 消息队列

RabbitMQ 是一个流行的消息队列服务，可在各种应用程序中用于可靠且高效的通信。本文将指导您如何在 Golang 框架中集成 RabbitMQ 消息队列。

安装 RabbitMQ

确保已安装 Erlang，它是 RabbitMQ 的依赖项：
```
sudo apt install erlang
```
登录后复制
安装 RabbitMQ：

立即学习“go语言免费学习笔记（深入）”；
```
sudo apt install rabbitmq-server
```
登录后复制
启动 RabbitMQ 服务：
```
sudo systemctl start rabbitmq-server
```
登录后复制

创建 Go 项目

创建一个新的 Go 项目目录：
```
mkdir my-rabbitmq-app
cd my-rabbitmq-app
```
登录后复制
初始化 Go 模块：

代码小浣熊
代码小浣熊是基于商汤大语言模型的软件智能研发助手，覆盖软件需求分析、架构设计、代码编写、软件测试等环节

429

查看详情
```
go mod init my-rabbitmq-app
```
登录后复制

安装 RabbitMQ AMQP 客户端库

安装 RabbitMQ AMQP 客户端库：
```
go get github.com/streadway/amqp
```
登录后复制

连接到 RabbitMQ 服务器

在您的 Go 代码中，您可以使用 amqp 包连接到 RabbitMQ 服务器：

package main

import (
    "context"
    "fmt"
    "log"
    "os"

    "github.com/streadway/amqp"
)

func main() {
    // 获取环境变量中的 RabbitMQ 设置
    username := os.Getenv("RABBITMQ_USERNAME")
    password := os.Getenv("RABBITMQ_PASSWORD")
    host := os.Getenv("RABBITMQ_HOST")
    port := os.Getenv("RABBITMQ_PORT")

    // 建立连接到 RabbitMQ 服务器
    conn, err := amqp.Dial(fmt.Sprintf("amqp://%s:%s@%s:%s/", username, password, host, port))
    if err != nil {
        log.Fatalf("Failed to connect to RabbitMQ: %s", err)
    }
    defer conn.Close()
}

登录后复制

创建频道并声明队列

一旦建立连接，您可以创建频道并声明队列：

// 创建一个新的 AMQP 频道
ch, err := conn.Channel()
if err != nil {
    log.Fatalf("Failed to create channel: %s", err)
}
defer ch.Close()

// 声明一个名为 "my-queue" 的队列
_, err = ch.QueueDeclare(
    "my-queue", // 队列名称
    false,      // 是否持久化
    false,      // 是否自动删除
    false,      // 是否独占
    false,      // 是否为临时队列
    nil,        // 其他参数
)
if err != nil {
    log.Fatalf("Failed to declare queue: %s", err)
}

登录后复制

准备要发送的消息

接下来，您可以准备要发送的消息：

// 定义消息主体
msgBody := "Hello, RabbitMQ!"

// 创建一个 AMQP 消息
msg := amqp.Publishing{
    Body: []byte(msgBody),
}

登录后复制

发布消息到队列

最后，您可以发布消息到队列：

// 发布消息到队列
err = ch.Publish(
    "",             // 交换机名称（留空表示默认交换机）
    "my-queue",  // 队列名称
    false,       // 是否为强制性消息
    false,       // 是否为立即确认
    msg,         // 消息
)
if err != nil {
    log.Fatalf("Failed to publish message: %s", err)
}

log.Printf("Message published: %s", msgBody)

登录后复制

实战案例：演示发送和接收消息

创建一个名为 producer.go 的文件来发送消息：

package main

import (
    "context"
    "fmt"
    "log"
    "os"
    "strconv"
    "time"

    "github.com/streadway/amqp"
)

func main() {
    // 获取环境变量中的 RabbitMQ 设置
    username := os.Getenv("RABBITMQ_USERNAME")
    password := os.Getenv("RABBITMQ_PASSWORD")
    host := os.Getenv("RABBITMQ_HOST")
    port := os.Getenv("RABBITMQ_PORT")

    // 建立连接到 RabbitMQ 服务器
    conn, err := amqp.Dial(fmt.Sprintf("amqp://%s:%s@%s:%s/", username, password, host, port))
    if err != nil {
        log.Fatalf("Failed to connect to RabbitMQ: %s", err)
    }
    defer conn.Close()

    // 创建一个新的 AMQP 频道
    ch, err := conn.Channel()
    if err != nil {
        log.Fatalf("Failed to create channel: %s", err)
    }
    defer ch.Close()

    // 声明一个名为 "my-queue" 的队列
    _, err = ch.QueueDeclare(
        "my-queue", // 队列名称
        false,      // 是否持久化
        false,      // 是否自动删除
        false,      // 是否独占
        false,      // 是否为临时队列
        nil,        // 其他参数
    )
    if err != nil {
        log.Fatalf("Failed to declare queue: %s", err)
    }

    // 初始化消息计数
    msgCount := 1

    // 发送消息循环
    for {
        // 创建要发送的消息
        msg := amqp.Publishing{
            Body: []byte(fmt.Sprintf("Message %d", msgCount)),
        }

        // 发布消息到队列
        err = ch.Publish(
            "",             // 交换机名称（留空表示默认交换机）
            "my-queue",  // 队列名称
            false,       // 是否为强制性消息
            false,       // 是否为立即确认
            msg,         // 消息
        )
        if err != nil {
            log.Fatalf("Failed to publish message: %s", err)
        }

        // 每 5 秒发送一条消息
        time.Sleep(5 * time.Second)

        // 递增消息计数
        msgCount++
    }
}

登录后复制

创建一个名为 consumer.go 的文件来接收消息：

package main

import (
    "context"
    "fmt"
    "log"
    "os"

    "github.com/streadway/amqp"
)

func main() {

登录后复制

以上就是如何在 Golang 框架中集成 RabbitMQ 消息队列？的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

如何使用Golang实现RPC异步调用_Golang RPC异步调用优化方法如何使用Golang反射生成动态SQL语句_Golang reflect数据库字段映射说明如何使用Golang创建HTTP客户端请求_Golang net HTTP Client请求方法说明 Golang如何优化微服务容器启动时间_Golang微服务容器启动优化实践如何在Golang中实现表格驱动基准测试_Golang table driven Benchmark示例