messageproducer.java

java的一系列产品中包括jsme,jmse,j2ee,本文件提供j2ee实现的源代码.

/*消息发送程序，发向消息队列*/
package queue;

import java.util.Properties;
import javax.rmi.PortableRemoteObject;
import javax.naming.InitialContext;
import javax.naming.Context;
import javax.naming.NamingException;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

public final class MessageProducer{

  private static QueueSender sender;
  private static TextMessage msg;
  
  private static final String url  = "t3://localhost:7001";
	
  public static void main(String [] argv) throws Exception
  {
    try {
      //设置初始上下文
      Properties env = new Properties();
      env.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
      env.put(Context.PROVIDER_URL, url);
      
      //获取初始上下文      
      Context ctx = new InitialContext(env);
      
      //1：通过JDNI查找ConnectionFactory
      QueueConnectionFactory qConFactory = (QueueConnectionFactory)
      		ctx.lookup("weblogic.jms.ConnectionFactory");
      
      //2：用ConnectionFactory建立JMS连接
    	QueueConnection qCon = qConFactory.createQueueConnection();
      
      //3：用Connection创建会话
    	QueueSession session = qCon.createQueueSession(
      	false, /* not a transacted session */
      	Session.AUTO_ACKNOWLEDGE 
    	);
    	
    	//4：通过JDNI查找目的（消息队列）
      Queue messageQueue = (Queue) ctx.lookup("MessageQueue");
      
      //5：创建消息发送者
    	sender = session.createSender(messageQueue);
    	
    	//6：创建文本消息，并发送
    	msg = session.createTextMessage();
    	//msg.setJMSDeliveryMode(2);
    	msg.setJMSType("String");
      //msg.setJMSPriority(5);
      
    	msg.setText("Hello");
    	msg.setStringProperty("MyProp","Prop String 1");
    	sender.send(msg);
    	
      msg.setText("Welcome to JMS");
    	msg.setStringProperty("MyProp","Prop String 2");
    	sender.send(msg);
    } catch (NamingException ne) {
      System.err.println("The JMS Server and the appropriate "+
        "JMS Destinations must be configured properly.");      
    }
  }
}