Golang基于amqp协议实现rabbitMQ队列消费

谁践踏了优雅 2023-07-03 08:06 2阅读 0赞

## 发布消息 ##

package main
    
    import (
    	"github.com/streadway/amqp"
    	"log"
    )
    
    //我们还需要一个辅助函数来检查每个amqp调用的返回值：
    func failOnError(err error, msg string) { 
    	if err != nil { 
    		log.Fatalf("%s: %s", msg, err)
    	}
    }
    
    func mains() { 
    	//建立连接
    	rabbbimqConn, err := amqp.Dial("amqp://admin:admin@ip地址:5672/")
    	failOnError(err, "Failed to connect to RabbitMQ")
    	defer rabbbimqConn.Close()
    
    	//创建通道
    	ch , err := rabbbimqConn.Channel()
    	failOnError(err, "Failed to open channel")
    	defer ch.Close()
    
    	//声明要发送到的队列
    	queue, err := ch.QueueDeclare(
    		"hello", //队列名称
    		false, //持久性
    		false, //不用时删除
    		false, //排他性
    		false, //无等待
    		nil, //参数
    		)
    	failOnError(err, "无法声明队列")
    
    	//向队列发送消息
    	str := "hello feixiang"
    
    	err = ch.Publish(
    		"", //交换
    		queue.Name, //队列名称
    		false, //强制为
    		false, //立即
    		amqp.Publishing{ 
    			ContentType:     "text/plain",
    			Body:            []byte(str),
    		})
    	failOnError(err, "消息发送失败")
    }

## 接收消息 ##

package main
    
    import (
    	"github.com/streadway/amqp"
    	"log"
    )
    
    func main() { 
    	//连接rabbitMQ
    	conn, err := amqp.Dial("amqp://admin:admin@ip地址:5672/admin")
    	failOnError(err, "连接失败")
    
    	//设置通道
    	ch, err := conn.Channel()
    	failOnError(err, "设置通道失败")
    
    	//声明队列
    	queue, err := ch.QueueDeclare(
    		"hello",
    		false,
    		false,
    		false,
    		false,
    		nil,
    		)
    
    	//消费队列
    	msgs, err := ch.Consume(
    		queue.Name, //队列名称
    		"", //消费者
    		true, //自动确认
    		false, //排他
    		false,
    		false,
    		nil,
    		)
    	failOnError(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
    }