IBM MQ JAVA客户端连接在多线程的时候特别要注意的一点
经常看到有人写的如下的IBM MQ客户端代码:MQEnvironment.port = 1414;
MQEnvironment.hostname = "147.151.240.48";
MQEnvironment.channel = "SYSTEM.DEF.SVRCONN";
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);
//1 环境设置
qMgr = new MQQueueManager("MQ1");
这种代码在多线程的环境下运行还是有风险的: 比如上面的代码运行到 "//1 环境设置",另一个线程也是用类似的代码做
环境设置,假设代码如下:
MQEnvironment.port = 1415;
MQEnvironment.hostname = "......";
MQEnvironment.channel = ".....";
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);
这个线程把MQEnvironment.port改为了1415...
第一个线程构造 Queue Manager :qMgr = new MQQueueManager("MQ1");这时候,传给构造"MQ1"的端口就变成了
1415了,就会连接不上Queue Manager了.
正确的做法应该是在每次构造Queue Manager的时候把相应的设置传入构造函数.如下:
Hashtable prop = new Hashtable();
prop.put(MQC.PORT_PROPERTY, 1414);
prop.put(MQC.HOST_NAME_PROPERTY, "147.151.240.48");
prop.put(MQC.CHANNEL_PROPERTY, "SYSTEM.DEF.SVRCONN");
prop.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);
qMgr = new MQQueueManager("MQ1",prop);
这样就不会有线程间的问题了.
页:
[1]