guimsg.java

通讯采集软件

              }
            }
            System.out.println(
                "***************    收到 参数检测 －－－－－ 要terminal_server");
            break;
          }
          case 5: {
            HashMap m_HashMap = (HashMap) object;
            if (m_HashMap != null) {
              Object[] objs = m_HashMap.values().toArray();
              if (objs.length > 0) {
                if (objs[0] instanceof protocol) {
                  Set key_set = m_HashMap.keySet();
                  Object[] keyArray = key_set.toArray();
                  if (keyArray.length > 0) {
                    for (int i = 0; i < keyArray.length; i++) {
                      Object key = keyArray[i];
                      protocol m_protocol = (protocol) (m_HashMap.get(key));
                      if (m_protocol != null) {
                        CollectorDefine.m_HashProtocol.put(key, m_protocol);
                      }
                    }
                  }
                  keyArray = null;
                  key_set = null;
                }
              }
            }
            System.out.println("***************    收到 参数检测 －－－－－ 要protocol");
            break;
          }
          case 6: { //jmsobject----fac_id

            ArrayList m_list = (ArrayList) object;
            if (m_list != null) {
              if (m_list.size() > 0) {
                for (int i = 0; i < m_list.size(); i++) {
                  Object m_obj = m_list.get(i);
                  if (m_obj instanceof terminal) {
                    terminal m_terminal = (terminal) m_obj;
                    CollectorDefine.m_HashTerminal.put(new Long(m_terminal.
                        getTerminalId()), m_terminal);
                    //System.out.println("@@@@@@@@@@@@@@@@@@  terminal_name = "+m_terminal.getTerminalName());
                  }
                }
              }
            }
            break;
          }
        }
      }

      else if (report_type == CollectorDefine.QUIT_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.RESET_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.LOGOUT_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.ALIVE_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.WRITE_CHREPORT_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.WRITE_REPORT_JMS_TYPE) {

      }
      else if (report_type == CollectorDefine.WRITE_EXPLAIN_JMS_TYPE) {

      }
      //wj add
      /*
           else if (report_type == CollectorDefine.CHANNEL_TASK_ASSIGN_JMS_TYPE) {
          if (CollectorDefine.CHANNEL_TASK_ASSIGN_FLAG == false) {
              return -1;
          }
          HashMap m_HashMap = (HashMap) object;
          Set key_set = m_HashMap.keySet();
          Object[] keyArray = key_set.toArray();
          if (keyArray.length > 0) {
              for (int i = 0; i < keyArray.length; i++) {
                  Object key = keyArray[i];
                  computer m_computer = (computer) (m_HashMap.get(key));
                  if (m_computer != null) {
                      CollectorDefine.m_HashComputer.put(key, m_computer);
                  }
              }
          }
          keyArray = null;
          key_set = null;
          m_HashMap = null;
          if (FrontGuiDefine.m_FrontFrame != null) {
              if (this.InitFinished == true) {
                  FrontGuiDefine.m_FrontFrame.initComputersPanel(true);
              }
          }
          if (FrontGuiDefine.m_TaskAssignFrame != null) {
              FrontGuiDefine.m_TaskAssignFrame.initComputers();
              FrontGuiDefine.m_TaskAssignFrame.initLocalList();
          }
                   }
       */
      else if (report_type == CollectorDefine.CHANNEL_TASK_ASSIGN_JMS_TYPE) {
        if (CollectorDefine.CHANNEL_TASK_ASSIGN_FLAG == false) {
          CFunction.writeLog("guirec", "Error in guimsg error #1", null);
          return -1;
        }
        CFunction.writeLog("guirec",
                           "收到CollectorDefine.CHANNEL_TASK_ASSIGN_JMS_TYPE", null);
        computer m_computer = (computer) object;
        if (m_computer != null) {
          CFunction.writeLog("guirec",
                             "computer name :" +m_computer.getComputerName()  , null);
          if (m_computer.getLinkedList() != null)
          {
            CFunction.writeLog("guirec",
                               "computer name :" +m_computer.getComputerName()+
                               "size:"+ m_computer.getLinkedList().size()  , null);
          }

          CollectorDefine.m_HashComputer.put(new Long(m_computer.getComputerId()),
                                             m_computer);
        }
        if (FrontGuiDefine.m_FrontFrame != null) {
          if (this.InitFinished == true) {
            if (CollectorDefine.LOGIN_FLAG == false) {
              CFunction.writeLog("guirec", "initComputersPanel", null);
              FrontGuiDefine.m_FrontFrame.initComputersPanel(true);
            }
            else {
              CFunction.writeLog("guirec",
                                 "CollectorDefine.LOGIN_FLAG != false ", null);
            }
          }
          else {
            CFunction.writeLog("guirec", "this.InitFinished != true ", null);
          }
        }
        else {
          CFunction.writeLog("guirec", "Error in guimsg error #2", null);

        }
        if (FrontGuiDefine.m_TaskAssignFrame != null) {
          CFunction.writeLog("guirec", "initComputers", null);
          FrontGuiDefine.m_TaskAssignFrame.initComputers();
          CFunction.writeLog("guirec", "initLocalList", null);
          FrontGuiDefine.m_TaskAssignFrame.initLocalList();
        }
        else {
          CFunction.writeLog("guirec",
                             "FrontGuiDefine.m_TaskAssignFrame == null", null);

        }
      }

      //
      else if (report_type == CollectorDefine.TERMINAL_JMS_TYPE) {
        if (CollectorDefine.TERMINAL_FLAG == false) {
          return -1;
        }
        terminal m_terminal = (terminal) object;
        CollectorDefine.m_HashTerminal.put(new Long(terminalid), m_terminal);
        if (terminalid == PublicMethod.LastTerminalId) {
        }
      }
      else {
        CFunction.writeLog("guirec", "run in TransGui Error #4 ", null);
      }
    }
    catch (Exception e) {
      CFunction.writeLog("guirec", "run in TransGui Error #5 ", null);
      e.printStackTrace();
    }
    return 1;
  }

  public int initProcess() {
    initJms(CollectorDefine.APPSERVER_TYPE,
            CollectorDefine.JMS_INITIAL_CONTEXT_FACTORY,
            CollectorDefine.JMS_URL1, CollectorDefine.JMS_PORT1,
            CollectorDefine.JMS_URL2, CollectorDefine.JMS_PORT2,
            CollectorDefine.GUI_TOPICFACTORY, CollectorDefine.GUI_TOPIC);
// wj add
    initJms_1(CollectorDefine.APPSERVER_TYPE,
              CollectorDefine.JMS_INITIAL_CONTEXT_FACTORY,
              CollectorDefine.JMS_URL1, CollectorDefine.JMS_PORT1,
              CollectorDefine.JMS_URL2, CollectorDefine.JMS_PORT2,
              CollectorDefine.EVENT_TOPICFACTORY, CollectorDefine.EVENT_TOPIC);
//

    return 1;
  }

  public int initJms(String app_type,
                     String jms_init_context_factory,
                     String jms_url1, String jms_port1,
                     String jms_url2, String jms_port2,
                     String topicfactory, String tpoic) {
    this.m_jmsgui= new JmsSwitch(CollectorDefine.APPSERVER_CLUSTER);
    this.m_jmsgui.setJmsParam(app_type,
                              jms_init_context_factory,
                              jms_url1,
                              jms_port1,
                              jms_url2,
                              jms_port2);
    this.m_jmsgui.setJmsFrontParam(topicfactory,
                                   tpoic);
    this.m_jmsgui.setMachineSwitchWaitCounter(CollectorDefine.
                                              MACHINE_SWITCH_WAIT_COUNTER);
    if (this.m_jmsgui.initJmsSwitch() < 0) {
      CollectorDefine.SystemPrintln("initCollector In guimsg Error #1");
      return -1;
    }
    this.m_jmsgui.setGuiComputerFlag(true);
    return 1;
  }

  public int initJms_1(String app_type,
                       String jms_init_context_factory,
                       String jms_url1, String jms_port1,
                       String jms_url2, String jms_port2,
                       String topicfactory, String tpoic) {
    this.m_jmsswitch = new JmsSwitch(CollectorDefine.APPSERVER_CLUSTER);
    this.m_jmsswitch.setJmsParam(app_type,
                                 jms_init_context_factory,
                                 jms_url1,
                                 jms_port1,
                                 jms_url2,
                                 jms_port2);
    this.m_jmsswitch.setJmsFrontParam(topicfactory,
                                      tpoic);
    this.m_jmsswitch.setMachineSwitchWaitCounter(CollectorDefine.
                                                 MACHINE_SWITCH_WAIT_COUNTER);
    if (this.m_jmsswitch.initJmsSwitch() < 0) {
      System.out.println("&&&&&&&&&&&initCollector In guimsg Error #1");
      return -1;
    }
    this.m_jmsswitch.setGuiComputerFlag(true);
    return 1;
  }

  /*
       private void adjustAlive() {
      if (CollectorDefine.ALIVE_FLAG == true) {
          CollectorDefine.ALIVE_FLAG = false;
          this.m_LastAliveTime = System.currentTimeMillis() / 1000;
      }
      this.m_nowTime = System.currentTimeMillis() / 1000;
      if (java.lang.Math.abs(m_nowTime - m_LastAliveTime) >
      CollectorDefine.MAX_COUNER_FOR_GUI) {
          CollectorDefine.QUIT_FLAG = true;
      }
       }
   */

  private boolean runflag = true;
  public boolean getFlag() {
    return this.runflag;
  }

  public void setFlag(boolean m_flag) {
    this.runflag = m_flag;
  }

  public void run() {
    ServerSocket ser = null;
    int no;
    int m_isLocal = CollectorDefine.AUTO_MODE;
    int flag = 0;
    long FiveMinute = 5 * 60 * 1000; //五分钟发一次==5*60*1000
    long currenttime = -1l;

    try {
      System.out.println("haha: ");
      resetAllFlag();
      resetFlag1();
      clearmsg();
      CollectorDefine.QUIT_FLAG = false;
      CollectorDefine.GUI_QUIT_FLAG = false;

      while (true) {
        while (runflag) {
          try {
            recMsgFromGui();
            currenttime = System.currentTimeMillis();
            if (currenttime % FiveMinute == 0) {
              //sendAliveMsg();
            }
          }
          catch (Exception e) {
            e.printStackTrace();
          }
          try {
            Thread.sleep(1000);
          }
          catch (Exception ee) {
          }
        }
        try {
          Thread.sleep(1000);
        }
        catch (Exception ee) {
        }
      }
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  public static void main(String[] args) {
    guimsg m_guimsg = null;
    try {
      m_guimsg = new guimsg(); //创建新线程
      m_guimsg.start();
    }
    catch (Exception e) {
      CFunction.writeLog("guirec", "startTransGuiThread in Collector Error #1 ",
                         e);
    }
    try {
      Thread.sleep(2000);
    }
    catch (Exception e) {
    }

    for (int i = 0; i < 100; i++) {
      try {
        Thread.sleep(200);
      }
      catch (Exception e) {
      }
    }
  }

}