メッセージ送受信サンプルコード

RabbitMQのメッセージの送信・受信を行うgolangのサンプルコードです。

cf. https://www.rabbitmq.com/tutorials/tutorial-one-go

事前準備

• 下記で必要なパッケージをインストールしてください:

go get github.com/rabbitmq/amqp091-go

送信

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    amqp "github.com/rabbitmq/amqp091-go"
)

func main() {
    const (
        RabbitmqDefaultUser = "admin"
        RabbitmqDefaultPass = "password"
        RabbitmqDefaultHost = "localhost"
        RabbitmqDefaultPort = "5672"
    )

    conn, err := amqp.Dial(
        fmt.Sprintf(
            "amqp://%s:%s@%s:%s/",
            RabbitmqDefaultUser,
            RabbitmqDefaultPass,
            RabbitmqDefaultHost,
            RabbitmqDefaultPort,
        ),
    )
    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", // name
        true,    // durableサーバが落ちてもキューを保持する
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    failOnError(err, "Failed to declare a queue")

    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    body := "Hello World!"
    err = ch.PublishWithContext(ctx,
        "",     // exchange
        q.Name, // routing key
        false,  // mandatory
        false,  // immediate
        amqp.Publishing{
            ContentType:  "text/plain",
            Body:         []byte(body),
            DeliveryMode: amqp.Persistent, // サーバが落ちてもメッセージを保持する
        })
    failOnError(err, "Failed to publish a message")
    log.Printf(" [x] Sent %s\n", body)
}

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

実行すると、下記のようなメッセージが表示され、RabbitMQのWeb画面上でキューが作成されたことが確認できます:

$ go run main.go
2026/01/11 07:29:48  [x] Sent Hello World!

受信

package main

import (
    "fmt"
    "log"

    amqp "github.com/rabbitmq/amqp091-go"
)

func main() {
    const (
        RabbitmqDefaultUser = "admin"
        RabbitmqDefaultPass = "password"
        RabbitmqDefaultHost = "localhost"
        RabbitmqDefaultPort = "5672"
    )

    conn, err := amqp.Dial(
        fmt.Sprintf(
            "amqp://%s:%s@%s:%s/",
            RabbitmqDefaultUser,
            RabbitmqDefaultPass,
            RabbitmqDefaultHost,
            RabbitmqDefaultPort,
        ),
    )
    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", // name
        true,    // durable
        false,   // delete when unused
        false,   // exclusive
        false,   // no-wait
        nil,     // arguments
    )
    failOnError(err, "Failed to declare a queue")

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

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

    log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
    select {}
}

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

select{}によって、起動後アプリは待機を続けます。RabbitMQからメッセージがpushされると下記のようなメッセージが出力されます:

2026/01/11 07:29:48 Received a message: Hello World!