Golang?rabbitMQ生產者和消費者怎么實現

今天小編給大家分享一下Golang rabbitMQ生產者和消費者怎么實現的相關知識點，內容詳細，邏輯清晰，相信大部分人都還太了解這方面的知識，所以分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后有所收獲，下面我們一起來了解一下吧。

消費者

package main
import (
	"fmt"
	"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
	if err != nil {
		fmt.Println("%s: %s", msg, err)
	}
}
// 只能在安裝 rabbitmq 的服務器上操作
func main() {
	conn, err := amqp.Dial("amqp://mquser:123456@127.0.0.1/toutiao")
	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(
		"toutiao.web.test", // 隊列名字
		false,   // 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
		"toutiao",     // consumer
		true,   // auto-ack,true消費了就消失
		false,  // exclusive
		false,  // no-local
		false,  // no-wait
		nil,    // args
	)
	failOnError(err, "Failed to register a consumer")
	forever := make(chan bool)
	go func() {
		for d := range msgs {
			fmt.Println(fmt.Sprintf("返回的消息:%s",d.Body))
		}
	}()
	fmt.Println("[*] Waiting for messages. To exit press CTRL+C")
	<-forever
}

生產者

body：消息體

package main
import (
	"github.com/streadway/amqp"
	"log"
)
func failOnError(err error, msg string) {
	if err != nil {
		log.Fatalf("%s: %s", msg, err)
	}
}
// 只能在安裝 rabbitmq 的服務器上操作
func main() {
	conn, err := amqp.Dial("amqp://mquser:123456@127.0.0.1/toutiao")
	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(
	"toutiao.web.test",   // name
		false, // durable
		false, // delete when unused
		false, // exclusive
		false, // no-wait
		nil, // arguments
)
	failOnError(err, "Failed to declare a queue")
	body := "Hello World!"  //發送的消息
	err = ch.Publish(
	"",         // exchange
		q.Name, // routing key
		false,  // mandatory
		false,  // immediate

		amqp.Publishing{
		ContentType: "text/plain",
			Body:        []byte(body),
		})
	log.Printf(" [x] Sent %s", body)
	failOnError(err, "Failed to publish a message")
}

以上就是“Golang rabbitMQ生產者和消費者怎么實現”這篇文章的所有內容，感謝各位的閱讀！相信大家閱讀完這篇文章都有很大的收獲，小編每天都會為大家更新不同的知識，如果還想學習更多的知識，請關注億速云行業資訊頻道。