/**
     * 遞歸讀取流
     *
     * @param output
     * @param inStream
     * @return
     * @throws Exception
     */
    public void readStreamWithRecursion(ByteArrayOutputStream output, InputStream inStream) throws Exception {
        long start = System.currentTimeMillis();
        while (inStream.available() == 0) {
            if ((System.currentTimeMillis() - start) > 20* 1000) {//超時(shí)退出
                throw new SocketTimeoutException("超時(shí)讀取");
            }
        }
        byte[] buffer = new byte[2048];
        int read = inStream.read(buffer);
        output.write(buffer, 0, read);
        SystemClock.sleep(100);//需要延時(shí)以下，不然還是有概率漏讀
        int a = inStream.available();//再判斷一下，是否有可用字節(jié)數(shù)或者根據(jù)實(shí)際情況驗(yàn)證報(bào)文完整性
        if (a > 0) {
            LogUtils.w("========還有剩余：" + a + "個(gè)字節(jié)數(shù)據(jù)沒讀");
            readStreamWithRecursion(output, inStream);
        }
    }
    /**
     * 讀取字節(jié)
     *
     * @param inStream
     * @return
     * @throws Exception
     */
    private byte[] readStream(InputStream inStream) throws Exception {
        ByteArrayOutputStream output = new ByteArrayOutputStream();
        readStreamWithRecursion(output, inStream);
        output.close();
        int size = output.size();
        LogUtils.i("本次讀取字節(jié)總數(shù)：" + size);
        return output.toByteArray();
    }

 /**
     * 遞歸讀取流
     *
     * @param output
     * @param inStream
     * @return
     * @throws Exception
     */
    public void readStreamWithRecursion(ByteArrayOutputStream output, InputStream inStream) throws Exception {
        long start = System.currentTimeMillis();
        int time =500;//毫秒，間看實(shí)際情況
        while (inStream.available() == 0) {
            if ((System.currentTimeMillis() - start) >time) {//超時(shí)退出
                throw new SocketTimeoutException("超時(shí)讀取");
            }
        }
        byte[] buffer = new byte[2048];
        int read = inStream.read(buffer);
        output.write(buffer, 0, read);
       int wait = readWait();
        long startWait = System.currentTimeMillis();
        boolean checkExist = false;
        while (System.currentTimeMillis() - startWait <= wait) {
            int a = inStream.available();
            if (a > 0) {
                checkExist = true;
                //            LogUtils.w("========還有剩余：" + a + "個(gè)字節(jié)數(shù)據(jù)沒讀");
                break;
            }
        }
        if (checkExist) {
            if (!checkMessage(buffer, read)) {
                readStreamWithRecursion(output, inStream, timeout);
            }
        }        
    }
    
 /**
     * 讀取等待時(shí)間，單位毫秒
     */
    protected int readWait() {
        return 100;
    }
    
    /**
     * 讀取字節(jié)
     *
     * @param inStream
     * @return
     * @throws Exception
     */
    private byte[] readStream(InputStream inStream) throws Exception {
        ByteArrayOutputStream output = new ByteArrayOutputStream();
        readStreamWithRecursion(output, inStream);
        output.close();
        int size = output.size();
        LogUtils.i("本次讀取字節(jié)總數(shù)：" + size);
        return output.toByteArray();
    }

 mPrintWriter.print(sendData+ "\r\n");   
 mPrintWriter.flush();
 String msg = mBufferedReader.readLine();
 //處理數(shù)據(jù)