Golang 死信队列的使用

2022 年 9 月 28 日
北京
本文字数：1099 字
阅读完需：约 4 分钟

GAOKAO 系统开发过程中涉及到任务执行超时的问题，大家都知道一旦任务执行超时，任务状态没法自动更新，任务状态没有更新用户就会一直等结果，这样既没法继续重复执行超时任务用户体验也不好，因此需要解决下超时任务的问题。实现方案问：RabbitMQ 死信队列是什么？答：死信，在官网中对应的单词为“Dead Letter”，可以看出翻译确实非常的简单粗暴。那么死信是个什么东西呢？“死信”是 RabbitMQ 中的一种消息机制，当你在消费消息时，如果队列里的消息出现以下情况之一：那么该消息将成为“死信”。“死信”消息会被 RabbitMQ 进行特殊处理，如果配置了死信队列信息，那么该消息将会被丢进死信队列中，如果没有配置，则该消息将会被丢弃。

问：如何配置死信队列？答：其实很简单，大概可以分为以下步骤：第三步：发送消息到 queue.normal 中，消息过期之后流入 queue.dlx 队列中，然后进行消费

代码实现

package main
import (    "fmt"    "github.com/streadway/amqp"    "time")func main()  {    conn, _ := amqp.Dial("amqp://user:password@host:ip/vhost")    ch, _ := conn.Channel()    body := "Hello World " + time.Now().Format("2021-10-20 15: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 关键字    defer conn.Close() // 压栈 后进先出    defer ch.Close()   // 压栈 后进先出}package main
import (    "fmt"    "github.com/streadway/amqp")
func main()  {    conn, _ := amqp.Dial("amqp://xxx:xxx@host:ip/vhost")    ch, _ := conn.Channel()
    //监听queue.dlx队列    msgs, _ := ch.Consume("queue.dlx", "", true, false, false, false, nil)
    for d := range msgs {        fmt.Printf("receive: %s\n", d.Body) // 收到消息，业务处理    }}

复制代码

总结延迟队列在现实业务场景中，还是有很多实际用途的，订单的超时取消、重试等，都可以借助此来完成，在 RabbitMQ 中的实现主要是根据 TTL + 死信队列来完成的，本文最后采用了 Golang 进行了实践，希望能帮助到你。

发布于: 刚刚阅读数: 3

测吧(北京)科技有限公司

关注

社区：ceshiren.com 2022.08.29 加入

微信公众号：霍格沃兹测试开发提供性能测试、自动化测试、测试开发等资料、实事更新一线互联网大厂测试岗位内推需求，共享测试行业动态及资讯，更可零距离接触众多业内大佬

发布

暂无评论

创作场景

Golang 死信队列的使用

测吧(北京)科技有限公司

评论