延迟队列:
延迟队列存储的对象是对应的延迟消息，所谓的延迟消息是指当消息被发送以后，并不想让消费者立刻拿到消息，而是等待特定的时间后，消费者才能拿到这个消息进行消费。
延迟队列的使用场景：
在订单系统中，一个用户下单之后通常有30分钟的时间进行支付，如果30分钟之内没有支付成功，则对这个订单进行异常处理，这个时候可以使用延迟队列来处理这些订单。
在AMQP协议中，或者RabbitMQ本身没有直接支持延迟队列的功能，但是可以通过DLX 和 TTL 模拟出延迟队列的功能。
定义多个级别的死信交换器以及死信队列，设置不同死信队列消息过期时间，消费者根据需求选择不同延迟等级的延迟队列进行消费。
优先级队列：
具有高优先级的队列具有高的优先权，优先级高的消息具备优先被消费的特权。
package com.song.songvue.config.message;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeoutException;/*** 生产者客户端代码*/
public class RabbitProducer {private static final String IP_ADDRESS = "172.16.200.239";private static final int PORT = 5672;public static void main(String[] args) throws IOException, TimeoutException {ConnectionFactory factory = new ConnectionFactory();factory.setHost(IP_ADDRESS);factory.setPort(PORT);factory.setUsername("root");factory.setPassword("123456");// 创建连接Connection connection = factory.newConnection();// 创建信道Channel channel = connection.createChannel();// 优先级队列 10Map<String,Object> params = new HashMap<>();params.put("x-max-priority", 10);channel.queueDeclare("song_five",true, false,false,params);channel.queueBind("song_five","exchange.normal","");// 优先级为5的消息channel.basicPublish("exchange.normal", "", new AMQP.BasicProperties.Builder().priority(5).build(), "priority message level five".getBytes());// 优先级为10的消息channel.basicPublish("exchange.normal", "", new AMQP.BasicProperties.Builder().priority(10).build(), "priority message level ten".getBytes());// 关闭资源channel.close();connection.close();}
}
recv message:priority message level ten
recv message:priority message level five