RabbitMQ是一個消息代理：它接受消息并轉發。 * **生產者**：發送消息 * **隊列**：消息存儲在隊列中。隊列只受主機內存和磁盤限制，實際上是一個大的消息緩沖區。許多生產者可以向一個隊列發送消息，而許多消費者嘗試從一個隊列接收消息。 * **消費者**：等待接收消息。 **生產者示例代碼：** ~~~go // 1.建議RabbitMQ連接 conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/"） // ....err處理 defer conn.Close() // 2.創建channel ch, err := conn.Channel() // ....err處理 defer ch.Close() // 3.聲明消息要發送到的隊列，name為隊列名 q, err := ch.QueueDeclare( "hello", // name false, // durable false, // delete when unused false, // exclusive false, // no-wait nil, // arguments ) // 4.將消息發布到聲明的隊列 body := "Hello World!" err = ch.Publish( "", // exchange q.Name, // routing key false, // mandatory false, // immediate amqp.Publishing { ContentType: "text/plain", Body: []byte(body), }) ~~~ **消費者代碼示例：** ``` // 1.建議RabbitMQ連接 conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/"） // ....err處理 defer conn.Close() // 2.獲取channel ch, err := conn.Channel() // ....err處理 defer ch.Close() // 3.聲明消息要發送到的隊列，name為隊列名 q, err := ch.QueueDeclare( "hello", // name false, // durable false, // delete when unused false, // exclusive false, // no-wait nil, // arguments ) // 獲取接收消息的Delivery通道 msgs, err := ch.Consume( q.Name, // queue "", // consumer true, // auto-ack false, // exclusive false, // no-local false, // no-wait nil, // args ) // ....err處理 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 ```