loginaction.java~2~

100多M的J2EE培训内容

package com.cwj.userjmssesenbdb;

import org.apache.struts.action.*;
import javax.servlet.http.*;
import java.util.*;
import javax.naming.*;
import javax.jms.*;
import javax.rmi.*;

public class LoginAction
    extends Action {
//  public ActionForward perform(ActionMapping actionMapping, ActionForm actionForm, HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse) {
//    /**@todo: complete the business logic here, this is just a skeleton.*/
//    LoginActionForm loginActionForm = (LoginActionForm) actionForm;
//    throw new java.lang.UnsupportedOperationException("Method perform() not yet implemented.");
//  }

  public final static String
      JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";
  public final static String URL = "t3://192.168.0.100:7001";
  private static final String QUEUE_CONNECTION_FACTORY =
      "DemoJMSConnectionFactory";
  private static final String QUEUE = "DemoJMSQueue";
  private static SessHome sessHome = null;

  private static InitialContext getInitialContext(String url) throws
      NamingException {
    Hashtable env = new Hashtable();
    env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
    env.put(Context.PROVIDER_URL, url);
    return new InitialContext(env);
  }

  public static void inputpar(String Shancbz, String Xiwbz) throws Exception {
    Context ctx = getInitialContext(URL);
    QueueConnectionFactory qConnFact = (QueueConnectionFactory) ctx.lookup(
        QUEUE_CONNECTION_FACTORY);
    QueueConnection qConn = qConnFact.createQueueConnection();
    QueueSession qSess = qConn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    Queue q = (Queue) ctx.lookup(QUEUE);
    QueueSender qSend = qSess.createSender(q);
    try {
      TextMessage txtMsg = qSess.createTextMessage(Shancbz);
      System.out.println("Sending a message to queue");
      qSend.send(txtMsg);
    }
    catch (Exception ex) {
      ex.printStackTrace();
      System.out.println("Error!!!!!!!!!");
    }
//---------------------------------------------------------//
    qConn.close();
  }

  public static void inputparSess(String Shancbz, String Xiwbz) throws
      Exception {
    Context context = getInitialContext(URL);
    /*
       Hashtable env = new Hashtable();
       Context context = new InitialContext(env);
     */
    Object ref = context.lookup("SessBean");
    sessHome = (SessHome) PortableRemoteObject.narrow(ref, SessHome.class);
    sessHome.create().insTableAa11(Shancbz, Xiwbz);
  }

  public ActionForward perform(ActionMapping actionMapping,
                               ActionForm actionForm,
                               HttpServletRequest httpServletRequest,
                               HttpServletResponse httpServletResponse) {
    LoginActionForm form = (LoginActionForm) actionForm;
    if ( (form.getShancbz_new().toString().equals(form.getXiwbz_new().toString().
                                                  trim()))) {
      HttpSession session = httpServletRequest.getSession();
      session.setAttribute("Shancbz", form.getShancbz_new());
      //---------------------------------------------------------------------//
      /* try {
         inputpar(form.getShancbz_new().toString().trim(),
         form.getXiwbz_new().toString().trim());
         return (actionMapping.findForward("success"));
         }
         catch (Exception ex) {
         System.out.println("insert error!");
         return (actionMapping.findForward("inputError"));
         }
           //JMS
       */
      try {
        inputparSess(form.getShancbz_new().toString().trim(),
                     form.getXiwbz_new().toString().trim());
      }
      catch (Exception ex) {
        System.out.println("insert error!");
        return (actionMapping.findForward("inputError"));
      }
      return (actionMapping.findForward("success"));
      //Session
      //---------------------------------------------------------------------//
    }
    ActionErrors errors = new ActionErrors();
    if (!form.getShancbz_new().equals("a")) {
      errors.add(ActionErrors.GLOBAL_ERROR,
                 new ActionError("error.Shancbz.wrong"));
    }
    if (!form.getXiwbz_new().equals("1")) {
      errors.add(ActionErrors.GLOBAL_ERROR,
                 new ActionError("error.Xiwbz.wrong"));
    }
    saveErrors(httpServletRequest, errors);
    return (actionMapping.findForward("inputError"));
  }
}