java - 通过Java代码关闭MQ channel

Question

我是MQ程序员的新手。根据我的要求，我试图将示例XML消息放入队列中，并期望从响应队列中返回响应。
我可以看到关联的通道打开的时间很短，持续了几秒钟，然后又关闭了。请在下面找到我用来将消息放入队列的代码。请您提供宝贵的意见以解决此问题。

错误：

Process(12908.13579) User(abc) Program(amqrmppa)
                    Host(hostname)
AMQ9208: Error on receive from host 10 (10.0.0.1). 
EXPLANATION:
An error occurred receiving data from 10 (10.0.0.1) over TCP/IP. This may
be due to a communications failure.

使用的代码：

package com.company.mq;


import java.io.DataInputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.URL;

import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;

public class MQConnection {

                private static final String CORR_ID = "CORRELID";
                String qMgrStr = "";
                String hostName = "hostname";
                String password ="xxxx"; 
                String userName ="username";   
                String putqueueName = "putqueuename";
                String getqueuename = "getqueuename ";
                String channel = "channel";
                String replyToQueue = "replyToQueue";
                String replyToQueueManager = "";

                static String content = ""; 


                int port =10000;

                MQQueue readQueue = null;
                MQQueue writeQueue = null;
                MQQueueManager qManager;


                @SuppressWarnings("unchecked")
                public void init(){                              
                                MQEnvironment.hostname =hostName;
                                MQEnvironment.channel = channel;
                                MQEnvironment.port = port;
                                MQEnvironment.userID = userName;
                                MQEnvironment.password = password;
                                MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);

