我是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();
}
}
最佳答案
该应用程序似乎是封装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会话一样多，因此我认为在推荐它方面不会有利益冲突。
关于java - 通过Java代码关闭MQ channel ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29690318/