weblogic 与jms事例配置

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();  

    }  

}