增加模拟通讯类

wuyouming666

2024-03-26 90110ed128dd9212caf3b7d5fb4a8d5f870d2905

 UnLoadGlassModule/src/main/java/com/mes/common/RabbitMQUtils.java

@@ -106,6 +106,25 @@
    }





//接收队列中所有消息，不消费

    public static List<String> browseMessages(String queueName) throws Exception {

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost(host);

        List<String> messages = new ArrayList<>();

        try (Connection connection = factory.newConnection();

             Channel channel = connection.createChannel()) {

            channel.queueDeclare(queueName, false, false, false, args);

            // 获取队列中的消息

            GetResponse response;

            while ((response = channel.basicGet(queueName, false)) != null) {

                String message = new String(response.getBody(), "UTF-8");

                messages.add(message);

            }

        }

        return messages;

    }







    private static Set<String> sentMessageIds = new HashSet<>();

//根据id发送消息

@@ -145,18 +164,18 @@
            channel.queueDeclare(queueName, false, false, false, args);



            GetResponse response;

        boolean found = false;



            while ((response = channel.basicGet(queueName, false)) != null) {

                String receivedMessage = new String(response.getBody(), "UTF-8");

                if (response.getProps().getMessageId().equals(messageId)) {

                    long deliveryTag = response.getEnvelope().getDeliveryTag();

                    channel.basicAck(deliveryTag, false);

                    System.out.println("Selected message: "+messageId+ receivedMessage);

                    return receivedMessage; // 返回选定的消息内容

                System.out.println("Selected message: " + messageId + " " + receivedMessage);

                return receivedMessage;

                } else {

                    // 对于不符合条件的消息，进行 Nack 操作

//                    long deliveryTag = response.getEnvelope().getDeliveryTag();

//                    channel.basicNack(deliveryTag, false, true);

                    return "Specified message not found in the queue.";

                // 未找到指定消息，继续查找

                channel.basicReject(response.getEnvelope().getDeliveryTag(), false);

                }

            }