/** 
   * 讀取終端設(shè)備數(shù)據(jù) 
   * @author Administrator 
   */ 
  private class ReadThread extends Thread { 
 
    @Override 
    public void run() { 
      super.run(); 
 
      // 定義一個(gè)包的最大長(zhǎng)度 
      int maxLength = 2048; 
      byte[] buffer = new byte[maxLength]; 
      // 每次收到實(shí)際長(zhǎng)度 
      int available = 0; 
      // 當(dāng)前已經(jīng)收到包的總長(zhǎng)度 
      int currentLength = 0; 
      // 協(xié)議頭長(zhǎng)度4個(gè)字節(jié)（開始符1，類型1，長(zhǎng)度2） 
      int headerLength = 4; 
 
      while (!isInterrupted()) { 
        try { 
          available = mInputStream.available(); 
          if (available > 0) { 
            // 防止超出數(shù)組最大長(zhǎng)度導(dǎo)致溢出 
            if (available > maxLength - currentLength) { 
              available = maxLength - currentLength; 
            } 
            mInputStream.read(buffer, currentLength, available); 
            currentLength += available; 
          } 
           
        } 
        catch (Exception e) { 
          e.printStackTrace(); 
        } 
 
        int cursor = 0; 
        // 如果當(dāng)前收到包大于頭的長(zhǎng)度，則解析當(dāng)前包 
        while (currentLength >= headerLength) { 
          // 取到頭部第一個(gè)字節(jié) 
          if (buffer[cursor] != 0x0F) { 
            --currentLength; 
            ++cursor; 
            continue; 
          } 
           
          int contentLenght = parseLen(buffer, cursor, headerLength); 
          // 如果內(nèi)容包的長(zhǎng)度大于最大內(nèi)容長(zhǎng)度或者小于等于0，則說明這個(gè)包有問題，丟棄 
          if (contentLenght <= 0 || contentLenght > maxLength - 5) { 
            currentLength = 0; 
            break; 
          } 
          // 如果當(dāng)前獲取到長(zhǎng)度小于整個(gè)包的長(zhǎng)度，則跳出循環(huán)等待繼續(xù)接收數(shù)據(jù) 
          int factPackLen = contentLenght + 5; 
          if (currentLength < contentLenght + 5) { 
            break; 
          } 
 
          // 一個(gè)完整包即產(chǎn)生 
          // proceOnePacket(buffer,i,factPackLen); 
          onDataReceived(buffer, cursor, factPackLen); 
          currentLength -= factPackLen; 
          cursor += factPackLen;  
        } 
        // 殘留字節(jié)移到緩沖區(qū)首 
        if (currentLength > 0 && cursor > 0) { 
          System.arraycopy(buffer, cursor, buffer, 0, currentLength); 
        } 
      } 
    } 
  } 
 
  /** 
   * 獲取協(xié)議內(nèi)容長(zhǎng)度 
   * @param header 
   * @return 
   */ 
  public int parseLen(byte buffer[], int index, int headerLength) { 
 
//   if (buffer.length - index < headerLength) { return 0; } 
    byte a = buffer[index + 2]; 
    byte b = buffer[index + 3]; 
    int rlt = 0; 
    if (((a >> 7) & 0x1) == 0x1) { 
      rlt = (((a & 0x7f) << 8) | b); 
    } 
    else { 
      char[] tmp = new char[2]; 
      tmp[0] = (char) a; 
      tmp[1] = (char) b; 
      String s = new String(tmp, 0, 2); 
      rlt = Integer.parseInt(s, 16); 
    } 
 
    return rlt; 
  } 
 
protected void onDataReceived(final byte[] buffer, final int index, final int packlen) { 
    System.out.println("收到信息"); 
    byte[] buf = new byte[packlen]; 
    System.arraycopy(buffer, index, buf, 0, packlen); 
    ProtocolAnalyze.getInstance(myHandler).analyze(buf);  
  }