RabbitMQ-Queue-TTLCarter Ho3 Minutes2019年6月22日

• RMQ的Queue跟Kafka的Partition都會保存訊息直到Consumer來取走，來確保資料送達，但如果在大量訊息壓力下轟炸任誰也承受不住，所以必須要對Queue裡的訊息做保留策略。
• 一般的情況下我們會保留訊息一天，如果線上出了問題反映後還能有餘裕時間把queue裡的資料消化掉，所以機器配置至少要能承受一天的訊息量；當然是針對高頻率的訊息佇列。
• 設置TTL方式
  • rabbitctl
  • http
  • Per-Message TTL
  • Queue TTL
  • 以上設定最後會以最小TTL為準

    ## 透過rabbitctl
    rabbitmqctl set_policy TTL ".*" '{"message-ttl":60000}' --apply-to queues
    
    ## 透過http
    curl -i -u guest:guest -H "content-type:application/json"  -XPUT 
    -d'{"auto_delete":false,"durable":true,"arguments":{"x-message-ttl": 60000}}'
    http://localhost:15672/api/queues/{vhost}/{queuename}
    
    ## Per-Message TTL (發布事件時對訊息加入TTL)
    var body = Encoding.UTF8.GetBytes($"{message}");
    var prop = channel.CreateBasicProperties();
    prop.Expiration = $"{ttl}"; // Expiration是字串格式單位為秒正整數
    
    channel.BasicPublish(
        $"{exchange}",
        $"{routingKey}",
        prop,
        body);
    
    ## Queue TTL (對Queue設定TTL)
    //// generate queue
    var args = new Dictionary<string, object>();
    args.put("x-expires", $"{ttl}"); // Expiration是字串格式單位為秒正整數
    channel.QueueDeclare($"{queue}", false, false, false, args);