rabbitmq——持久化消息

使用rabbitmq做持久化消息，我们有两种方式。

使用自动确认机制，如果使用这种机制，消费者接收到消息之后自动确认，但是如果接收到消息之后，服务卡顿，就会导致这条消息不会重新发送给其他或者重启之后的消费者所在的服务器。导致间接性消息丢失。使用手动确认机制，当消息接收到之后，不要立即确认收到，而是先处理，处理之后，再确认这条消息。

product.go

que , err := c.QueueDeclare("hello-test" , false , false , false , false , nil)
if err != nil {
	fmt.Println(err)
	return
}
fmt.Print(err)
_ = c.Publish("" , que.Name, false , false , amqp.Publishing{
	Body: []byte("test hello"),
})

consumer.go

	qu , err := c.QueueDeclare("hello-test" , false , false , false , false , nil)
	fmt.Println(err)
	//err = c.QueueBind(qu.Name , "info" , "dir" , false ,nil)
	fmt.Println(err)
	msg , err := c.Consume(qu.Name ,"" , false , false , false , false , nil)
	fmt.Println(err)
	for d := range msg {
		fmt.Println(string(d.Body))
		d.Ack(false)
	}

注意：在consumer.go中，将消息体输出之后再确认到接收，那么这里传递true和传递false有什么区别？

如果传递false，则只会确认当前消息体的接收，如果为true，则确认包括当前消息体在内的之前的消息都确认收到。