jms - Mule JMS 消息被截断 - IBM MQ
问题描述
我有一个问题,我的 jms 消息没有完全发送到队列并被截断,队列中只设置了 100 个字符。这是我的配置:
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:util="http://www.springframework.org/schema/util"
xmlns:spring="http://www.springframework.org/schema/beans" xmlns:http="http://www.mulesoft.org/schema/mule/http"
xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns:vm="http://www.mulesoft.org/schema/mule/vm"
xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" xmlns:task="http://www.springframework.org/schema/task"
xmlns:script="http://www.mulesoft.org/schema/mule/scripting"
xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.4/mule.xsd
hhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/3.4/mule-http.xsd
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/3.4/mule-jms.xsd
http://www.mulesoft.org/schema/mule/vm http://www.mulesoft.org/schema/mule/vm/3.4/mule-vm.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd
http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/3.3/mule-scripting.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd">
<spring:bean id="MQConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
<spring:property name="transportType" value="1" />
<spring:property name="hostName" value="222.222.100.58"/>
<spring:property name="port" value="1414"/>
<spring:property name="queueManager" value="ESBDEVBKRQM"/>
</spring:bean>
<jms:connector name="WebsphereMQConnector"
connectionFactory-ref="MQConnectionFactory"
username="Administrator" password="*****"
numberOfConsumers="200" />
<flow name="test-webSphere-flow">
<http:inbound-endpoint address="http://localhost:8081/test/in/websphere3" method="POST"/>
<object-to-string-transformer />
<jms:outbound-endpoint queue="ACCT_Q_REQ" connector-ref="WebsphereMQConnector"/>
</flow>
</mule>
为了确保问题不是来自 wepshpere mq 端,我使用带有 ibm API 的 java 代码来发送消息,并且它已完全发送
package jms;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.ibm.mq.jms.MQQueueConnectionFactory;
public class TestJMS {
void send() {
String destinationName = "ACCT_Q_REQ";
MessageProducer producer = null;
Connection connection = null;
Session session = null;
try {
MQQueueConnectionFactory MQQueueConnectionFactory = new MQQueueConnectionFactory();
MQQueueConnectionFactory.setTransportType(1);
MQQueueConnectionFactory.setHostName("222.222.100.58");
MQQueueConnectionFactory.setPort(1414);
MQQueueConnectionFactory.setQueueManager("ESBDEVBKRQM");
connection = MQQueueConnectionFactory.createConnection("Administrator", "******");
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue source = session.createQueue(destinationName);
producer = session.createProducer(source);
connection.start();
String text = ".....";
TextMessage objectMessage = session.createTextMessage();
objectMessage.setText(text);
producer.send(objectMessage);
} catch (JMSException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new TestJMS().send();
}
}
这里可能是什么问题?
解决方案
您应该检查所有 MQ 相关的最大消息大小限制器:
- MQ 连接的 MaxMsgLength - 这是您的 MQQueueConnectionFactory 的一部分
- 队列管理器最大消息长度,MAXMSGL
- 队列的 MQIA_MAX_MSG_LENGTH
- 如果您通过 MQ 通道接收消息,即使是通道的 MAXMSGL
以上所有内容都必须设置为高于 1000 的值才能正常工作...
推荐阅读
- c# - 限制可用整数的数量
- c++ - 为什么|| 操作员在我的情况下工作
- python - 在 IIS 10 上部署 Python Flask - 发布路由失败
- java - 如何使用 Jackson (Java) 正确打开 SSL 流到多个 URL?
- r - 如何将“base R”位置图迁移到“ggplot2”并避免“for”循环?
- excel - Excel 生成两张工作表之间的价格差异
- javascript - 错误:使用 google meet 链接创建活动时会议类型值无效
- flutter - Flutter中的网络请求面临问题
- mongodb - 我想通过 id 查找数据并传递正确的 id 但返回为 null
- sql - 将 SELECT 中的值与 ORACLE 中的分隔符连接起来