延迟队列

        如上一篇死信队列，在消息属性上设置TTL的方式，消息可能不会按时死亡，RabbitMQ只会检查第一个消息是否过期，如果过期就会丢到死信队列，如果第一个消息延时时间很长，而第二个消息延时时间很短，第二个消息则不会得到优先执行。这里利用插件实现延迟队列。

 插件下载地址

https://www.rabbitmq.com/community-plugins.html

下载文件放在服务器/usr/lib/rabbitmq/lib/rabbitmq_server-3.11.3/plugins下然后再shell中运行

rabbitmq-plugins enable rabbitmq_delayed_message_exchange
//重启
systemctl restart rabbitmq-server

Configuration配置类

@Configuration
public class Rabbimq2 {
    @Bean
    public CustomExchange customExchange(){
        Map<String,Object> map=new HashMap<>();
        map.put("x-delayed-type","direct");
        return new CustomExchange("exchange5","x-delayed-message",true,false,map);
    }
    @Bean
    public Queue queue(){
        return new Queue("queue5",true,false,false);
    }
    @Bean
    public Binding binding(){
        return BindingBuilder.bind(queue()).to(customExchange()).with("123").noargs();
    }
}

生产者

    @Test
    void contextLoads() {
        MessageProperties messageProperties=new MessageProperties();
        messageProperties.setDelay(40000);
        Message message1=new Message("hello".getBytes(),messageProperties);
        rabbitTemplate.convertAndSend("exchange5","123",message1);
    }
    @Test
    void test(){
        MessageProperties messageProperties1=new MessageProperties();
        messageProperties1.setDelay(20000);
        Message message2=new Message("jk".getBytes(),messageProperties1);
        rabbitTemplate.convertAndSend("exchange5","123",message2);
    }

消费者

@Component
public class rabbitmq {
    @RabbitListener(queues = "queue5")
    public void consume(String msg, Message message, Channel channel){
       System.out.println(msg);
    }
}

优先级队列

客户端通过配置队列的x-max-priority参数的方式设置一个队列支持的最大优先级以此来声明一个优先级队列。优先级最大值为255、最小值为0（默认值），推荐1～10。生产者可以通过设置priority属性设置消息的优先级（值越大，优先级越高）。优先级越高，越先被消费者消费，但是带来的内存、磁盘、CPU开销越高。

Configuration配置

@Configuration
public class DirectExchange1 {
    @Bean
    public Queue queue(){
        Map<String,Object> map=new HashMap<>();
        map.put("x-max-priority",10);
        return new Queue("queue6",true,false,false,map);
    }
    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange("exchange6",true,false);
    }
    @Bean
    Binding binding(){
        Binding binding= BindingBuilder.bind(queue()).to(directExchange()).with("123");
        return binding;
    }
}

生产者

 @Test
    void test(){
        for(int i=0;i<10;i++){
            if(i==5){
                rabbitTemplate.convertAndSend("exchange6","123","hello"+i,message ->{
                    MessageProperties messageProperties=message.getMessageProperties();
                    messageProperties.setPriority(5);
                    return  message;
                } );
            }
            else {
                rabbitTemplate.convertAndSend("exchange6","123","hello"+i,message ->{
                    MessageProperties messageProperties=message.getMessageProperties();
                    messageProperties.setPriority(1);
                    return  message;
                } );
            }
        }
    }

番外篇

由于文字代码太多，文字太少，这里写个java学习路线总结

对于想要学习Java编程语言的人来说，制定学习路线是非常重要的。在这篇文章中，我将为您提供一个基础的Java学习路线，帮助您更快地掌握Java编程语言。

Java 基础

首先，您需要了解Java基础知识。这些知识包括Java语法、变量和数据类型、运算符、流程控制语句、数组、类和对象等。这个阶段最好通过阅读一些Java入门书籍或者在线教程来学习。我的建议是，如果您已经有编程经验，可以选择一些更深入的学习资源，例如《Java核心技术》或者《Thinking in Java》。

面向对象编程

Java 是一种面向对象的程序设计语言。因此，在学习Java时，必须熟悉面向对象编程思想。这个阶段，您应该学习对象、类、封装、继承、多态等面向对象编程的概念。我的建议是在学习Java的同时，也可以去学习其他语言的面向对象编程，如C++或Python等。

Java 集合框架

Java集合框架是Java中最重要的部分之一。它包括了Java中大部分用于数据存储和处理的类和接口。了解集合框架非常重要，因为它们是您在编写Java程序时必须使用的最常见工具之一。我的建议是学习ArrayList、LinkedList、HashMap、HashSet等基本的集合类。

Java 输入输出流

在Java编程中，输入输出流是必不可少的。Java提供了各种各样的类和接口来访问文件、网络和其他设备上的数据。这个阶段，您应该学习如何使用Java的输入输出流来读取和写入文件、网络连接和其他数据源。我的建议是学习Java.io包中的InputStream和OutputStream类。

Java 网络编程

Java 是一个广泛用于网络编程的语言。了解Java网络编程对于开发网络应用程序非常重要。这个阶段，您应该去了解Java网络编程所需要的Socket编程、TCP协议和UDP协议。我的建议是跟随一些使用Java进行网络编程的教程学习，例如《Java网络编程》或者《Head First Java》。

Java 多线程编程

Java 实现多线程编程非常容易，并且可以有效地提高程序的性能。了解多线程编程对于开发复杂的应用程序至关重要。这个阶段，您应该学习Java中的线程模型、线程安全、同步和锁等概念。我的建议是学习Java中的Thread类和Runnable接口。

Java 数据库编程

Java 与数据库的连接对于许多应用程序来说是至关重要的。Java提供了一个称为JDBC（Java Database Connectivity）的API，它允许您使用Java编写与各种关系型数据库进行交互的应用程序。这个阶段，您应该学习如何使用JDBC API来连接数据库、执行SQL语句和处理结果集。我的建议是学习Java中的JDBC技术。

Servlet 和 JSP

Servlet 和 JSP 是Java Web开发的基础。Servlet 允许在Web服务器上运行Java代码，而JSP 允许您在HTML文档中嵌入Java代码。这个阶段，您应该学习如何编写Servlet和JSP以及如何将它们部署到Web服务器上。我的建议是学习Java EE平台相关的知识，如Tomcat或者其他应用服务器。

SSM ，Springboot, Springcloud等框架

Spring 是一个非常流行的Java应用程序开发框架。它提供了大量的组件和工具，以帮助您更轻松地编写高质量的Java应用程序。Spring家族非常强大。

总结

以上就是基础的Java学习路线总结。学习Java需要长时间的投入和练习，但如果您按照上述路线进行学习，您将能够快速地掌握Java编程语言并开始开发自己的Java应用程序。记住，不要害怕犯错，不断尝试和实践，这是成为一名优秀Java程序员的关键。