修改进片逻辑判断，添加异常捕获

ZengTao

2024-04-29 7687eb6cc76ab8ca20b39e7567255939abc4ff66

 springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java

@@ -13,28 +13,19 @@
    public static void main(String[] args) throws Exception {

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");



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



        try (Connection connection = factory.newConnection();

             Channel channel = connection.createChannel()) {

            boolean autoAck = false;

           // autoAck 参数设置为 false，然后手动确认消息处理完成

            // 循环获取队列中的所有消息

//            while (true) {

                GetResponse response = channel.basicGet(QUEUE_NAME, autoAck);



                GetResponse response = channel.basicGet(QUEUE_NAME, autoAck);

                if (response != null) {

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

                    messages.add(message);



                    // 手动确认消息处理完成

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

                    channel.basicAck(deliveryTag, false);

//                } else {

//                    // 如果队列为空，则退出循环

//                    break;

//                }



            }

        }