2017-03-06 165 views
0

我在尝试连接到WebSphere JMS。我可以使用HermesJMS连接到它,下面是使用HermesJMS连接到我的队列的步骤,然后是使用logstash-plugin-jms尝试连接的步骤。 请真的需要帮助,试图消费这个队列中的消息,并找不到任何关于它的文档。如何使用logstash-input-jms插件与WebSphere JMS建立连接?

续步骤在HermesJMS

1)我创建了一个文件夹,并将其命名为我的客户机上的“WASJMS”,并复制从WebSphere下列文件到这个文件夹中读取的WebSphere JMS队列中的消息。

com.ibm.ws.sib.client.thin.jms_8.5.0.jar 
com.ibm.ws.orb_8.5.0.jar 
com.ibm.ws.ejb.thinclient_8.5.0.jar 
sas.client.props 
ssl.client.props 

2)在WebSphere我有key.p12和trust.p12文件,这是我不得不转换为JKS格式,因此它可以由Oracle JVM代替IBM JVM(的WebSphere默认JVM)

可以使用
# keytool -v -importkeystore -srckeystore trust.p12 -destkeystore trust.jks -srcstoretype pkcs12 -deststoretype jks -srcstorepass WebAS -deststorepass WebAS_JKS -alias root2 -srckeypass WebAS -destkeypass WebAS_JKS 

# keytool -v -importkeystore -srckeystore key.p12 -destkeystore key.jks -srcstoretype pkcs12 -deststoretype jks -srcstorepass WebAS -deststorepass WebAS_JKS -alias default -srckeypass WebAS -destkeypass WebAS_JKS 

然后我复制的新文件(key.jks和trust.jks)到我的客户端文件夹(WASJMS)

3)有些变动是在ssl.client.props和sas.client.props文件来设置jks文件路径,密码并将其设置为读取SUN(Oracle)类型。这些文件的主片低于:

ssl.client.props

com.ibm.ssl.alias=DefaultSSLSettings 
com.ibm.ssl.protocol=SSL 
com.ibm.ssl.securityLevel=HIGH 
com.ibm.ssl.trustManager=SunX509 
com.ibm.ssl.keyManager=SunX509 
com.ibm.ssl.contextProvider=SunJSSE 
com.ibm.ssl.enableSignerExchangePrompt=gui 

# KeyStore information 
com.ibm.ssl.keyStoreName=ClientDefaultKeyStore 
com.ibm.ssl.keyStore=C:/Users/ranieri/WASJMS/key.jks 
com.ibm.ssl.keyStorePassword=WebAS_JKS 
com.ibm.ssl.keyStoreType=JKS 
com.ibm.ssl.keyStoreProvider=SUN 
com.ibm.ssl.keyStoreFileBased=true 

# TrustStore information 
com.ibm.ssl.trustStoreName=ClientDefaultTrustStore 
com.ibm.ssl.trustStore=C:/Users/ranieri/WASJMS/trust.jks 
com.ibm.ssl.trustStorePassword=WebAS_JKS 
com.ibm.ssl.trustStoreType=JKS 
com.ibm.ssl.trustStoreProvider=SUN 
com.ibm.ssl.trustStoreFileBased=true 
com.ibm.ssl.trustStoreReadOnly=false 

sas.client.props

com.ibm.CORBA.authenticationTarget=BasicAuth 
com.ibm.CORBA.authenticationRetryEnabled=true 
com.ibm.CORBA.authenticationRetryCount=3 
com.ibm.CORBA.validateBasicAuth=true 
com.ibm.CORBA.securityServerHost=bpm857 
com.ibm.CORBA.securityServerPort=9810 
com.ibm.CORBA.loginTimeout=300 
com.ibm.CORBA.loginSource=properties 

# RMI/IIOP user identity 
com.ibm.CORBA.loginUserid=myuser 
com.ibm.CORBA.loginPassword=mypassword 

4)然后,我改变hermes.bat文件在启动时使用我的ssl.client.props和sas.client.props,在最后一行之前粘贴以下文件。

set SSL_RMI_DEFS=^
-Dcom.ibm.SSL.ConfigURL="file:/C:/Users/ranieri/WASJMS/ssl.client.props"^
-Dcom.ibm.CORBA.ConfigURL="file:/C:/Users/ranieri/WASJMS/sas.client.props" 
set HERMES_OPTS=%HERMES_OPTS% %SSL_RMI_DEFS% 

5)然后我打开HermesJMS,创建了我命名为was855一个新的会话和提供商选项卡上,我创建了一个新组(was855sib),并添加了所有需要的罐子(3个罐子文件,我提到的步骤1)

enter image description here

6)然后,早在会议标签我选择hermes.JNDIQueueConnectionFactory为类,然后选择was855sib使用他们的罐子依赖。在那之后,我添加3个属性并将其值设置如下:

binding: jms/RanieriConnectionFactory 
initialContextFactory: com.ibm.websphere.naming.WsnInitialContextFactory 
providerURL: iiop://bpm857:9810 

而且,我已经通知用户名和密码字段,这是WebSphere用户,并通过有权限读取队列。

enter image description here

7)这就是全部。这个设置后所有我需要做的就是右键单击创建的会话,然后选择“查看”选项,所以它列出的所有JMS队列,我可以选择我的JMS/RanieriQueue

