RabbitMQ是否支持按時間從隊列中執行進程？

Question

這次可以在RabbitMQ中爲呼叫處理程序存儲時間嗎？ RabbitMQ是否支持這個？

Answer 1

是的，它支持，但只能通過額外的插件。

There is more dateiled about that

簡單地說，你需要安裝插件rabbitmq-plugins enable rabbitmq_delayed_message_exchange，並添加新標題到消息：

byte[] messageBodyBytes = "delayed payload".getBytes(); 
AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder(); 
headers = new HashMap<String, Object>(); 
headers.put("x-delay", 5000); 
props.headers(headers); 
channel.basicPublish("my-exchange", "", props.build(), messageBodyBytes); 

所以你需要把x-delay值與毫秒後應該處理此消息。