JMS浅尝辄止

客户端

package jms.firstQueue;

import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class Consumer1_1 implements MessageListener {

	public void onMessage(Message arg0) {
		// TODO Auto-generated method stub
		try {
			System.out.println("接受到的消息为："+((TextMessage)arg0).getText());
		} catch (JMSException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	//客户端代码
	public static void main(String[] args){
		Consumer1_1 c = new Consumer1_1();
		String queueConnectionFactoryName = "MyJMSConnectionFactory";	//JMS 连接工厂的JNDI
		String queueName = "MyJMSQueue";	//JMS QUEUE 的 JNDI
		
		boolean transacted = false;	//transaction模式   false为自动提交
		int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;	//acknowledgement模式
		
		Properties properties = new Properties();	
		//一个映射文件  封装了weblogic的一个JDNI工厂的信息和 访问路径  t3为weblogic专有
		properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
		properties.put(Context.PROVIDER_URL, "t3://localhost:7001");
		
		try {
			Context context = new InitialContext(properties);
			ConnectionFactory cf = (ConnectionFactory) context.lookup(queueConnectionFactoryName);
			Connection conn = cf.createConnection();
			conn.start();
			Session session = conn.createSession(transacted, acknowledgementMode);
			/////
			MessageConsumer mc = session.createConsumer((Queue)context.lookup(queueName));
			mc.setMessageListener(c);
			
			 //同步
	        synchronized(c){
	        //PS:这里不等待一下的话，执行过快，看不到效果，不是必须等待
	        //wait方法为等待多少毫秒后执行  
	          c.wait(1000);   
	        }  
			
			if(mc!=null)mc.close();
			if(session!=null)session.close();
			if(conn!=null)conn.close();
			
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

消息发送端

package jms.firstQueue;

import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class Product1_1 {

	//消息发送端
	public static void main(String[] args){
		String queueConnectionFactoryName = "MyJMSConnectionFactory";	//JMS 连接工厂的JNDI
		String queueName = "MyJMSQueue";	//JMS QUEUE 的 JNDI
		
		boolean transacted = false;	//transaction模式   false为自动提交
		int acknowledgementMode = Session.AUTO_ACKNOWLEDGE;	//acknowledgement模式
		String message = "哈哈哈哈哈222";	//模拟的发送消息
		
		Properties properties = new Properties();	
		//一个映射文件  封装了weblogic的一个JDNI工厂的信息和 访问路径  t3为weblogic专有
		properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
		properties.put(Context.PROVIDER_URL, "t3://localhost:7001");
		
		try {
			Context context = new InitialContext(properties);
			ConnectionFactory cf = (ConnectionFactory) context.lookup(queueConnectionFactoryName);
			Connection conn = cf.createConnection();
			conn.start();
			Session session = conn.createSession(transacted, acknowledgementMode);
			/////
			TextMessage tm = session.createTextMessage();
			tm.setText(message);
			MessageProducer mp =  session.createProducer((Queue) context.lookup(queueName));
			mp.send(tm);
			if(transacted) session.commit();
			
			if(mp != null)mp.close();
			if(session != null)session.close();
			if(conn != null)conn.close();

		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

JMS的Jar包以及weblogic支持库