从Java读取MQ的所有消息时出现问题

Question

我已经开发了一个Java应用程序来从MQ读取消息。Java应用程序必须从MQ中读取所有消息，将它们放入列表中并返回列表。我正在使用while循环来逐一读取消息，如果捕获了2033异常并返回列表，则会中断。

我的问题是，阅读单个消息后出现2033异常。例如，我已将大约10条消息推入队列并运行我的应用程序，第一个循环读取了第一条消息并将其放入列表中。但是在第二个循环中，它在获取第二条消息时抛出2033年异常。然后，我需要运行该应用程序以读取第二条消息，并且发生相同的事情。

由于我是MQ的新手，所以无法找到导致其发生的路由。我正在使用Java8和IBM MQ核心库。下面是我的代码。

package com.reciever.mq;

import com.ibm.mq.*;

import com.ibm.mq.constants.MQConstants;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.io.IOException;

import java.util.*;

public class MQReceiver {

    private static final Logger LOGGER = LoggerFactory.getLogger(MQReceiver.class);

    private static int GET_OPTIONS_CONSTANT = MQConstants.MQGMO_WAIT |

    MQConstants.MQGMO_PROPERTIES_COMPATIBILITY |

    MQConstants.MQGMO_ALL_SEGMENTS_AVAILABLE |

    MQConstants.MQGMO_COMPLETE_MSG |

    MQConstants.MQGMO_ALL_MSGS_AVAILABLE |

    MQConstants.MQGMO_SYNCPOINT;

    public static MQQueueManager queueManager;

    public static void main(String[] args) throws MQException {

        Hashtable<String, Object> mqOptions = new Hashtable<>();

        mqOptions.put(MQConstants.HOST_NAME_PROPERTY, "host.name"); //just a placeHolder

        mqOptions.put(MQConstants.CHANNEL_PROPERTY, "channelName");

        mqOptions.put(MQConstants.USER_ID_PROPERTY, "userName");

        mqOptions.put(MQConstants.TRANSPORT_PROPERTY, MQConstants.TRANSPORT_MQSERIES);

        mqOptions.put(MQConstants.PORT_PROPERTY, 1980);

        queueManager = new MQQueueManager("queueManager", mqOptions);

        int options = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT

        | MQConstants.MQOO_FAIL_IF_QUIESCING | MQConstants.MQOO_PASS_ALL_CONTEXT | MQConstants.MQOO_INQUIRE;

        MQQueue mq = queueManager.accessQueue("queueNametoRead", options);

        MQException.logExclude(2033);

下面是我运行程序后的sysouts

Current depth : 9

Recieved Message...

 No more messages.. : 2033

Final List size : 1

从上面的输出中，它的打印电流深度为9。但是在第二个循环中会断开。

Answer 1

从队列中获取消息时，将填充消息ID和相关性ID字段。如果使用相同的MQMessage方式获取下一条消息，则必须首先重置这两个字段。因此，在调用该get方法之前，请添加这两行。&nbsp;mqMessage.messageId&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;=&nbsp;MQConstants.MQMI_NONE; &nbsp;mqMessage.correlationId&nbsp;=&nbsp;MQConstants.MQCI_NONE;

Answer 2

您还可以在循环内移动MQMessage对象的创建&nbsp;while(hasMsges){&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; byte[] buffer = null;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; try{&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; MQMessage mqMessage = new mqMessage();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; mq.get(mqMessage, getOptions);这也将有助于解决问题