WS02 JMS传输协议适用于Websphere MQ

4

经过几天的查找,我无法从IBM MQ消费消息。我按照文档进行操作,但系统仍然无法正常工作。我正在使用4.8.0和MQ 7.5.0.2

错误

[2014-02-06 01:06:14,341] ERROR - JMSListener Unable to continue server startup as it seems the JMS Provider is not yet started. Please start the JMS provider now.
[2014-02-06 01:06:14,342] ERROR - JMSListener Connection attempt : 1 for JMS Provider failed. Next retry in 20 seconds
[2014-02-06 01:06:34,364] ERROR - JMSListener Unable to continue server startup as it seems the JMS Provider is not yet started. Please start the JMS provider now.
 [2014-02-06 01:06:34,365] ERROR - JMSListener Connection attempt : 2 for JMS Provider failed. Next retry in 40 seconds

root@sandbox:/opt/wso2esb-4.8.0/FFDC# more JMSCC0001.FDC
----------------------------------START FFST------------------------------------
/opt/wso2esb-4.8.0/FFDC/JMSCC0001.FDC PID:5897

                                JMS Common Client First Failure Symptom Report


Product          :- IBM WebSphere MQ classes for JMS
Date/Time        :- Thu Feb 06 00:54:07 CET 2014
System time      :- 1391644447539
Operating System :- SunOS
UserID           :- root
Java Vendor      :- Oracle Corporation
Java Version     :- 23.3-b01

Source Class     :- com.ibm.mq.jms.MQQueueConnectionFactory
Source Method    :- readObject()
ProbeID          :- XF001003
Thread           :- name=localhost-startStop-1 priority=5 group=main ccl=org.eclipse.core.runtime.internal.adaptor.ContextFinder@1da36ad

axis2 config

<transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
        <parameter name="default" locked="false">
                <parameter name="java.naming.factory.initial" locked="false">com.sun.jndi.fscontext.RefFSContextFactory</parameter>
                <parameter name="java.naming.provider.url" locked="false">file:///var/tmp/jndi</parameter>
                <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">ivtQCF</parameter>
                <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter>
                <parameter name="transport.jms.Destination" locked="false">ivtQ</parameter>
        </parameter>
</transportReceiver>

测试JNDI是否正常工作

java JmsJndiConsumer -i file:///var/tmp/jndi -c ivtQCF -d ivtQ
Initial context found!
Received message:

  JMSMessage class: jms_text
  JMSType:          null
  JMSDeliveryMode:  2
  JMSExpiration:    0
  JMSPriority:      4
  JMSMessageID:     ID:414d5120514d412020202020202020204424ee5203db0020
  JMSTimestamp:     1391646438379
  JMSCorrelationID: null
  JMSDestination:   queue://QMA/QUEUE1
  JMSReplyTo:       null
  JMSRedelivered:   false
    JMSXAppID: JmsJndiProducer
    JMSXDeliveryCount: 1
    JMSXUserID: webservd
    JMS_IBM_Character_Set: UTF-8
    JMS_IBM_Encoding: 273
    JMS_IBM_Format: MQSTR
    JMS_IBM_MsgType: 8
    JMS_IBM_PutApplType: 28
    JMS_IBM_PutDate: 20140206
    JMS_IBM_PutTime: 00271840
JmsJndiProducer: Your lucky number today is 324

proxy

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
       name="StockQuoteProxy2"
       transports="jms"
       startOnLoad="true"
       trace="disable">
   <description/>
   <target>
      <endpoint>
         <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
      </endpoint>
     <inSequence>
         <property name="OUT_ONLY" value="true"/>
     </inSequence>
     <outSequence>
         <send/>
     </outSequence>
   </target>
   <publishWSDL uri="file:repository/samples/resources/proxy/sample_proxy_1.wsdl"/>
   <parameter name="transport.jms.ContentType">
      <rules>
         <jmsProperty>contentType</jmsProperty>
         <default>application/xml</default>
      </rules>
   </parameter>
</proxy>

我检查了网络,但是没有看到来自esb到mq服务器的任何连接。

有什么想法吗?

更新

我已经在示例中配置了axis服务器($WSO2_HOME/samples/axis2Server/repository/conf/axis2.xml),使用了完全相同的jms传输(默认)。

编译'SimpleStockQuoteService'并启动服务器后,我可以看到它运行正常。

cd wso2esb-4.8.1/samples/axis2Server/src/SimpleStockQuoteService/ && ant
cd wso2esb-4.8.1/samples/axis2Server/ && ./axis2server.sh

14/02/10 21:20:29 INFO jms.JMSListener: JMS listener started
14/02/10 21:20:30 INFO jms.JMSListener: Connection attempt: 1 for JMS Provider for
service: SimpleStockQuoteService was successful!
14/02/10 21:20:30 INFO jms.ServiceTaskManager: Task manager for service : 
SimpleStockQuoteService [re-]initialized
14/02/10 21:20:31 INFO jms.JMSListener: Started to listen on destination : ivtQ of 
type queue for service SimpleStockQuoteService
14/02/10 21:20:31 INFO util.SampleAxis2ServerManager: [SimpleAxisServer] Started

我还不明白为什么它在碳中无法工作!!!


您在CARBON_HOME/repository/logs/wso2carbon.log中看到任何错误吗? - Kasun Gajasinghe
读取JNDI配置存在问题,因此您会在连接工厂中看到问题,从而无法连接到MQ服务器。ws02使用的配置文件存在一些问题。 - Neeraj Krishna
TID: [0] [ESB] [2014-02-06 22:38:09,956] 错误 {org.apache.axis2.transport.jms.JMSListener} - 无法继续服务器启动,因为似乎 JMS 提供程序尚未启动。请现在启动 JMS 提供程序。{org.apache.axis2.transport.jms.JMSListener}TID: [0] [ESB] [2014-02-06 22:38:09,957] 错误 {org.apache.axis2.transport.jms.JMSListener} - JMS 提供程序连接尝试:第 7 次失败。下一次重试将在 1280 秒后发生 {org.apache.axis2.transport.jms.JMSListener}。 - user3277560
@Neeraj。我使用JmsJndiConsumer测试了/var/tmp/jndi,它可以正常工作,但我不知道为什么读取文件时会出现问题。 - user3277560
$ ls /opt/wso2esb-4.8.0/repository/components/lib/ | more CL3Export.jar CL3Nonexport.jar com.ibm.mq.headers.jar com.ibm.mq.jar com.ibm.mq.jmqi.jar com.ibm.mqjms.jar dhbcore.jar fscontext.jar jms.jar jndi.jar jta.jar ldap.jar providerutil.jar rmm.jar - user3277560
显示剩余2条评论
1个回答

2
我发现让它工作的唯一方法是修改启动脚本(ws02server.sh),将MQ客户端Java库添加到类路径中。
如果MQ传输类型为BIND(ws02在与MQ服务器相同的服务器上),则还需要包括JNI库(-Djava.library.path=/opt/mqm/java/lib)。
根据文档,在repository/component/lib中复制MQ Java库并不起作用。
在Solaris和RHEL7上测试了MQ 7.5.0.2和ws02 4.8.1。

我在Windows环境下进行了测试,但没有成功(我的JNDI正常工作,我已经使用两个Java代码进行了测试,并且可以从队列发送和接收消息):rem --- 适用于IBM MQ set CARBON_CLASSPATH=.\mq\com.ibm.mq.jar;.\mq\com.ibm.mqjms.jar;.\mq\com.ibm.mq.jmqi.jar;.\mq\dhbcore.jar;%CARBON_CLASSPATH% - Jorge Infante Osorio

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接