qmconsumer.java

网络购物系统开发详细步骤

package jms.client;

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

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import java.util.Properties;


public class QMConsumer {
  public static void main(String[] args) {
    Properties jndiEnv = new Properties();
    jndiEnv.setProperty(Context.INITIAL_CONTEXT_FACTORY,
                        "weblogic.jndi.WLInitialContextFactory");
    jndiEnv.setProperty(Context.PROVIDER_URL, "t3://localhost:7001");
    QueueConnection con = null;
    QueueSession session = null;
    QueueReceiver receiver = null;
    try {
      Context ctx = new InitialContext(jndiEnv);
      QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup(
          "jms/QueueConnectionFactory");
      con = factory.createQueueConnection();
      con.start();
      session = con.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
      Queue q = (Queue) ctx.lookup("jms/fileQueue");
      receiver = session.createReceiver(q);
      TextMessage msg=(TextMessage)receiver.receive();
      System.out.println(msg.getText());
    }
    catch (NamingException ne) {
      ne.printStackTrace();
    }
    catch (JMSException je) {
      je.printStackTrace();
    }
    finally{
      if(receiver !=null)try{receiver.close();}catch(JMSException je){}
      if(session !=null)try{session.close();}catch(JMSException je){}
      if(con !=null)try{con.close();}catch(JMSException je){}

    }
  }
}