如何使用TTL+DLX的方式來實現(xiàn)延遲消息-創(chuàng)新互聯(lián)
這篇文章主要介紹如何使用TTL+DLX的方式來實現(xiàn) 延遲消息，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！
正文:
網(wǎng)上都是2種辦法去實現(xiàn)，第二種我就不說了，要升級rabbitmq 別人也說什么什么不行
TTL + DLX的方式來實現(xiàn) 延遲消息（java的 python的相關(guān)代碼都有 就是沒有 拍huang片的！?。。。?/p>
擼代碼咯：
1.首先得要創(chuàng)建一個新的隊列 新的交換機來存放延遲消息 并且設(shè)置新的隊列消息ttl到期后 轉(zhuǎn)發(fā)的 交換機 和 routeing key （我的老的交換機為e_test key 為k1）
主要代碼為：
function mqInitYanChi($e_name,$q_name,$k_route,$conn)
{
//創(chuàng)建連接和channel
$channel = new AMQPChannel($conn);
//創(chuàng)建交換機對象
$ex = new AMQPExchange($channel);
$ex->setName($e_name);
$ex->setType(AMQP_EX_TYPE_DIRECT); //必須設(shè)置
$ex->setFlags(AMQP_DURABLE); //持久化 可以不必選
echo "exchange status:".$ex->declareExchange().'\n';
//綁定交換機與隊列，并指定路由鍵
//創(chuàng)建隊列
$q = new AMQPQueue($channel);
$q->setName($q_name);
#$q->setFlags(AMQP_DURABLE); //持久化
$q->setArgument('x-dead-letter-exchange','e_test'); //設(shè)置ttl超時轉(zhuǎn)發(fā)到e_test
$q->setArgument('x-dead-letter-routing-key','k1'); //設(shè)置ttl超時轉(zhuǎn)發(fā)的key為k1
echo "Message Total:".$q->declare()."\n";
echo 'Queue Bind: '.$q->bind($e_name, $k_route)."\n";
return $ex;
}
2.也就是消息發(fā)送的送時候設(shè)置ttl就行了 其實很簡單
主要代碼：
$message = "測試延遲!";
$ex1=mqInitYanChi('e_yanchi','q_yanchi','k1',$conn);
$attributes = array('expiration' => 5000); //設(shè)置為5秒
$ex1->publish($message,'k1','1',$attributes);
就這樣 就可以發(fā)送到q_yanchi隊列里邊的 消息 五秒后過期 轉(zhuǎn)發(fā)到 綁定了 e_test的交換機 routing-key 為k1的隊列中去了
以上是“如何使用TTL+DLX的方式來實現(xiàn) 延遲消息”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。
網(wǎng)站名稱：如何使用TTL+DLX的方式來實現(xiàn)延遲消息-創(chuàng)新互聯(lián)
標題URL：http://www.jiaotiyi.com/article/degchg.html