readrecievequeue.java~79~

用java写编写的一个GPS源代码请大家多多指教

package com.gps.center.dataservice;

import java.io.File;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.DocumentBuilder;
import org.w3c.dom.Document;
import org.w3c.dom.NodeList;
import java.util.regex.Pattern;
import java.util.regex.Matcher;
import com.gps.center.baseclass.ParseData;
import com.gps.center.baseclass.MsgObj;
import com.gps.center.baseclass.HashObj;
import com.gps.center.baseclass.ParseInterface;
import javax.swing.JOptionPane;

public class ReadRecieveQueue
    extends ParseData
    implements Runnable, ParseInterface {
  private String[][] expression;

  public ReadRecieveQueue() {
    readxml();
    readDeviceType();
    loadDeviceClass();
  }

  /**
   * run
   */
  public void run() {
    Pattern regex;
    Matcher matcher;
    ParseInterface parseobj;
//    ParseInterface makeStrObj;
    boolean findStartword = false;
    boolean findCommandword = false;
    boolean findEndword = false;int m = 0;
    for(int n =0;n<100;n++){

        m++;
        //JOptionPane.showMessageDialog(null,String.valueOf(m));
      while (super.recieveQueue.isEmpty()) {
        try {

          Thread.sleep(500);
          //JOptionPane.showMessageDialog(null,"线程睡眠");
        }
        catch (InterruptedException e) {
          System.out.println(e);
        }
      }
      if (!super.recieveQueue.isEmpty()) {
//        MsgObj msg = new MsgObj();
        MsgObj msg = getRecieveMsg();
        if(msg.cSelectionKey==null){System.out.println("msg.cSelectionKey为空ReadRecieveQueue");}
                else{System.out.println("msg.cSelectionKey不为空ReadRecieveQueue");}
        System.out.println("ReadRecieveQueue  Receive " + msg.cMsgType + ":" + msg.cMsg);
        for (int i = 0; i < expression.length; i++) {
          findStartword = false;
          findCommandword = false;
          findEndword = false;
          for (int j = 1; j <= 3; j++) {
            regex = Pattern.compile(expression[i][j]);
            matcher = regex.matcher(msg.cMsg);
            //cMsgtype:1--TCPMSG,2--DEVICEUDPMSG,3--SMSMSG
            //4--TCPSENDTODEVICE,5--UDPSENDTODEVICE,6--SMSSENDTODEVICE,7--TCPSENDTOTERMINAL,8--TCPRETURNTERMINAL
            switch (j) {
              case 1:
                findStartword = matcher.find();
                break;
              case 2:
                findCommandword = matcher.find();
                break;
              case 3:
                findEndword = matcher.find();
                break;
            }
          }
          if (findStartword & findCommandword & findEndword) {
              if (!super.classMap.containsKey(expression[i][0])) {
                  System.out.println("LoadClass ：" + expression[i][0] +
                                     "ReadRecieveQueue");
                  parseobj = loadClass(expression[i][0]);
                  super.classMap.put((expression[i][0]), parseobj);
                  parseobj.ParseMsg(msg);
              } else {
                  System.out.println("Use Class Parse Msg：" + expression[i][0]+"ReadRecieveQueue");
                  parseobj = (ParseInterface)super.classMap.get(expression[i][0]);
                  parseobj.ParseMsg(msg);
                  System.out.println("Use Class Parse Msg：" + expression[i][0]+"ReadRecieveQueue");
              }
              break;
          }
        }
      }
    }//
 System.out.println("线程跳出");
}

  protected static ParseInterface loadClass(String classname) {
    ParseInterface s = null;
    try {
      Class parseClass = Class.forName("com.gps.center.parsedata." +
                                       classname.trim());
      s = (ParseInterface) parseClass.newInstance();
    }
    catch (Exception e) {
      System.out.println("erro for Class.forName(servicename)" + classname);
//      System.out.println("Service s=" + s.toString());
//      System.out.println(e.getMessage());
    }
    return s;
  }


  private void readxml() {
//    String strclassname, strexpression;
    try {
      //"E:\\nk\\JBuilderWorkspace\\GPSCenter\\Expression.xml"
      File f = new File("ExpressionInfo.xml");
      if (f.exists()) {
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        DocumentBuilder builder = factory.newDocumentBuilder();
        Document doc = builder.parse(f);
        NodeList nl = doc.getElementsByTagName("Center");
//        System.out.println("nl.getLength():" + nl.getLength());
        expression = new String[nl.getLength()][4];
        for (int i = 0; i < nl.getLength(); i++) {
          expression[i][0] = new String( (doc.getElementsByTagName("ClassName").
                                          item(i).
                                          getFirstChild().getNodeValue()).trim());
          expression[i][1] = new String( (doc.getElementsByTagName("Startword").
                                          item(i).
                                          getFirstChild().
                                          getNodeValue()).trim());
          expression[i][2] = new String( (doc.getElementsByTagName(
              "Commandword").item(i).getFirstChild().getNodeValue()).trim());
          expression[i][3] = new String( (doc.getElementsByTagName("Endword").
                                          item(i).
                                          getFirstChild().
                                          getNodeValue()).trim());
        }
      }
      else {
        System.out.println("no find file：ExpressionInfo.xml");
        System.exit( -1);
      }

    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  private void readDeviceType() {
    try {
      //"E:\\nk\\JBuilderWorkspace\\GPSCenter\\Expression.xml"
      File f = new File("VehicleTable.xml");
      if (f.exists()) {
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        DocumentBuilder builder = factory.newDocumentBuilder();
        Document doc = builder.parse(f);
        NodeList nl = doc.getElementsByTagName("Center");
//        System.out.println("nl.getLength():" + nl.getLength());
        super.DeviceIdType = new String[nl.getLength()][2];
        for (int i = 0; i < nl.getLength(); i++) {
          DeviceIdType[i][0] = new String( (doc.getElementsByTagName("DeviceID").
                                            item(i).
                                            getFirstChild().getNodeValue()).
                                          trim());
          DeviceIdType[i][1] = new String( (doc.getElementsByTagName(
              "DeviceType").item(i).getFirstChild().getNodeValue()).trim());
        }
      }
      else {
        System.out.println("no find file：ExpressionInfo.xml");
        System.exit( -1);
      }
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  private void loadDeviceClass() {
    ParseInterface parseobj;
    String[] DeviceType = {"HC2000"};
    //for (int i = 0; i < DeviceIdType.length; i++) {
      if (!super.classMap.containsKey(DeviceIdType[0])) {
        parseobj = loadClass(DeviceType[0]);
//        System.out.println("loadClass :" + DeviceType[i]);
        super.classMap.put( (DeviceType[0]), parseobj);
      //}
    }
  }

  /**
   * ParseMsg
   *
   * @param msg MsgObj
   */
  public void ParseMsg(MsgObj msg) {
  }

}