                                try {
                                                qManager = new MQQueueManager("");
                                                System.out.println("qManager====>"+qManager);
                                }catch(Exception e){
                                                e.printStackTrace();
                                }
                                try {
                                                System.out.println("qManager==> hhh"+qManager);
                                } catch (Exception e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                }
                }

                public String putAndGetMessage() throws InterruptedException, IOException{

                                int openOptions = MQC.MQOO_OUTPUT | MQC.MQPMO_SET_ALL_CONTEXT | MQC.MQOO_FAIL_IF_QUIESCING;
                                String msgString = content.toString();
                                System.out.println("msgString=="+msgString);
                                int expiryTime =60000;
                                MQMessage getmessage = null;
                                int waitInterval =4000;
                                try {
                                                System.out.println("qManager Desc==>"+qManager.getDescription());
                                                writeQueue =openWriteQueue(qManager,putqueueName);

                                                MQMessage message = myPut(writeQueue,msgString,expiryTime,getqueuename);

//                                                qManager.accessQueue(putqueueName, openOptions,null,null,null);

                                                readQueue =openReadQueue(qManager,getqueuename);

                                                getmessage =mqGet(readQueue,waitInterval,message.messageId);


                                                /*MQMessage msg = new MQMessage();
                                                msg.messageType = MQC.MQMT_REQUEST;
                                                msg.format = "MQSTR";
                                                // msg.characterSet = 500;
                                                msg.persistence = MQC.MQPER_NOT_PERSISTENT;
                                                msg.correlationId = CORR_ID.getBytes();
                                                // msg.messageId = CORR_ID.getBytes();
                                                msg.expiry= 10000;*/

                                                /*System.out.println("before");
                                                Thread.sleep(10000);
                                                System.out.println("after");*/

                                                /*MQGetMessageOptions gmo = new MQGetMessageOptions();
                                                int openOptions1 = MQC.MQGMO_WAIT| MQC.MQGMO_CONVERT| MQC.MQGMO_FAIL_IF_QUIESCING;
                                                System.out.println("in getqManager==>"+qManager);
                                                readQueue = qManager.accessQueue(getqueuename, openOptions1);
                                                System.out.println("deafaultQueue======>"+readQueue);
                                                readQueue.get(getmessage,gmo);
                                                System.out.println(getmessage.readInt());

                                                String retriveMsg = getmessage.readUTF();
                                                System.out.println("read===>"+retriveMsg);*/

                                } catch(MQException e){
                                                e.printStackTrace();
                                }
                                return getmessage.readString(getmessage.getMessageLength());


                }


                private MQMessage mqGet(MQQueue readQueue2, int waitInterval,
                                                byte[] corrID) throws MQException {
                                MQMessage responseMessage = new MQMessage();
                                responseMessage.correlationId =corrID;

                                MQGetMessageOptions gmo = new MQGetMessageOptions();
                                gmo.options =MQC.MQGMO_WAIT| MQC.MQGMO_CONVERT| MQC.MQGMO_FAIL_IF_QUIESCING;
                                gmo.matchOptions = MQC.MQMO_MATCH_CORREL_ID;
                                gmo.waitInterval = waitInterval;
                                // TODO Auto-generated method stub
                                readQueue2.get(responseMessage,gmo);
                                return responseMessage;
                }

                private MQQueue openReadQueue(MQQueueManager manager, String getqueuename2) throws MQException {
                                // TODO Auto-generated method stub
                                return openQueue(manager,getqueuename2,MQC.MQOO_INPUT_SHARED | MQC.MQOO_INQUIRE |MQC.MQOO_FAIL_IF_QUIESCING);
                }

                private MQMessage myPut(MQQueue writeQueue2, String msgString,
                                                int expiryTime, String getqueuename2) {
                                // TODO Auto-generated method stub

                                MQPutMessageOptions mpo =new MQPutMessageOptions();
                                mpo.options = MQC.MQPMO_NEW_MSG_ID | MQC.MQMO_MATCH_CORREL_ID;

                                MQMessage putmessage = new MQMessage();
                                putmessage.format = MQC.MQFMT_STRING;
                                putmessage.messageFlags = MQC.MQMT_REQUEST;
                                putmessage.replyToQueueName =replyToQueue;
                                putmessage.replyToQueueManagerName = qMgrStr;
                                putmessage.userId="userId";
                                putmessage.expiry =expiryTime;
                                try {
                                                putmessage.write(msgString.getBytes());
                                                try {
                                                                writeQueue2.put(putmessage,mpo);
                                                } catch (MQException e) {
                                                                // TODO Auto-generated catch block
                                                                e.printStackTrace();
                                                }
                                } catch (IOException e) {
                                                // TODO Auto-generated catch block
                                                e.printStackTrace();
                                }

                                return putmessage;
                }

                private MQQueue openWriteQueue(MQQueueManager manager, String queueName) throws MQException{
                                // TODO Auto-generated method stub
                                return openQueue(manager,queueName,MQC.MQOO_OUTPUT | MQC.MQPMO_SET_ALL_CONTEXT | MQC.MQOO_FAIL_IF_QUIESCING);
                }

                private MQQueue openQueue(MQQueueManager manager, String queueName, int options)  throws MQException{
                                // TODO Auto-generated method stub
                                return manager.accessQueue(queueName, options,null,null,null);
                }

                /**
                * @param args
                * @throws IOException 
                 * @throws InterruptedException 
                 */
                public static void main(String[] args) throws IOException, InterruptedException {
                                // TODO Auto-generated method stub

                                MQConnection conn = new MQConnection();

                                DataInputStream dis =    new DataInputStream ( new FileInputStream ("c://request//Request.xml"));

                                 byte[] datainBytes = new byte[dis.available()];
                                dis.readFully(datainBytes);
                                dis.close();

                                content = new String(datainBytes, 0, datainBytes.length);
                                //System.out.println("content===>"+content);

                                conn.init();
                                System.out.println("connected");
                                conn.putAndGetMessage();

                }

}

Answer 1

该应用程序似乎是封装MQ I / O的类。在实例化时，init例程构造该类并尝试连接到队列管理器。我看到的代码存在一些问题。另外，我怀疑我知道为什么代码会失败，但是问题中没有提供诊断信息，因此我只能猜测。我将先描述问题，然后再描述通常需要的诊断信息。

代码问题
该代码提供了用户ID和密码。除非这是与v8.0队列管理器对话的v8.0客户端，或者是使用出口通过TLS通道与MQ对话的客户端，否则不会检查密码，也不需要密码。更糟糕的是，如果通道不是TLS加密的，则ID和密码将通过网络以明文方式传输。取出密码。仅在需要在连接请求中覆盖应用提供的ID时，才使用ID。

