使用java的Websphere MQ SSL连接

Question

我有下面的代码，它连接到IBM Websphere MQ，它没有SSL，没有问题并且能够放置/获取消息。但是当我尝试使用SSL连接MQ时，出现错误。

请注意，patch（）方法将禁用SSL，该SSL将被执行但不会禁用SSL。

而不是这个，你能告诉我如何连接到具有SSL启用通道的MQ。

注 - 我有证书文件，如 - key.kdb，key.crl，key.rdb，key.sth和其他几个CA3，CA4.cer文件。我如何安装并在代码中使用它？

import com.ibm.mq.MQEnvironment; 
import com.ibm.mq.MQMessage; 
import com.ibm.mq.MQPutMessageOptions; 
import com.ibm.mq.MQQueue; 
import com.ibm.mq.MQQueueManager; 
import com.ibm.mq.constants.CMQC; 
import com.ibm.mq.*; 

import java.io.IOException; 
import java.net.URL; 
import java.security.KeyManagementException; 
import java.security.NoSuchAlgorithmException; 
import java.security.cert.CertificateException; 
import java.security.cert.X509Certificate; 
import java.util.Hashtable; 

import javax.net.ssl.HostnameVerifier; 
import javax.net.ssl.HttpsURLConnection; 
import javax.net.ssl.SSLContext; 
import javax.net.ssl.SSLSession; 
import javax.net.ssl.TrustManager; 
import javax.net.ssl.X509TrustManager; 

public class mq1 { 

public static String host = "localhost"; 
public static int  port = 1414; 
public static String strchannel = "MQ.CHL"; 
public static String strqueuemanager = "MQMGR"; 
public static String strqueue = "REQUEST.QUEUE"; 

@SuppressWarnings("deprecation") 
public static void main(String[] args) throws KeyManagementException, NoSuchAlgorithmException { 
//call patch() to skip SSL 
patch(); 

int openOptions = CMQC.MQOO_BROWSE | CMQC.MQOO_INQUIRE | CMQC.MQOO_OUTPUT | CMQC.MQOO_INPUT_AS_Q_DEF ; 

MQEnvironment.hostname = host; 
MQEnvironment.port = port; 
MQEnvironment.channel = strchannel; 
MQEnvironment.properties.put(CMQC.TRANSPORT_PROPERTY,CMQC.TRANSPORT_MQSERIES); 

MQQueueManager qMgr; 
try { 
qMgr = new MQQueueManager (strqueuemanager); 
System.out.println(qMgr); 
MQQueue destQueue = qMgr.accessQueue(strqueue, openOptions); 
System.out.println("Queue size:" + destQueue.getCurrentDepth()); 
MQMessage hello_world = new MQMessage(); 
System.out.println("MQMessage message created"); 
hello_world.writeUTF("Sending Sample message"); 
MQPutMessageOptions pmo = new MQPutMessageOptions(); 
try { 
destQueue.put(hello_world,pmo); 
destQueue.get(hello_world); 
} 
catch (Exception e) 
{ 
System.out.println(e.getMessage()); 
} 

int len = hello_world.getDataLength(); 
System.out.println("Length : " + len); 
System.out.println("GET: "+ hello_world.readString(len-1)); 
destQueue.close(); 
qMgr.disconnect(); 
} catch (Exception e) { 
e.printStackTrace(); 
} 
} 


public static void patch() throws KeyManagementException, NoSuchAlgorithmException { 

System.out.println("Calling SSL patch"); 

TrustManager[] trustAllCerts = new TrustManager[]{ 
new X509TrustManager() { 
public java.security.cert.X509Certificate[] getAcceptedIssuers() { 
return null; 
} 

public void checkClientTrusted(X509Certificate[] certs, String authType) { 
} 

public void checkServerTrusted(X509Certificate[] certs, String authType) { 
} 

} 
}; 

System.out.println("trustAllCerts = "+trustAllCerts); 

SSLContext sc = SSLContext.getInstance("SSL"); 

System.out.println("sc before init = "+sc); 

sc.init(
null, trustAllCerts, new java.security.SecureRandom()); 
HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory()); 
HostnameVerifier allHostsValid = new HostnameVerifier() { 
public boolean verify(String hostname, javax.net.ssl.SSLSession session) { 
return true; 
} 
}; 

System.out.println("sc after init= "+sc); 
System.out.println("allHostsValid= "+allHostsValid); 
// Install the all-trusting host verifier 
HttpsURLConnection.setDefaultHostnameVerifier(allHostsValid); 
} 

} 

Answer 1

最简单的方法是不要把它放在您的代码中，而是使用客户端通道定义表（CCDT）。然后，您可以在没有SSL的情况下使用它，稍后将CCDT更改为使用SSL，而无需更改您的代码。这被认为是客户端连接到IBM MQ的最佳实践。

这意味着您不再使用MQEnvironment类来传递通道名称，主机名等内容，而是使用带有两个参数的稍微不同的构造函数，第一个是先前的队列管理器名称，第二个是您的CCDT文件的名称。

你可以阅读更多有关如何在官方IBM MQ知识中心与Java使用CCDT下面的页面还包括一​​个链接，如何创建CCDT文件： -

• Using a client channel definition table with IBM MQ classes for Java