Golang在CentOS上如何使用消息队列

发布时间:2025-04-22 16:53:02

阅读量:59

在CentOS上使用Golang与消息队列进行通信，通常涉及以下几个步骤：

选择消息队列系统：首先，你需要选择一个消息队列系统。常见的消息队列系统有RabbitMQ、Kafka、ActiveMQ等。这里以RabbitMQ为例进行说明。

安装消息队列系统：在CentOS上安装RabbitMQ。

sudo yum install epel-release
sudo yum install rabbitmq-server
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

安装Golang消息队列客户端库：使用go get命令安装RabbitMQ的Golang客户端库。
```
go get github.com/streadway/amqp
```

编写Golang代码：编写Golang代码来连接RabbitMQ并发送/接收消息。

下面是一个简单的示例，展示如何发送和接收消息：

package main

import (
    "log"
    "time"

    "github.com/streadway/amqp"
)

func failOnError(err error, msg string) {
    if err != nil {
        log.Fatalf("%s: %s", msg, err)
    }
}

func main() {
    // 连接到RabbitMQ服务器
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    failOnError(err, "Failed to connect to RabbitMQ")
    defer conn.Close()

    // 创建一个通道
    ch, err := conn.Channel()
    failOnError(err, "Failed to open a channel")
    defer ch.Close()

    // 声明一个队列
    q, err := ch.QueueDeclare(
        "hello", // 队列名称
        false,   // durable
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    failOnError(err, "Failed to declare a queue")

    // 发送消息到队列
    body := "Hello World!"
    err = ch.Publish(
        "",     // exchange
        q.Name, // routing key
        false,  // mandatory
        false,  // immediate
        amqp.Publishing{
            ContentType: "text/plain",
            Body:        []byte(body),
        })
    failOnError(err, "Failed to publish a message")
    log.Printf(" [x] Sent %s", body)

    // 接收消息
    msgs, err := ch.Consume(
        q.Name, // queue
        "",     // consumer
        true,   // auto-ack
        false,  // exclusive
        false,  // no-local
        false,  // no-wait
        nil,    // args
    )
    failOnError(err, "Failed to register a consumer")

    forever := make(chan bool)

    go func() {
        for d := range msgs {
            log.Printf("Received a message: %s", d.Body)
        }
    }()

    log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
    <-forever
}