1.在WEBLOGIC12中配置JMS服务器
参考链接:http://blog.csdn.net/gxlstone/article/details/41378949
2.创建java project编写测试代码
(1) 创建一个java project（不是web项目）
(2) 将weblogic安装目录中的wlclient.jar加入classpath中（注意：weblogic老版本的话使用weblogic.jar）, 具体路径：$Weblogic_HOME\wlserver_10.3\server\lib。
(3) 需要将javaee.jar加入到classpath，因为我们建的是java project项目，不会自动添加javaee包。注意：从官网下载javaee sdk，安装后lib中有这个包。
package com.jms;import java.util.Hashtable; ?import javax.jms.JMSException; ?import javax.jms.Message; ?import javax.jms.Queue; ?import javax.jms.QueueConnection; ?import javax.jms.QueueConnectionFactory; ?import javax.jms.QueueSender; ?import javax.jms.QueueSession; ?import javax.jms.Session;import javax.jms.TextMessage;import javax.naming.Context; ?import javax.naming.InitialContext; ?import javax.naming.NamingException; ?//生产者 ?public class JMSSender { ?public static final String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";private static QueueConnectionFactory qconFactory;private static QueueConnection qcon;private static QueueSession qsession;private static QueueSender qsender;private static Queue queue;private static TextMessage msg;public static void init() throws NamingException, JMSException { ??//init JNDI context ?????????String JNDIFactory = "weblogic.jndi.WLInitialContextFactory";//define JNDI context factory ?????????String providerUrl = "t3://localhost:7001"; //define weblogic JMS url ?????????Hashtable env = new Hashtable(); ?????????env.put(Context.INITIAL_CONTEXT_FACTORY, JNDIFactory); ?????????env.put(Context.PROVIDER_URL, providerUrl); ?????????Context ctx = new InitialContext(env); ?????????String queueName = "SevenQueue";//生成者队列 ???????String connFactoryJNDI = "myJMSConnectionFactory";//工厂//获取一个JMS连接工厂是为了获取与服务器的连接。前题是这个JMS工厂一定要事先创建好，注:查询的是连接工厂的JNDI的名字，不是连接工厂的名字。qconFactory = ((QueueConnectionFactory) ctx.lookup(connFactoryJNDI));// ?创建一个列队或主题连接是为了获取与JMS会话的Session qcon = qconFactory.createQueueConnection();// 创建会话Session 是为了创建一个消息的发送者和发送内容类型。qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);//创建一个列队来存储消息，是消息的存方的物理地址，前题是这个队列需要在weblogic里创建后。queue = ((Queue) ctx.lookup(queueName));///创建一个消息的发送者qsender = qsession.createSender(queue);//创建一个发送内容类型(Stream,byte,map,text,object)。msg = qsession.createTextMessage();//一个字符串对象//打开连接，设置发送文本内容。qcon.start();ctx = null;}public static void send(String message) throws JMSException {msg.setText(message);//设置发送内容qsender.send(msg);}public static void close() throws JMSException {if (qsender != null) {qsender.close();}if (qsession != null) {qsession.close();}if (qcon != null)qcon.close();} ???/** ?????* @param args ?????* @throws NamingException ??????* @throws JMSException ??????*/ ?????public static void main(String[] args) throws NamingException, JMSException { ????????init(); ??????send("haha"); ??????close(); ???} ???} ?
package com.jms;import java.util.Hashtable;import java.util.Map;import javax.jms.BytesMessage; ?import javax.jms.JMSException; ?import javax.jms.MapMessage; ?import javax.jms.Message; ?import javax.jms.MessageListener; ?import javax.jms.ObjectMessage; ?import javax.jms.Queue; ?import javax.jms.QueueConnection; ?import javax.jms.QueueConnectionFactory; ?import javax.jms.QueueReceiver; ?import javax.jms.QueueSession; ?import javax.jms.Session; ?import javax.jms.StreamMessage; ?import javax.jms.TextMessage; ?import javax.naming.Context; ?import javax.naming.InitialContext; ?import javax.naming.NamingException;import org.dom4j.Element;import com.utils.BASE64;import com.utils.XmlHelper; ???//消费者 ?public class JMSReceiver { ?????public static void main(String[] args) throws NamingException, JMSException { ????????????//init JNDI context ?????????String JNDIFactory = "weblogic.jndi.WLInitialContextFactory";//define JNDI context factory ?????????String providerUrl = "t3://localhost:7001"; //define weblogic JMS url ?????????Hashtable env = new Hashtable(); ?????????env.put(Context.INITIAL_CONTEXT_FACTORY, JNDIFactory); ?????????env.put(Context.PROVIDER_URL, providerUrl); ?????????Context ctx = new InitialContext(env); ???????????????????//find connection factory ?????????String connFactoryJNDI = "myJMSConnectionFactory"; //jms connectionFactory JNDI name ?????????QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup(connFactoryJNDI); ?????????//create queue connection ?????????QueueConnection qConn = (QueueConnection) connFactory.createConnection(); ?????????//create session ?????????QueueSession qSession = qConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); ?????????//find queue by JNDI lookup ?????????Queue queue = (Queue) ctx.lookup("SevenQueue"); ???????????????????//create receiver ?????????QueueReceiver qReceiver = qSession.createReceiver(queue); ?????????//create message listener ?????????qReceiver.setMessageListener(new MessageListener() { ???????????????public void onMessage(Message msg) { ?????????????????????????????String msgText = ""; ?????????????????double d = 0; ??????????????????try { ?????????????????????if (msg instanceof TextMessage) { ????????????????????????????????msgText = ((TextMessage) msg).getText(); ?????????????????????????} else if (msg instanceof StreamMessage) { ????????????????????????????????msgText = ((StreamMessage) msg).readString(); ????????????????????????????????d = ((StreamMessage) msg).readDouble(); ????????????????????????????} else if (msg instanceof BytesMessage) { ????????????????????????????????byte[] block = new byte[1024]; ????????????????????????????????((BytesMessage) msg).readBytes(block); ????????????????????????????????msgText = String.valueOf(block); ????????????????????????????} else if (msg instanceof MapMessage) { ????????????????????????????????msgText = ((MapMessage) msg).getString("name"); ????????????????????????????} ??????????????????????????????????} catch (JMSException e) { ?????????????????????// TODO Auto-generated catch block ?????????????????????e.printStackTrace(); ?????????????????} ?????????????????????????????????????System.out.println(msgText + " " + d); ?????????????}}); ???????????qConn.start(); ???????????????} ???????} ?
weblogic 与jms事例配置
原文地址：http://www.cnblogs.com/tytr/p/8023685.html