Spring-Konfiguration für JMS (Websphere MQ - SSL, Tomcat, JNDI, Nicht IBM JRE)

Ich glaube, dass ich endlich herausgefunden, wie man dieses Weg zu ziehen... hier ist eine kurze Beschreibung der Schritte. Wenn Sie weitere Einzelheiten benötigen, lassen Sie es mich wissen.

Pre-reqs:
Websphere MQ-Server installiert ist (mindestens v 8.0.0.2)
Konfigurieren Sie das QM -, SSL-und nicht-SSL-Kanäle, erstellen von Qs-und all das gute Zeug, die Sie benötigen.
Unnötig zu sagen, Sie müssen die Websphere MQ-Gläser. Darauf achten, keine Zulassungsbeschränkungen.

Schritt 1: Holen Sie sich die direkte Verbindung ohne SSL, keine JNDI. Sie verwenden müssen, diese Bohnen zu konfigurieren, spring-basierte JMS-Listener-und JMS-Vorlagen etc.

<bean id="mq-jms-cf-sandbox"
   class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory">
    <ref bean="mqQueueConnectionFactory" />
    </property>
</bean>
<bean id="mqQueueConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
   <property name="hostName" value="localhost" />
   <property name="port" value="1414" />
   <property name="queueManager" value="QM_SANDBOX" />
   <property name="transportType" value="1" />
   <property name="channel" value="NON_SSL_CHANNEL" />
 </bean>
 <bean id="jms-destination-sandbox" class="com.ibm.mq.jms.MQQueue">
   <constructor-arg value="SANDBOX_Q" />
    <property name="baseQueueManagerName">
    <value>QM_SANDBOX</value>
    </property>
    <property name="baseQueueName">
    <value>SANDBOX_Q</value>
    </property>
</bean>

Schritt 2: Holen Sie sich die direkte Verbindung mit SSL, keine JNDI. Ich fand die Einstellung ein wenig schwierig.

2a. Da ich mit einem nicht-IBM-JRE, die ich hatte, um sicherzustellen, dass die cipher-specs & cipher-suites konfiguriert werden musste entsprechend der Zuordnungen, die hier angegeben:
http://www-01.ibm.com/support/docview.wss?uid=swg1IV66840

Dies bedeutet natürlich, dass wir zumindest haben unseren Websphere MQ aktualisiert 8.0.0.2. In meinem Fall habe ich ECDHE_RSA_AES_256_GCM_SHA384 auf den SSL-Kanal und der Konfiguration des jms-Bohnen innerhalb einer Anwendung zu verwenden TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384, etwa so:

<bean id="mq-jms-cf-sandbox"
    class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory">
        <ref bean="mqQueueConnectionFactory" />
    </property>
</bean>
<bean id="mqQueueConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
  <property name="hostName" value="localhost" />
  <property name="port" value="1414" />
  <property name="queueManager" value="QM_SANDBOX" />
  <property name="transportType" value="1" />
  <property name="channel" value="SSL_CHANNEL" />
  <property name="SSLCipherSuite" value="TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384"/>
</bean>
<bean id="jms-destination-sandbox" class="com.ibm.mq.jms.MQQueue">
<constructor-arg value="SANDBOX_Q" />
    <property name="baseQueueManagerName">
       <value>QM_SANDBOX</value>
    </property>
    <property name="baseQueueName">
       <value>SANDBOX_Q</value>
    </property>
</bean>

2b. Erstellen Sie Zertifikate, keystores (kdbs), exchange, Zertifikate etc. Es gibt viele Möglichkeiten, dies zu tun. Aber bewusst sein, dass Sie brauchen, zu verstauen Passwörter, Schlüssel label für den queue manager muss 'ibmwebspheremqqmgr' – alles in Kleinbuchstaben, keine Leerzeichen (ohne Anführungszeichen), das Schlüssel-label sein muss, wie 'ibmwebspheremquserid' – alles in Kleinbuchstaben, keine Leerzeichen (ohne Anführungszeichen), wo die userid ist die userid, das läuft tomcat. Wenn Sie brauchen mehr details, wie genau habe ich es mit self-signed certs, lass es mich wissen.

2c. Jetzt haben Sie, um die JVM, dass tomcat ausgeführt wird, Lesen Sie Ihr-keystores. Es gibt viele Möglichkeiten, aber hier ist, wie ich es gemacht habe:
Erstellen Sie eine setenv.bat-Datei in den tomcat-bin-Ordner, mit folgendem Inhalt (Debuggen von SSL ist optional)

set JAVA_OPTS="-Djavax.net.ssl.trustStore=C:\path-to-keystore\key.jks" "-Djavax.net.ssl.trustStorePassword=topsecret" "-Djavax.net.ssl.keyStore=C:\path-to-keystore\key.jks" "-Djavax.net.ssl.keyStorePassword=topsecret" "-Djavax.net.debug=ssl" "-Dcom.ibm.mq.cfg.useIBMCipherMappings=false"

2d. Starten Sie tomcat mit dem folgenden Befehl:

catalina.bat run > ..\logs\tomcat.log 2>&1 

Stoppen, drücken Sie einfach Strg+c (bei windows). Egal welchen Weg Sie es tun, stellen Sie sicher, dass setenv.bat verwendet wird, während der start-up. Oder verwenden Sie JAVA_OPTS zum festlegen der keystore-Eigenschaften.

