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

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!