该代码未打印链接的异常。 JMS异常是一种多层次的数据结构，其中顶层是JMS理解的异常，而较低层的异常是传输提供商所理解的异常。许多传输提供程序，尤其是那些用纯Java编写的传输提供程序，仅使用数据结构的顶层，并且不提供链接的异常。但是，作为开发人员，您不能假定情况永远不会如此。

没有合理的理由让JMS开发人员无法打印链接的异常。

当我在一家大型银行管理MQ Admin团队时，我的政策是，如果不遵循以下规则，那么生产将一无所有：


遇到JMS异常时，代码必须打印链接的异常。
如果没有链接到JMS Exception的异常，则代码必须打印字符串“未找到链接的异常”，以便我们知道它至少已查找了一个。


该代码使用MQC.MQPMO_SET_ALL_CONTEXT选项打开队列。通常不向非管理员用户授予此级别的特权。该代码明确指定了一个ID，表明它没有以管理员权限运行。由于这些原因，我怀疑您遇到2035错误，因为代码无法打印链接的异常，所以您当然看不到该错误。

缺少诊断
MQ的行为因版本而异。多年来，已经对Java / JMS类进行了重新包装，重构和升级，使其分别为JMS 1.1和JMS 2.0。诊断问题（无论是在此处发布还是在生产中断时发送到您的MQ管理员界面）应指示正在使用的MQ客户端和MQ服务器的版本。客户端节点和服务器节点上的dspmqver -a输出总是很有帮助的。

如前所述，链接的异常不会被打印。没有它，堆栈跟踪可能一文不值，因此，我一次也不感到失望，没有提供堆栈跟踪。但是，更新代码以打印链接的异常，并在将来包含堆栈跟踪。

客户端和服务器均会生成错误日志。除了队列管理器的错误日志之外，服务器上还有全局错误日志，用于识别队列管理器之前发生的事情或在全局MQ配置上运行的命令。在这种情况下，没有提供来自任何这些来源的错误日志信息。为什么不？

服务器还会生成事件消息。这些通常由监视代理程序使用，但可以由管理员启用并进行检查以确定问题。在没有错误日志消息的情况下，事件消息可能会非常有帮助。在这种情况下，我不希望它们出现，但是为了完整起见，请在此处提及。

FDC文件由队列管理器生成，并与全局错误日志存储在同一目录中。它们提供的信息比错误日志条目要详细得多，但并非总是产生。通常，问题诊断请求会提到没有生成FDC文件，或者提到它们并提供了它们的标题块。

资源资源
请参见：


MQ Knowledge Center（如果尚未找到）。
特别是troubleshooting部分，
以及linked exceptions部分。 （尽管这些不是特定于MQ的，但IBM至少提供了一些可以复制和粘贴的示例代码。请确保将其粘贴为纯文本并更正所有弯引号。）
MQ SupportPacs页，
...尤其是MS0T是最新的MQ Explorer（与后端QMgrs一起使用），而MS0P是一组插件，这些插件使Explorer可以解析事件消息等。
IBM的MQDev社区。尽管这对于查找文章和参考资料非常有用，但这些论坛是中等水平的。
对于社区，我更喜欢Vienna MQ list server或MQSeries.net上的论坛。两者都是繁荣的开发人员，管理员和IBM员工社区。
当然，请继续在websphere-mq标记中发布。上述两个社区都没有针对MQ完善的FAQ，而Stack Overflow提供了该功能。有几个MQ的老手和IBM员工正在策划Stack Overflow MQ标签。
如果您可以管理资金和差旅，请参加MQ Tech Conference。 IBM曾经召开过Transaction and Messaging会议，但是将它们与WebSphere的其余部分结合在一起形成了IMPACT。去年，它将包括IMPACT在内的多个会议合并到了Interconnect中。 MQ Tech会议整周都是MQ，而且价格便宜。由于IBM将其MQ课程和培训外包，因此课堂培训是不太可行的选择，并且会议涵盖了课堂培训中没有的材料。


坚持下去，祝你好运！

完全公开：我是MQ Tech会议的创始人之一，我的MQ咨询公司是赞助商。但是，在去年的第一天，它的MQ会话几乎与Interconnect整周的MQ会话一样多，因此我认为在推荐它方面不会有利益冲突。