WAS7.0 + MQ 7.0 + JNDI 最简配置和收发示例
?
2、在WAS上配置JNDI的JMS队列连接工厂，资源——JMS——队列连接工厂?
?
?2.1、选择一个作用域
?2.2、点击【新建】
?2.3、选择 JMS 资源提供程序，这里选?WebSphere MQ messaging provider
?
?2.4、点击【确定】
?2.5、填写【名称】和【JNDI名称】
?
?
?2.6、点击【下一步】
?
?2.7、继续点击【下一步】，输入队列管理器名称?
?
?2.8、点击【下一步】，
????????? 【传输】选“客户机”
????????? 【主机名】写MQ所在主机地址
? ? ? ? ? 【端口】写MQ监听器的端口，默认1414
????????? 【服务器连接通道】，写连接通道的名字
?
?2.9、点击【测试连接】，并测试成功
?
?
?2.10、摘要，并点击【完成】
?
?
?3、配置队列JNDI
?3.1、点击【新建】
?
?
?3.2、选择 JMS 资源提供程序?
?
?3.3、点击【下一步】、填写各项
?
?
3.4、点击【WebSphere MQ 连接属性】，填写各个属性
?
?
3.5、点击【确定】。?
4、编写发送方程序
?
package jmsdemo.client;
import java.io.UnsupportedEncodingException;
import java.util.Properties;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class JMSClientProducer?
{
public static void main(String[] args)?
{
ConnectionFactory connectionFactory = null;
Connection connection = null;
Session session = null;
Destination destination = null; // 它有两个子接口 TemporaryQueue 和 TemporaryTopic 见《精通MQ》P249
MessageProducer messageProducer = null;
try
{
Properties p = new Properties();
p.put(Context.INITIAL_CONTEXT_FACTORY, "com.ibm.websphere.naming.WsnInitialContextFactory");
p.put(Context.SECURITY_AUTHENTICATION, "simple"); ?
p.put(Context.SECURITY_PRINCIPAL, "LZC"); ?
p.put(Context.SECURITY_CREDENTIALS, "999999999");?
p.put(Context.URL_PKG_PREFIXES, "com.ibm.ws.naming");?
p.put(Context.PROVIDER_URL, "iiop://127.0.0.1:2813/");?
Context context = new InitialContext(p);
Object jndi_ConnectionFactory = context.lookup("MQConnectionFactoryDEMO");
Object jndi_Destionation = context.lookup("队列DEMO");
connectionFactory = (ConnectionFactory) jndi_ConnectionFactory;
destination = (Destination) jndi_Destionation;
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
messageProducer = session.createProducer(destination);
messageProducer.setTimeToLive(100000);
BytesMessage message = session.createBytesMessage();
message.setStringProperty("MsgID", "MsgID_001");
message.writeBytes("MESSAGECONTENT".getBytes("GBK"));
message.setJMSCorrelationID("CorrelationID_001");
messageProducer.send(message);
}
catch ( NamingException e )
{}
catch ( JMSException e )
{}
catch ( UnsupportedEncodingException e )
{}
finally
{
if ( connection != null )
{
if ( messageProducer != null )
{
try
{
messageProducer.close();
}?
catch (JMSException e)?
{
e.printStackTrace();
}
}
if ( session != null )
{
try?
{
session.close();
}?
catch (JMSException e)?
{
e.printStackTrace();
}
}
try?
{
connection.close();
}?
catch (JMSException e)
{
e.printStackTrace();
}
}
}
}
}
?
?
5、编写接收方程序
package jmsdemo.client;