删除mq示例

wuyouming666

2024-03-19 4601fbc2c8f20497010a7d938a8a051efb88f004

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

@@ -3,6 +3,9 @@
import com.rabbitmq.client.*;

import com.fasterxml.jackson.databind.ObjectMapper;



import java.util.ArrayList;

import java.util.List;



public class RabbitMQUtils {

    // ObjectMapper对象，用于序列化和反序列化JSON

    private static ObjectMapper objectMapper = new ObjectMapper();

@@ -25,6 +28,28 @@
        }

    }





    public List<String> readMessages(String queueName) 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;



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

            if (response != null) {

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

                messages.add(message);

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

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

                channel.basicAck(deliveryTag, false);

            }

        }



        return messages;

    }



    // 从 RabbitMQ 队列中接收消息

    public static void receiveMessage(String queueName) throws Exception {

        // 创建连接工厂并设置主机名