使用java监视IBM MQ

import com.ibm.mq.*;
import com.ibm.mq.constants.CMQC;

public static void connectMQ() {
    MQQueueManager qMgr = null;
    try {
        MQEnvironment.hostname = "your_host"; // 替换为您的MQ服务器地址
        MQEnvironment.port = 1414; // 请替换为您的MQ服务器端口
        MQEnvironment.userID = "your_username"; // 替换为您的MQ用户名
        MQEnvironment.password = "your_password"; // 替换为您的MQ密码

        qMgr = MQQueueManager.getInstance("QM_NAME"); // 请替换为您的队列管理器名称
    } catch (MQException e) {
        System.out.println("连接到MQ时出错: " + e.getMessage());
    }
}

public static void receiveMessages(MQQueueManager qMgr, String queueName) {
    try {
        int openOptions = CMQC.MQOO_INPUT_SHARED | CMQC.MQOO_FAIL_IF_QUIESCING;
        MQQueue queue = qMgr.accessQueue(queueName, openOptions);

        MQMessage msg = new MQMessage();
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        gmo.options = gmo.options + CMQC.MQGMO_WAIT;
        gmo.waitInterval = 5000; // 等待5秒

        queue.get(msg, gmo);
        String messageText = msg.readStringOfByteLength(msg.getMessageLength());
        System.out.println("收到消息: " + messageText);

        queue.close();
    } catch (MQException e) {
        System.out.println("从队列接收消息时出错: " + e.getMessage());
    }
}

public static void main(String[] args) {
    MQQueueManager qMgr = connectMQ();
    if (qMgr != null) {
        receiveMessages(qMgr, "your_queue_name"); // 请替换为您的队列名称
    }
}