golang使用rabbitmqhelloworld

Posted 2023-02-27 吴冬冬

module

require github.com/streadway/amqp v0.0.0-20190404075320-75d898a42a94

连接rabbitmq

	conn, err := amqp.Dial("amqp://admin:rabbitmq123@18.232.146.30:5672/")
	defer conn.Close()

打开通道

	ch, err := conn.Channel()
	defer ch.Close()

声明队列

	q, err := ch.QueueDeclare("hello", false, false, false, false, nil)

消费消息

	msgs, err := ch.Consume(q.Name, "", true, false, false, false, nil)

	go func() 
		for msg := range msgs 
			log.Printf("Received a message: %s", msg.Body)
		
	()

生产消息

	body := "Hello World33!"

	err = ch.Publish("", q.Name, false, false, amqp.Publishing
		ContentType: "text/plain",
		Body:        []byte(body),
	)