2e. Stellen Sie sicher, dass die Verwendung des SSL-Kanals arbeitet.

Schritt 3: Holen Sie sich eine JNDI-Verbindung mit nicht-SSL, JNDI
Es gibt viele, war die Einrichtung JNDI auf tomcat. Hier ist, wie ich es gemacht habe: Innerhalb der web-Anwendung eine Datei erstellen META-INF/Context.xml mit folgendem Inhalt:

<Resource
   name="jms/qcf_sandbox"
   auth="Container"
   type="com.ibm.mq.jms.MQQueueConnectionFactory"
   factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory"
   description="JMS Queue Connection Factory for sending messages"
   HOST="localhost"
   PORT="1414"
   CHAN="NON_SSL_CHANNEL"
   TRAN="1"
   QMGR="QM_SANDBOX"/>
<Resource
   name="jms/SandboxQ"
   auth="Container"
   type="com.ibm.mq.jms.MQQueue"
   factory="com.ibm.mq.jms.MQQueueFactory"
   description="JMS Queue"
   QU="SANDBOX_Q"/>

Nun in der spring-config, statt der direkten Konfigurationen, alles, was Sie tun müssen, ist:

<jee:jndi-lookup id="mq-jms-cf-sandbox" jndi-name="java:/comp/env/jms/qcf_sandbox" resource-ref="false" />
<jee:jndi-lookup id="jms-destination-sandbox" jndi-name="java:/comp/env/jms/SandboxQ" resource-ref="false" />

Beachten Sie, dass für die Kürze, ich wollte nur nicht, verwenden Sie Ressourcen-Referenzen. Falls Sie das tun, gibt es ein paar zusätzliche Schritte, die sich gerade nach vorne.

Schritt 4: Nun der Letzte Schritt ist die Verwendung eines SSL-Kanal und JNDI. Vorausgesetzt, Sie haben getan, Schritt 2, das ist einfach. Ändern Sie die META-INF/Context.xml mit folgendem Inhalt:

<Resource
   name="jms/qcf_sandbox"
   auth="Container"
   type="com.ibm.mq.jms.MQQueueConnectionFactory"
   factory="com.ibm.mq.jms.MQQueueConnectionFactoryFactory"
   description="JMS Queue Connection Factory for sending messages"
   HOST="localhost"
   PORT="1414"
   CHAN="SSL_CHANNEL"
   TRAN="1"
   QMGR="QM_SANDBOX"
   SCPHS="TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384"/>
<Resource
   name="jms/SandboxQ"
   auth="Container"
   type="com.ibm.mq.jms.MQQueue"
   factory="com.ibm.mq.jms.MQQueueFactory"
   description="JMS Queue"
   QU="SANDBOX_Q"/>

Beachten Sie die Zeile mit SCPHS="TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384". Wenn Sie brauchen, um stellen Sie die anderen Parameter finden Sie in der "Kurzen Form" Spalte in diesem link:
https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.ref.dev.doc/q111800_.htm%23jm10910_?lang=en

Hoffentlich alle diese arbeiten für Sie. Viel Glück!

Einmal diese Konfiguration funktioniert, das senden von Nachrichten ist ziemlich straight-forward. Aber dies ist, wie Sie hören eine Nachricht auf einer queue mit Spring JMS
Referenz: https://docs.spring.io/spring/docs/current/spring-framework-reference/html/jms.html

Schritt 1: Verwenden Sie Spring DefaultMessageListenerContainer und konfigurieren Sie Ihre beans in einer xml-Datei so (spring-beans.xml):

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"      
    "http://www.springframework.org/dtd/spring-beans.dtd">

   <!-- this is the Message Driven POJO (MDP) -->
   <bean id="messageListener" class="jmsexample.ExampleListener" />

   <!-- and this is the message listener container -->
   <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
       <property name="connectionFactory" ref="mq-jms-cf-sandbox"/>
       <property name="destination" ref="jms-destination-sandbox"/>
       <property name="messageListener" ref="messageListener" />
   </bean>

</beans>

Schritt 2: Fügen Sie diese zu Ihrem web.xml

<context-param>
   <param-name>contextConfigLocation</param-name>
   <param-value>/WEB-INF/context/spring-beans.xml</param-value>
 </context-param>

<listener>
       <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

Schritt 3: Schreiben Sie eine Nachricht Listener-Klasse in etwa so:

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class ExampleListener implements MessageListener {

    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                System.out.println(((TextMessage) message).getText());
            }
            catch (JMSException ex) {
                throw new RuntimeException(ex);
            }
        }
        else {
            throw new IllegalArgumentException("Message must be of type TextMessage");
        }
    }
}

Alternativ, anstelle von Schritt 3, wenn Sie mit spring integration, können Sie etwas wie das tun:

<int:channel id="jms-inbound"/>
    <int-jms:message-driven-channel-adapter
        id="jms-inbound-adapter" container="jmsContainer" channel="jms-inbound" 
        extract-payload="true" acknowledge="transacted" 
        message-converter="messagingMessageConverter" />

<beans:bean id="messagingMessageConverter" class="org.springframework.jms.support.converter.MessagingMessageConverter">
    </beans:bean>