Golang死信队列的使用

见贤思齐

背景GAOKAO系统开发过程中涉及到任务执行超时的问题，大家都知道一旦任务执行超时，任务状态没法自动更新，任务状态没有更新用户就会一直等结果，这样既没法继续重复执行超时任务用户体验也不好，因此需要解决下超时任务的问题。实现方案问：RabbitMQ死信队列是什么？答：死信，在官网中对应的单词为“Dead Letter”，可以看出翻译确实非常的简单粗暴。那么死信是个什么东西呢？“死信”是RabbitMQ中的一种消息机制，当你在消费消息时，如果队列里的消息出现以下情况之一：①.消息被否定确认，使用 channel.basicNack 或channel.basicReject ，并且此时requeue 属性被设置为false。②.消息在队列的存活时间超过设置的TTL时间。③.消息队列的消息数量已经超过最大队列长度。那么该消息将成为“死信”。“死信”消息会被RabbitMQ进行特殊处理，如果配置了死信队列信息，那么该消息将会被丢进死信队列中，如果没有配置，则该消息将会被丢弃。问：如何配置死信队列？答：其实很简单，大概可以分为以下步骤：第一步：创建交换器 exchange.dlx, 分别绑定两个队列 queue.normal 和 queue.dlx第二步：把 queue.normal 队列里面的消息配置过期时间，然后通过 x-dead-letter-exchange 指定死信交换器为 exchange.dlx第三步：发送消息到 queue.normal 中，消息过期之后流入 queue.dlx 队列中，然后进行消费代码实现packagemainimport("fmt""github.com/streadway/amqp""time")funcmain(){conn,_:=amqp.Dial("amqp://user:password@host:ip/vhost")ch,_:=conn.Channel()body:="HelloWorld"+time.Now().Format("2021-10-2015:04:05")fmt.Println(body)//声明交换器args:=amqp.Table{"x-dead-letter-exchange":"exchange.dlx"}//声明一个queue.normal队列，并设置队列的死信交换机为"exchange.dlx"q,_:=ch.QueueDeclare("queue.normal",true,false,false,false,args)ch.Publish("",q.Name,false,false,amqp.Publishing{Body:[]byte(body),Expiration:"5000",//设置TTL为5秒})//defer关键字deferconn.Close()//压栈后进先出deferch.Close()//压栈后进先出}packagemainimport("fmt""github.com/streadway/amqp")funcmain(){conn,_:=amqp.Dial("amqp://xxx:xxx@host:ip/vhost")ch,_:=conn.Channel()//监听queue.dlx队列msgs,_:=ch.Consume("queue.dlx","",true,false,false,false,nil)ford:=rangemsgs{fmt.Printf("receive:%s\n",d.Body)//收到消息，业务处理}}总结延迟队列在现实业务场景中，还是有很多实际用途的，订单的超时取消、重试等，都可以借助此来完成，在 RabbitMQ 中的实现主要是根据 TTL + 死信队列来完成的，本文最后采用了Golang进行了实践，希望能帮助到你。