如何使用TTL+DLX的方式來實(shí)現(xiàn) 延遲消息

這篇文章主要介紹如何使用TTL+DLX的方式來實(shí)現(xiàn) 延遲消息，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

正文:

  網(wǎng)上都是2種辦法去實(shí)現(xiàn)，第二種我就不說了，要升級rabbitmq 別人也說什么什么不行

   TTL + DLX 的方式來實(shí)現(xiàn) 延遲消息（java的 python的相關(guān)代碼都有 就是沒有 拍huang片的?。。。。?/p>

  擼代碼咯：

  1.首先得要?jiǎng)?chuàng)建一個(gè)新的隊(duì)列 新的交換機(jī)來存放延遲消息 并且設(shè)置新的隊(duì)列消息ttl到期后 轉(zhuǎn)發(fā)的 交換機(jī) 和 routeing key （我的老的交換機(jī)為e_test  key 為k1）

主要代碼為：

function mqInitYanChi($e_name,$q_name,$k_route,$conn)

{

//創(chuàng)建連接和channel 

$channel = new AMQPChannel($conn); 

//創(chuàng)建交換機(jī)對象    

$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';

//綁定交換機(jī)與隊(duì)列，并指定路由鍵 

//創(chuàng)建隊(duì)列    

$q = new AMQPQueue($channel); 

$q->setName($q_name);   

#$q->setFlags(AMQP_DURABLE); //持久化  

$q->setArgument('x-dead-letter-exchange','e_test'); //設(shè)置ttl超時(shí)轉(zhuǎn)發(fā)到e_test

$q->setArgument('x-dead-letter-routing-key','k1'); //設(shè)置ttl超時(shí)轉(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í)候設(shè)置ttl就行了 其實(shí)很簡單

主要代碼：

$message = "測試延遲!"; 

$ex1=mqInitYanChi('e_yanchi','q_yanchi','k1',$conn);

$attributes = array('expiration' => 5000); //設(shè)置為5秒

$ex1->publish($message,'k1','1',$attributes);

就這樣 就可以發(fā)送到q_yanchi隊(duì)列里邊的 消息 五秒后過期  轉(zhuǎn)發(fā)到 綁定了 e_test的交換機(jī) routing-key 為k1的隊(duì)列中去了  

以上是“如何使用TTL+DLX的方式來實(shí)現(xiàn) 延遲消息”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道！