基于RabbitMQ构建延迟队列

延迟任务在业务中是一个很常见的需求，比如： 订单下单15分钟之后，用户没有支付，则自动取消订单 用户做了某些操作，5分钟之后发短信提醒用户 诸如此类的场景比比皆是，一种最常见的实现方式，就是开启一个定时任务，然后一直轮询数据库，这种实现方式在数据量小的时候还好，但是数据量一旦过大，这轮询数据库就会给数据库造成很大的压力，此时全面扫表的实现方式就显得不可靠了。 另外一种实现方式，就是用延迟队列的方式来实现，但是RabbitMQ本身是没有实现延迟队列的，不过可以使用TTL+死信队列的方式来实现延迟队列。 # 消息的TTL TTL全称Time To Live，即生存时间。消息的TTL也就是消息的生存时间。在RabbitMQ中设置TTL有两种 第一种是声明队列的时候，在队列的属性中设置TTL，这样该队列中的消息都会有相同的有效期 第二种是发送消息时给消息设置属性，可以为每条消息都设置不同的TTL 如果两者都设置，生存时间取两者最小的那一个。这里我们采用第二种，即为每条消息设置TTL # 死信交换机/死信队列 一个消息在满足如下的条件的时候，就会变成“死信”，并且能被投递到死信交换机（Dead-Letter-Exchange），最后进入到死信交换机绑定的队列，也称死信队列（Dead-Letter-Queue） - 消息被拒绝而且requeue=false - 消息的TTL到了，即消息过期 - 队列排满了，排在前面的消息会被丢弃或者扔到死信路由上 死信交换机和普通的交换机是没有区别的，只是某一个设置死信交换机的队列中有消息过期了，会自动触发消息的转发，发送到死信交换机中去，再由死信交换机转发到死信队列中。死信队列也是一个普通的队列，并没有什么其它特殊的。 # 延迟队列的实现 接着来看看TTL+死信交换机是如何实现延迟队列的 ![](https://upload-images.jianshu.io/upload_images/28338950-621bca1a757fe408.png) 上面的流程就是实现延迟队列的思路，比方说15分钟取消订单，那么用户下单之后，消息的TTL设置为15分钟，当消息在Queue1待的时间到了15分钟，那么就会被转发到Dead-Letter-Exchange，从而转发到Dead-Letter-Queue，最后被消费者消费，实现延迟任务。 先在RabbitMQ控制台创建一个名为dlx的交换机，作为死信交换机，并绑定上一个dlxQueue队列，作为Dead-Letter-Queue ![](https://upload-images.jianshu.io/upload_images/28338950-927ef83996ac9433.png) ``` // 生产者.go package main import ( "github.com/streadway/amqp" "mq/fail" ) func main() { conn, err := amqp.Dial("amqp://123:123@localhost:5672") fail.OnError(err) defer conn.Close() ch, err := conn.Channel() fail.OnError(err) defer ch.Close() args := amqp.Table{"x-dead-letter-exchange": "dlx"} q, err := ch.QueueDeclare("test", true, false, false, false, args) // 声明一个test队列，并设置队列的死信交换机为"dlx" body := "hello world1" for i := 0; i < 10; i++ { err = ch.Publish("", q.Name, false, false, amqp.Publishing{ Body: []byte(body), Expiration: "5000", // 设置TTL为5秒 }) fail.OnError(err) } } ``` 启动生产者，可以看到消息被投递到test队列中 ![](https://upload-images.jianshu.io/upload_images/28338950-2dc39b3d0648ab52.png) 5秒之后，消息被转发到dlxQueue队列中 ![](https://upload-images.jianshu.io/upload_images/28338950-dfa1dc28ee0969e1.png) 之后有一个消费者，专门处理这个dlxQueu队列中的消息 ``` // 消费者.go package main import ( "fmt" "github.com/streadway/amqp" "mq/fail" ) func main() { conn, err := amqp.Dial("amqp://123:123@localhost:5672") fail.OnError(err) c, err := conn.Channel() fail.OnError(err) msgs, err := c.Consume("dlxQueue", "", true, false, false, false, nil) //监听dlxQueue队列 fail.OnError(err) for d := range msgs { fmt.Printf("收到信息: %s\n", d.Body) // 收到消息，业务处理 } } ``` ``` // 5秒之后，打印 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 // 收到信息: hello world1 ``` 总结 使用TTL+死信交换机实现延迟任务还是非常方便的，除此之外还可以使用相关的插件abbitmq-delayed-message-exchange，来实现延迟队列，也是非常的方便。 ![](https://upload-images.jianshu.io/upload_images/28338950-abe5d878166573ef.png) 转自： juejin.cn/post/6844904142155022344 本文由[mdnice](https://mdnice.com/?platform=6)多平台发布
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 219,039评论 6赞 508
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 93,426评论 3赞 395
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 165,417评论 0赞 356
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,868评论 1赞 295
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,892评论 6赞 392
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,692评论 1赞 305
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 40,416评论 3赞 419
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 39,326评论 0赞 276
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,782评论 1赞 316
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,957评论 3赞 337
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,102评论 1赞 350
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,790评论 5赞 346
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 41,442评论 3赞 331
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,996评论 0赞 22
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,113评论 1赞 272
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 48,332评论 3赞 373
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 45,044评论 2赞 355

推荐阅读更多精彩内容