一、在客戶(hù)端創(chuàng)建方式?
1.創(chuàng)建死信交換機(jī)
2.創(chuàng)建類(lèi)生產(chǎn)者隊(duì)列?
?3.創(chuàng)建死信隊(duì)列
其實(shí)就是一個(gè)普通的隊(duì)列，綁定號(hào)私信交換機(jī)，不給ttl，給上匹配的路由，等待交換機(jī)發(fā)送消息。
二、springboot實(shí)現(xiàn)創(chuàng)建類(lèi)生產(chǎn)者隊(duì)列?
1.在消費(fèi)者里的RabbitMQConfig配置類(lèi)里，創(chuàng)建隊(duì)列，給它加參數(shù)
package com.qf.bootconsumer.config;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
@Configuration
public class RabbitConfig {
@Bean
public Queue queue04(){
HashMap<String, Object> hashMap = new HashMap<>();
hashMap.put("x-message-ttl",20000); // 該隊(duì)列中消息的存活時(shí)間
hashMap.put("x-dead-letter-exchange","dlx"); // 該隊(duì)列關(guān)聯(lián)的死信交換機(jī)
hashMap.put("x-dead-letter-routing-key","dead.20s"); // 死信交換機(jī)的routingkey
hashMap.put("x-queue-type","classic"); // 死信交換機(jī)routingkey
Queue queue = new Queue("queasaaueB", true, false, false, hashMap);
return queue;
}
}
第四個(gè)參數(shù)，就是放入這個(gè)隊(duì)列，的一些屬性參數(shù)
也就是這兩個(gè)位置
文章來(lái)源：http://www.zghlxwxcb.cn/news/detail-703066.html
對(duì)應(yīng)Java代碼里好像少個(gè)參數(shù)，排他性，是指，是否為私有，這個(gè)隊(duì)列只能由創(chuàng)建它的connection連接對(duì)象進(jìn)行消費(fèi)。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-703066.html
到了這里，關(guān)于RabbitMQ: 死信隊(duì)列的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
