消费者如何根据发布者设置的消息的优先级获取消息 RabbitMQ

Question

我已经为单个消费者（即可能根据消息优先级接收消息的单个消费者）设置了一些优先级的消息发布。 我想要的是获取这些消息并根据消费者端的消息优先级打印它们。嘿伙计们帮帮我！

public class Send extends Thread {

   int priority; 
   String name = "";
   String app_type = "";
   private static final String EXCHANGE_NAME = "topic_exchange";

    public void run()
    {
        ConnectionFactory connFac = new ConnectionFactory();
        connFac.setHost("localhost");

        try {

                Connection conn = connFac.newConnection();
                Channel channel = conn.createChannel();
                channel.exchangeDeclare(EXCHANGE_NAME, 
                BuiltinExchangeType.TOPIC);
                for(int j=1; j<=200; j++)
                {
                    randomWait();

                    int random = (int)(Math.random() * 10 + 1);

                    String routingKey = j+"."+"update"+"."+app_type;
                    String msg = name;
                    channel.basicPublish(EXCHANGE_NAME, routingKey, new 
                    AMQP.BasicProperties.Builder()
                            .contentType("text/plain")
                            .deliveryMode(2)
                            .priority(priority)
                            .build(),
                            msg.getBytes("UTF-8"));
                    System.out.println("Sent " + routingKey + " : " + msg + 
                    " "+" Priority : "+priority);
                }

                channel.close();
                conn.close();

        } catch (IOException ex) {
            Logger.getLogger(Send.class.getName()).log(Level.SEVERE, null, 
             ex);
            System.out.println("Exception1 :--"+ex);

        } catch (TimeoutException ex) {
            Logger.getLogger(Send.class.getName()).log(Level.SEVERE, null, 
          ex);
            System.out.println("Exception 2:--"+ex);
        }
    }

     void randomWait()
    {
        try {
           Thread.currentThread().sleep((long)(200*Math.random()));
        } catch (InterruptedException x) {
           System.out.println("Interrupted!");
        }
    }

   public static void main(String[] args) {
        // TODO code application logic here

        Send test1 = new Send();
        test1.name = "Hello ANDROID";
        test1.app_type = "ANDROID";
        test1.priority = 10;

        Send test2 = new Send();
        test2.name = "Hello ANDROID";
        test2.app_type = "ANDROID";
        test2.priority = 5;

        test1.start();
        test2.start();
    }
}

在上面的代码中，我使用线程来传递优先级和消息值，并同时启动这两个线程来发布具有不同优先级的消息。我已经在 AMQ Builder 中设置了优先级值。

Answer 1

队列必须是configured to support priority。