How to Use Message Queues (NATS, RabbitMQ, Kafka) in Go

Use third-party client libraries like nats.go, amqp, or sarama to connect to NATS, RabbitMQ, or Kafka respectively, as Go's standard library does not include native message queue support. Install the NATS client and connect to a server with the following code:

import "github.com/nats-io/nats.go"

nc, err := nats.Connect(nats.DefaultURL)
if err != nil {
    panic(err)
}
nc.Publish("subject", []byte("Hello Go!"))
nc.Flush()
nc.Close()

For RabbitMQ, use github.com/rabbitmq/amqp091-go and for Kafka, use github.com/IBM/sarama with similar connection patterns.

Go does not have built-in message queues, so you must install external libraries to connect to services like NATS, RabbitMQ, or Kafka. Think of these libraries as adapters that let your Go program speak the specific language of the queue server. You install the library, connect to the server address, and then send or receive messages using the library's functions.