Day 2

Local Setup and First Go Producer/Consumer

আজকে আমরা RabbitMQ locally run করব, management UI দেখব, এবং Go দিয়ে first publish-consume cycle লিখব।

Setup Checklist

Step	Command / Action	Expected
1	`docker run -d --hostname rabbit-dev --name rabbit-dev -p 5672:5672 -p 15672:15672 rabbitmq:3-management`	RabbitMQ container up
2	Browser খুলে `http://localhost:15672`	UI open
3	Login with `guest / guest`	dashboard দেখাবে
4	`go get github.com/rabbitmq/amqp091-go`	package ready


msgs, err := ch.Consume("hello.queue", "", true, false, false, false, nil)
if err != nil {
	log.Fatal(err)
}
 
for msg := range msgs {
	log.Printf("received: %s", msg.Body)
}


err = ch.Publish("", "hello.queue", false, false, amqp.Publishing{
	ContentType: "text/plain",
	Body:        []byte("hello rabbitmq from go"),
})
if err != nil {
	log.Fatal(err)
}

Predict the Output

Situation: Consumer আগে চালু আছে। তারপর producer একবার চালানো হলো।

Goal: Console-এ কী হবে?

What to think about:

Queue আগে থেকেই declared
Consumer auto-ack mode-এ আছে
One message published হয়েছে

সম্ভাব্য সমাধান দেখুন

Consumer console-এ `received: hello rabbitmq from go` টাইপ আউটপুট দেখা যাবে, এবং queue depth আবার zero হয়ে যাবে।

আজকের production note

Checkpoint

নিজে explain করো: producer আর consumer উভয় code-এ `QueueDeclare` কেন থাকতে পারে?

Idempotent topology setup হিসেবে
Service startup-এ dependency reduce করতে
কিন্তু parameters mismatch হলে error আসতে পারে