如何使用TTL+DLX的方式來實現 延遲消息

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

正文:

  網上都是2種辦法去實現，第二種我就不說了，要升級rabbitmq 別人也說什么什么不行

   TTL + DLX 的方式來實現 延遲消息（java的 python的相關代碼都有 就是沒有 拍huang片的！！！！）

  擼代碼咯：

  1.首先得要創建一個新的隊列 新的交換機來存放延遲消息 并且設置新的隊列消息ttl到期后 轉發的 交換機 和 routeing key （我的老的交換機為e_test  key 為k1）

主要代碼為：

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

{

//創建連接和channel 

$channel = new AMQPChannel($conn); 

//創建交換機對象    

$ex = new AMQPExchange($channel);   

$ex->setName($e_name); 

$ex->setType(AMQP_EX_TYPE_DIRECT); //必須設置

$ex->setFlags(AMQP_DURABLE); //持久化 可以不必選

echo "exchange status:".$ex->declareExchange().'\n';

//綁定交換機與隊列，并指定路由鍵 

//創建隊列    

$q = new AMQPQueue($channel); 

$q->setName($q_name);   

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

$q->setArgument('x-dead-letter-exchange','e_test'); //設置ttl超時轉發到e_test

$q->setArgument('x-dead-letter-routing-key','k1'); //設置ttl超時轉發的key為k1

echo "Message Total:".$q->declare()."\n";   

echo 'Queue Bind: '.$q->bind($e_name, $k_route)."\n"; 

return $ex;

}

  2.也就是消息發送的送時候設置ttl就行了 其實很簡單

主要代碼：

$message = "測試延遲!"; 

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

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

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

就這樣 就可以發送到q_yanchi隊列里邊的 消息 五秒后過期  轉發到 綁定了 e_test的交換機 routing-key 為k1的隊列中去了  

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