java - 使用 JMS 从 Oracle AQ 收到的 TextMessage 仅包含 '???'

Question

我需要连接到不同数据库中的两个 Oracle AQ 队列。当然，除了连接字符串之外，我在这两种情况下都使用完全相同的代码。其中一个队列工作正常，但第二个队列不行。

String db_string = "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=x.y.z.2)(PORT=1521))(ADDRESS=(PROTOCOL=TCP)(HOST=x.y.z.3)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=DBNAME)))";

String name = "scott";
String pwd = "tiger";

Properties info = new Properties();
info.put("name", name);
info.put("password", pwd);

QueueConnectionFactory q_cf = AQjmsFactory.getQueueConnectionFactory(db_string, info);
QueueConnection q_conn q_conn = q_cf.createQueueConnection(name, pwd);

QueueSession q_sess = q_conn.createQueueSession(true, Session.CLIENT_ACKNOWLEDGE);
q_conn.start();
Queue queue = ((AQjmsSession) q_sess).getQueue("test","myaq");
((AQjmsDestination) queue).start(q_sess, true, true);
QueueReceiver q_recvr = q_sess.createReceiver(queue);
TextMessage message = (TextMessage) q_recvr.receive();

System.out.println(message.getText());

当我使用代码连接到工作正常的 AQ 时，它可以正确打印消息中包含的文本。无论消息包含什么内容，第二个 AQ 都只打印三个引号。

我使用的是 aqapi 10.2.0.2，并且已经使用 ojdbc14 10.2.0.2.0 和 ojdbc5 11.1.0.6.0 进行了测试。正在运行的 AQ 运行在 Oracle 11.1.0.0.0 上，导致问题的 AQ 运行在 10.2.0.4.0 上。我使用 Wireshark 分析了 TNS 数据包，包含 AQ 消息的数据包在两个数据库中看起来非常相似。

工作案例的 TextMessage 对象的反射转储如下所示:

{text_data=MY_TEXT_MESSAGEtext_msg_cont=oracle.jms.AQjmsTextMessage_C@1a7508agen_msg_cont=oracle.jms.AQjmsGenMessage_C@198cb3dtext_lob=m_boolClass=class java.lang.Booleanm_byteClass=class java.lang.Bytem_shortClass=class java.lang.Bytem_intClass=class java.lang.Integerm_longClass=class java.lang.Longm_floatClass=class java.lang.Floatm_doubleClass=class java.lang.Doublem_strClass=class java.lang.Stringm_systemProperties={JMSXDeliveryCount=class java.lang.Integer, JMS_OracleConnectionID=class java.lang.String, JMSXGroupSeq=class java.lang.Integer, JMSXAppID=class java.lang.String, JMSXRecvTimestamp=class java.lang.Long, JMS_OracleExcpQ=class java.lang.String, JMS_OracleHeaderOnly=class java.lang.String, JMS_OracleOriginalMessageID=class java.lang.String, JMSXGroupID=class java.lang.String, JMSXUserID=class java.lang.String, JMS_OracleDeliveryMode=class java.lang.String, JMS_OracleTimestamp=class java.lang.Long, JMS_OracleDelay=class java.lang.Long, JMSXState=class java.lang.Integer}m_settableSystemProperties=[JMSXGroupID, JMSXGroupSeq]header_ext=oracle.jms.AQjmsMessageHeaderExt@472d48message_id=oracle.jms.AQjmsMessageID@edf3f6enqueue_time=1265887454000corr_id=msg_dest=test.myaqdel_mode=2redelivered=trueexpiration=0priority=1msg_properties={JMS_OracleDeliveryMode=oracle.jms.AQjmsPropDatum@2bc3f5}access_mode=0prop_read_only=truerecv_time=1265891032384msg_state=0excp_queue=msg_delay=0orig_msg_id=sender_id=attempts=5m_signature=session=oracle.jms.AQjmsSession@a613f8m_hdrOnly=falsem_isjmsbody=truecompliant=falseJMS_REPLY_TO=JMSReplyTo}

还有破损的:

{text_data=???text_msg_cont=oracle.jms.AQjmsTextMessage_C@1bf3d87gen_msg_cont=oracle.jms.AQjmsGenMessage_C@60991ftext_lob=m_boolClass=class java.lang.Booleanm_byteClass=class java.lang.Bytem_shortClass=class java.lang.Bytem_intClass=class java.lang.Integerm_longClass=class java.lang.Longm_floatClass=class java.lang.Floatm_doubleClass=class java.lang.Doublem_strClass=class java.lang.Stringm_systemProperties={JMSXDeliveryCount=class java.lang.Integer, JMS_OracleConnectionID=class java.lang.String, JMSXGroupSeq=class java.lang.Integer, JMSXAppID=class java.lang.String, JMSXRecvTimestamp=class java.lang.Long, JMS_OracleExcpQ=class java.lang.String, JMS_OracleHeaderOnly=class java.lang.String, JMS_OracleOriginalMessageID=class java.lang.String, JMSXGroupID=class java.lang.String, JMSXUserID=class java.lang.String, JMS_OracleDeliveryMode=class java.lang.String, JMS_OracleTimestamp=class java.lang.Long, JMS_OracleDelay=class java.lang.Long, JMSXState=class java.lang.Integer}m_settableSystemProperties=[JMSXGroupSeq, JMSXGroupID]header_ext=oracle.jms.AQjmsMessageHeaderExt@1e4f7c2message_id=oracle.jms.AQjmsMessageID@145f0e3enqueue_time=1265890738000corr_id=msg_dest=test.myaqdel_mode=2redelivered=trueexpiration=0priority=1msg_properties={???=oracle.jms.AQjmsPropDatum@c9d92c}access_mode=0prop_read_only=truerecv_time=1265891388844msg_state=0excp_queue=msg_delay=0orig_msg_id=sender_id=attempts=1m_signature=session=oracle.jms.AQjmsSession@60e128m_hdrOnly=falsem_isjmsbody=truecompliant=falseJMS_REPLY_TO=JMSReplyTo}

Answer 1

我也遇到了同样的问题。与数据库唯一的区别是oracle NLS_CHARACTERSET 参数。 if NLS_CHARACTERSET = WE8MSWIN1252 消息参数接收良好。如果 NLS_CHARACTERSET = CL8MSWIN1251 - 消息参数仅包含 '???'在参数名称中。

找到解决方案并修复问题。将 orai18n.jar 添加到 Web 服务器应用程序类路径即可解决问题。