问题描述
应用范围:将消息从java应用发送到IBM MQ,供非java大型机应用使用
问题:非java大型机应用程序成功消费和处理简体中文字符消息。而繁体字符 msg 在接收应用程序时失败并出现以下错误。
0051963 MQ Request Failed. MQ Type: MQGET MQ Name: LOADER CC: 00000001 RC: 00002079
0051963 MQ Request Failed. MQ Type: MQOPEN MQ Name: ERROR CC: 00000002 RC: 00002035
0051963 MQ Request Failed. MQ Type: MQPUT MQ Name: ERROR CC: 00000002 RC: 00002019
错误代码 2079 说截断的消息已被接受,因此消息在接收应用程序时失败。
为什么要先截断繁体字消息?什么是 处理时应在java中使用正确的编码或CCSID 有汉字吗?
在 Java 应用程序中使用以下 MQ jar:
<!-- MQ Jars -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
<groupId>com.ibm</groupId>
<artifactId>com.ibm.mq.allclient</artifactId>
<version>8.0.0.5</version>
</dependency>
将消息发布到 IBM MQ 的 Java 代码。
Integer charSetId = 935;
String senderQ = "queue:///"+queueName+"?CCSID="+charSetId+"&targetClient=1";
jmstemplate.setExplicitQosEnabled(true);
jmstemplate.setDeliveryPersistent(false);
jmstemplate.send(senderQ,new MessageCreator() {
public javax.jms.Message createMessage(javax.jms.Session session) throws JMSException {
TextMessage msg = session.createTextMessage();
try {
msg.setIntProperty(WMQConstants.JMS_IBM_CHaraCTER_SET,charSetId);
msg.setStringProperty(WMQConstants.JMS_IBM_UNMAPPABLE_ACTION,"REPLACE");
msg.setText(txt);
} catch (Exception e) {
LOGGER.error(errorLog.getErrorDetail(e),e);
}
return msg;
}
});
解决方法
0051963 MQ 请求失败。 MQ 类型:MQGET MQ 名称:LOADER CC: 00000001 RC:00002079
原因代码 2079 (MQRC_TRUNCATED_MSG_ACCEPTED) 意味着您需要为 MQGET 使用更大的缓冲区。
0051963 MQ 请求失败。 MQ 类型:MQOPEN MQ 名称:错误 CC: 00000002 RC:00002035
原因代码 2035 (MQRC_NOT_AUTHORIZED) 表示您连接到队列管理器的 UserId 没有打开该特定队列的权限。获取 MQAdmin 为 UserId 设置权限,以便它可以打开队列。
0051963 MQ 请求失败。 MQ 类型:MQPUT MQ 名称:错误 CC: 00000002 RC:00002019
修复安全问题,此错误消息将消失。有人没有正确编码他们的应用程序,因为异常(2035 年的 RC)应该被捕获而不是继续放置消息。