Go中RabbitMQ的世界里，开启我们的helloworld之旅

后端

2023-09-07 07:48:39

从今天开始，我们将步入消息队列中间件的精彩世界，以Go语言为指引，与RabbitMQ携手同行，踏上探索消息传递奥秘的旅程。本文将带你开启helloworld之旅，为你揭开RabbitMQ的神秘面纱。

一、拉取镜像

第一步，让我们在docker中安装拉取一个最新的RabbitMQ镜像，只需要运行docker pull rabbitmq命令即可。当然，你也可以选择一个特定的版本来安装。

二、启动容器

完成拉取镜像后，我们就可以启动一个RabbitMQ容器了。使用docker run -d --name rabbitmq -p 5672:5672 rabbitmq:latest命令，即可轻松启动容器。

三、安装Go库

在Go语言的世界里，我们需要安装一个可靠的库来与RabbitMQ进行交互。使用go get -u github.com/streadway/amqp命令，便可轻松完成这一步。

四、编写代码

现在，我们已经准备好编写Go代码来与RabbitMQ进行通信了。首先，让我们创建一个新的Go项目，然后编写以下代码：

package main

import (
	"fmt"
	"log"

	"github.com/streadway/amqp"
)

func main() {
	// 连接到RabbitMQ服务器
	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
	if err != nil {
		log.Fatalf("Failed to connect to RabbitMQ: %s", err)
	}
	defer conn.Close()

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

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

	// 发布消息
	body := "Hello, world!"
	err = ch.Publish(
		"",          // 交换器名称（这里不使用交换器）
		q.Name,      // 队列名称
		false,       // 是否是强制发布
		false,       // 是否是立即发布
		amqp.Publishing{
			ContentType: "text/plain",
			Body:        []byte(body),
		},
	)
	if err != nil {
		log.Fatalf("Failed to publish a message: %s", err)
	}

	fmt.Println("Message sent successfully")
}