enter image description here

就是这样。我想使用logstash-input-jms插件读取相同的队列(jms/RanieriQueue),我尝试使用以下配置。

logstash.conf

input { 
    jms { 
     yaml_file => "C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/config/jms.yml" 
     yaml_section => "websphere" 
     include_header => true 
     include_properties => true 
     include_body => true 
     use_jms_timestamp => false 
     destination => "jms/RanieriQueue" 
     interval => 3 
     runner => async 
    } 
} 
output { 
    stdout { codec => rubydebug } 
} 

jms.yml

# JMS 
websphere: 
# Connect to a remote WebSphere JMS Queue 
    :jndi_name: jms/RanieriConnectionFactory 
    :jndi_context: 
    java.naming.factory.initial: com.ibm.websphere.naming.WsnInitialContextFactory 
    java.naming.provider.url: iiop://bpm857:9810 
    java.naming.factory.url.pkgs: com.ibm.ws.naming 
    java.naming.security.principal: bpmadmin 
    java.naming.security.credentials: bpmadmin 
    :require_jars: 
     - C:\Users\ranieri\WASJMS\com.ibm.ws.ejb.thinclient_8.5.0.jar 
     - C:\Users\ranieri\WASJMS\com.ibm.ws.orb_8.5.0.jar 
     - C:\Users\ranieri\WASJMS\com.ibm.ws.sib.client.thin.jms_8.5.0.jar 

而且,我已经改变了的setup.bat内logstash-5.2.2/bin中加载ssl.client .props和sas.client.props添加以下行:

SET JAVA_OPTS=%JAVA_OPTS% -Dcom.ibm.SSL.ConfigURL=file:/C:/Users/ranieri/WASJMS/ssl.client.props 
SET JAVA_OPTS=%JAVA_OPTS% -Dcom.ibm.CORBA.ConfigURL=file:/C:/Users/ranieri/WASJMS/sas.client.props 

当我尝试启动logstash时,我收到以下错误消息。

22:38:29.931 [[主要] javax.jms.JMSSecurityException:CWSIA0006E:该 授权提供的用户名没有成功, :回溯=> [“com.ibm.ws.sib (com/ibm/ws/sib/api/jms/impl/JmsManagedConnectionFactoryImpl.java:186)“, ”com.ibm.ws.sib.api.jms.impl.JmsManagedConnectionFactoryImpl .createConnection(com/ibm/ws/sib/api/jms/impl/JmsManagedConnectionFactoryImpl.java:138)“, ”java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)“ , “RUBY.initialize(C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/vendor/bundle/jruby/1.9/gems/jruby-jms-1.2.0-java/lib/ JMS/connection.rb:20 4)“, ”RUBY.start(C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/vendor/bundle/jruby/1.9/gems/jruby-jms-1.2.0-java /lib/jms/connection.rb:50)“, ”RUBY.run_async(C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/vendor/bundle/jruby/1.9/gems/ logstash-input-jms-3.0.0 -java/lib/logstash/inputs/jms.rb:226)“, ”RUBY.run(C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2 .2/vendor/bundle/jruby/1.9/gems/logstash -input-jms-3.0.0 -java/lib/logstash/inputs/jms.rb:257)“, ”RUBY.inputworker(C:/ Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/logstash-core/lib/logstash/pipeline.rb:449)“, ”RUBY.start_input(C:/Users/ranieri/Downloads/logstash-5.2 .2/logstash-5.2.2/logstash-core/lib/logstash/pipeline.rb:443)“, ”javalang/Thread.java:745)“]}

任何想法,哪里是我的错误? 谢谢

P.S:我也有一个java代码,可以连接到这个队列并阅读消息,让我知道如果你认为java代码可以帮助你了解问题出在哪里。

回答

0

我做到了。主要问题是我在目标参数上使用jndi名称,但我应该使用队列名称。要使用Java进行连接,只能使用jndi名称进行连接,但要使其与logstash-input-jms插件一起使用,必须按队列名称进行更改。

这是我的配置文件。

logstash.conf

input { 
    jms { 
     yaml_file => "C:/Users/ranieri/Downloads/logstash-5.2.2/logstash-5.2.2/config/jms.yml" 
     yaml_section => "websphere" 
     include_header => true 
     include_properties => true 
     include_body => true 
     use_jms_timestamp => false 
     destination => "RanieriQueueDestination" 
     interval => 3 
     runner => async 
    } 
} 
output { 
    stdout { codec => rubydebug } 
} 

jms.yml

# JMS 
websphere: 
    # Connect to a remote WebSphere JMS Queue 
:username: myuser 
:password: mypass 
:jndi_name: jms/RanieriConnectionFactory 
:jndi_context: 
    java.naming.factory.initial: com.ibm.websphere.naming.WsnInitialContextFactory 
    java.naming.provider.url: iiop://bpm857:9810 
    java.naming.security.principal: myuser 
    java.naming.security.credentials: mypass 
:require_jars: 
    - C:\Users\ranieri\WASJMS\com.ibm.ws.ejb.thinclient_8.5.0.jar 
    - C:\Users\ranieri\WASJMS\com.ibm.ws.orb_8.5.0.jar 
    - C:\Users\ranieri\WASJMS\com.ibm.ws.sib.client.thin.jms_8.5.0.jar