通过JAVA从MQ读取消息的时候报错及解决

Posted 2020-10-07 申公的博客

如果是通过JAVA将消息写入到MQ，再通过JAVA去读取消息，采用MQMessage读消息的方法readUTF()去读取的时候，就不会报错，可以正常读出来。如果采用在MQ资源管理器中插入测试消息或者是通过另外一台MQ服务器往当前MQ服务器通过远程队例写消息过来，通过JAVA读取出会错，我这里疑点有两个：

1、通过MQ资源管理器放入的消息的编码是什么？是否在读消息的时候需要指定读消息的编码?我通过JAVA进入的编码为1381，读的时候也是1381

2、我现在JAVA这边的MQ LIB是从WEBSPHERE6中取出来的，因为MQ7中带的JAR包老是报一些类不存在，现在的MQ服务是V7，不知道是否与这个有关。

个人感觉第一种原因的可能性最大，但不知道MQ的默认字体是什么？

 

通过命令DISPLAY QMGR可以查看到当前MQ使用的默认字符集为1381，其它的地方也说MQ在WINDOWS上安装的时候默认字符集为1381，可是我通过JAVA程序去读的时候，设置的CCSID也为1381，也是读的时候老是报如下错误：

java.io.EOFException
 at java.io.DataInputStream.readFully(Unknown Source)
 at java.io.DataInputStream.readUTF(Unknown Source)
 at java.io.DataInputStream.readUTF(Unknown Source)
 at com.ibm.mq.MQMessage.readUTF(MQMessage.java:1229)
 at test.MessageByMQ.getMessage(MessageByMQ.java:123)
 at test.MessageByMQ.main(MessageByMQ.java:146)

我通过JAVA往里面放消息设置的CCSID也为1381却可以正确读出来，但这里就搞不懂为什么读不出来了，

难道是上面提到的第三个原因，我的JAR包是V6的，MQ是V7的？

 

基本解决：
原来读消息的方法为：readUTF()
但是这种方式在其它的应用程序采用writeUTF写入消息的时候不会报错，就是我上面提到的当前的JAVA程序可以读出该程序中写入的消息，
但是通过MQ资源管理器放入的测试消息就不是UTF这样的格式的，所以会报错，这说面从MQ中读消息的时候读取的格式必须与放入消息的格式相兼容，否则读取消息的时候会报错。
后来尝试采用readLine的方式去读取，可以正常读出来，但是如果写入的是XML这样的消息，采用readLine就不行了，后面尝试readStringOfCharLength方法，可以正常读出客户端应用程序通过writeBytes方法写入的消息，也可以正常读出通过MQ客户端放入的测试报文，
这个问题搞了我一整天，终于可以暂时放一下了。

 读的代码如下：

...

MQMessage retrieve = new MQMessage();
String message=retrieve.readStringOfCharLength(32000).trim();

...