這篇是 代碼篇 ，略過 Direct，F(xiàn)anout，Topic 這幾種基本隊列的使用介紹，但是 Github 倉庫上可以查看到的。OfD28資訊網(wǎng)——每日最新資訊28at.com

圖片OfD28資訊網(wǎng)——每日最新資訊28at.com

<(￣︶￣)↗[GO!]OfD28資訊網(wǎng)——每日最新資訊28at.com

沖沖沖~OfD28資訊網(wǎng)——每日最新資訊28at.com

死信隊列

死信是指有這三個特點的消息OfD28資訊網(wǎng)——每日最新資訊28at.com

• 消息被拒絕，且沒有重新入隊（投遞）
• 消息過期
• 消息隊列滿了

// nack 返回 false，并放棄重新回到隊列channel.basicNack(deliveryTag, false, false);//拒絕，不重新入隊列channel.basicReject(deliveryTag, false);

死信交換機 —— DLX：Dead-Letter-ExchangeOfD28資訊網(wǎng)——每日最新資訊28at.com

@Beanpublic DirectExchange directExchange2() {    /**     * 交換機名，后面兩個是默認值就：持久化，不自動刪除     */    return new DirectExchange(RabbitMQConstants.DIRECT_EXCHANGE2, true, false);}@Beanpublic Queue directQueue2() {    return QueueBuilder            .durable(RabbitMQConstants.DIRECT_QUEUE2)            .deadLetterExchange(RabbitMQConstants.DLX_EXCHANGE)            .deadLetterRoutingKey(RabbitMQConstants.DLX_ROUTING_KEY)            .build();}/** * 將隊列綁定到交換機上 * * @return */@Beanpublic Binding directBinding2() {    return BindingBuilder.            bind(directQueue2()).            to(directExchange2()).            with(RabbitMQConstants.DIRECT_BINDING_KEY2);}

過期時間

兩種設(shè)置方式OfD28資訊網(wǎng)——每日最新資訊28at.com

• 創(chuàng)建隊列時設(shè)置，消息會被排序加入到隊列頭部，短的在前
• 發(fā)送消息時設(shè)置，時間到期不會立刻刪除，而是在推送消息時刪除

同時設(shè)置的話，過期時間已短的為準OfD28資訊網(wǎng)——每日最新資訊28at.com

/** * 創(chuàng)建隊列時設(shè)置 * @return */@Beanpublic Queue ttlQueue() {    Map<String, Object> args = new HashMap<>();    //設(shè)置消息過期時間    args.put("x-message-ttl", 5000);    //設(shè)置死信交換機    args.put("x-dead-letter-exchange", RabbitMQConstants.DLX_EXCHANGE);    //設(shè)置死信 routing_key    args.put("x-dead-letter-routing-key", RabbitMQConstants.DLX_ROUTING_KEY);    return new Queue(RabbitMQConstants.TTL_QUEUE, true, false, false, args);}

/** * 發(fā)送消息時設(shè)置 * @return */public void sendMessage2() throws JsonProcessingException {    User user = new User();    ObjectMapper objectMapper = new ObjectMapper();    byte[] bytes = objectMapper.writeValueAsBytes(user);    // 10 s 后過期    Message message =            MessageBuilder.withBody(bytes)                    .setExpiration("10000").build();    // 交換機，路由鍵，信息    rabbitTemplate.convertAndSend(            RabbitMQConstants.DIRECT_EXCHANGE2,            RabbitMQConstants.DIRECT_ROUTING_KEY2,            message    );}

效果演示

圖片OfD28資訊網(wǎng)——每日最新資訊28at.com

隊列 5 秒延遲的效果OfD28資訊網(wǎng)——每日最新資訊28at.com

圖片OfD28資訊網(wǎng)——每日最新資訊28at.com

延遲隊列

兩種方案實現(xiàn)OfD28資訊網(wǎng)——每日最新資訊28at.com

• 利用 死信隊列+過期時間 去處理，消息過期被轉(zhuǎn)發(fā)到死信交換機，死信交換機路由到死信隊列進行處理
• 使用插件 rabbitmq_delayed_message_exchange

插件可以在這里找到

本文鏈接：http://www.www897cc.com/showinfo-26-76494-0.htmlRabbitMQ代碼篇之過期時間，死信隊列，延遲隊列，優(yōu)先級隊列的基本使用

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： 關(guān)于Java程序服務(wù)預(yù)熱那些事

下一篇： 想進阿里？先搞懂Spring Bean的循環(huán)依賴！