如何在 go 框架中集成 rabbitmq 消息队列？安装 rabbitmq：安装 erlang 和 rabbitmq。创建 go 项目：创建一个新的 go 项目，并初始化 go 模块。安装 rabbitmq amqp 客户端库：使用 go get 命令安装。连接到 rabbitmq 服务器：使用 amqp 包连接到服务器。创建频道并声明队列：创建频道并声明一个名为 “my-queue” 的队列。准备消息：准备要发送的消息体。发布消息到队列：使用 ch.publish 函数发布消息。实战案例 ：演示
如何在 Golang 框架中集成 RabbitMQ 消息队列
RabbitMQ 是一个流行的消息队列服务，可在各种应用程序中用于可靠且高效的通信。本文将指导您如何在 Golang 框架中集成 RabbitMQ 消息队列。
安装 RabbitMQ
确保已安装 Erlang，它是 RabbitMQ 的依赖项：
1
sudo apt install erlang
安装 RabbitMQ：
1
sudo apt install rabbitmq-server
启动 RabbitMQ 服务：
1
sudo systemctl start rabbitmq-server
创建 Go 项目
创建一个新的 Go 项目目录：
1
2
mkdir my-rabbitmq-app
cd my-rabbitmq-app
初始化 Go 模块：
1
go mod init my-rabbitmq-app
安装 RabbitMQ AMQP 客户端库
安装 RabbitMQ AMQP 客户端库：
1
go get <a style=color:f60; text-decoration:underline; href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/streadway/amqp
连接到 RabbitMQ 服务器
在您的 Go 代码中，您可以使用 amqp 包连接到 RabbitMQ 服务器：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
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()
}
创建频道并声明队列
一旦建立连接，您可以创建频道并声明队列：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
// 创建一个新的 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)
}
准备要发送的消息
接下来，您可以准备要发送的消息：
1
2
3
4
5
6
7
// 定义消息主体
msgBody := "Hello, RabbitMQ!"
// 创建一个 AMQP 消息
msg := amqp.Publishing{
Body: []byte(msgBody),
}
发布消息到队列
最后，您可以发布消息到队列：
1
2
3
4
5
6
7
8
9
10
11
12
13
// 发布消息到队列
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 的文件来发送消息：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
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 的文件来接收消息：
1
2
3
4
5
6
7
8
9
10
11
12
package main
import (
"context"
"fmt"
"log"
"os"
"github.com/streadway/amqp"
)
func main() {
以上就是如何在 Golang 框架中集成 RabbitMQ 消息队列？的详细内容，更多请关注其它相关文章！