我在尝试连接到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)
6)然后,早在会议标签我选择hermes.JNDIQueueConnectionFactory为类,然后选择was855sib使用他们的罐子依赖。在那之后,我添加3个属性并将其值设置如下:
binding: jms/RanieriConnectionFactory
initialContextFactory: com.ibm.websphere.naming.WsnInitialContextFactory
providerURL: iiop://bpm857:9810
而且,我已经通知用户名和密码字段,这是WebSphere用户,并通过有权限读取队列。
7)这就是全部。这个设置后所有我需要做的就是右键单击创建的会话,然后选择“查看”选项,所以它列出的所有JMS队列,我可以选择我的JMS/RanieriQueue
就是这样。我想使用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代码可以帮助你了解问题出在哪里。