/**    * 讀取終端設備數據    * @author Administrator    */   private class ReadThread extends Thread {      @Override     public void run() {       super.run();        // 定義一個包的最大長度       int maxLength = 2048;       byte[] buffer = new byte[maxLength];       // 每次收到實際長度       int available = 0;       // 當前已經收到包的總長度       int currentLength = 0;       // 協議頭長度4個字節（開始符1，類型1，長度2）       int headerLength = 4;        while (!isInterrupted()) {         try {           available = mInputStream.available();           if (available > 0) {             // 防止超出數組最大長度導致溢出             if (available > maxLength - currentLength) {               available = maxLength - currentLength;             }             mInputStream.read(buffer, currentLength, available);             currentLength += available;           }                    }         catch (Exception e) {           e.printStackTrace();         }          int cursor = 0;         // 如果當前收到包大于頭的長度，則解析當前包         while (currentLength >= headerLength) {           // 取到頭部第一個字節           if (buffer[cursor] != 0x0F) {             --currentLength;             ++cursor;             continue;           }                      int contentLenght = parseLen(buffer, cursor, headerLength);           // 如果內容包的長度大于最大內容長度或者小于等于0，則說明這個包有問題，丟棄           if (contentLenght <= 0 || contentLenght > maxLength - 5) {             currentLength = 0;             break;           }           // 如果當前獲取到長度小于整個包的長度，則跳出循環等待繼續接收數據           int factPackLen = contentLenght + 5;           if (currentLength < contentLenght + 5) {             break;           }            // 一個完整包即產生           // proceOnePacket(buffer,i,factPackLen);           onDataReceived(buffer, cursor, factPackLen);           currentLength -= factPackLen;           cursor += factPackLen;          }         // 殘留字節移到緩沖區首         if (currentLength > 0 && cursor > 0) {           System.arraycopy(buffer, cursor, buffer, 0, currentLength);         }       }     }   }    /**    * 獲取協議內容長度    * @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);    }