java socket接收保證能讀完數(shù)據(jù)的實(shí)例

更新時(shí)間：2021年10月27日 12:01:59 作者：傲嬌萌萌噠

這篇文章主要介紹了java socket接收保證能讀完數(shù)據(jù)的實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

socket接收保證能讀完數(shù)據(jù)

//    private static byte[] readData(InputStream in,byte[] bData) throws IOException{
//      int readLength = in.read(bData);
//      if(readLength!=bData.length){
//          byte[] temp2 = readData(in,new byte[bData.length-readLength]);
//          System.arraycopy(temp2, 0, bData, readLength, temp2.length);
//          return bData;
//      }else{
//          return bData;
//      }
//    }
//    private static void readData(InputStream in,byte[] bData) throws IOException{
//      readData(in,bData,0,bData.length);
//    }
//    private static void readData(InputStream in,byte[] bData,int off,int length) throws IOException{
//      int readLength = in.read(bData, off, length);
//      if(readLength!=length){
//          readData(in,bData,readLength+off,length-readLength);
//      }
//    }
//    private static void readData(InputStream in,byte[] bData,int off,int length) throws IOException{
//
//      while(true){
//          int readLength = in.read(bData, off, length);
//          if(readLength!=length){
//              off = readLength+off;
//              length = length-readLength;
//          }else{
//              break;
//          }
//      }
//    }
//    private static void readData(InputStream in,byte[] bData,int off,int length) throws IOException{
//      int readLength = 0;
//      do{
//          off = readLength+off;
//          length = length-readLength;
//          readLength = in.read(bData, off, length);
//      }while(readLength!=length);
//    }
    /**
     * 最終使用此方法
     * @param in  輸入流
         * @param bData  讀取數(shù)據(jù)
     * @throws IOException  
     */
    private static void readData(InputStream in,byte[] bData) throws IOException{
        int off = 0;
        int length = bData.length;
        int readLength = 0;
        do{
            off = readLength+off;
            length = length-readLength;
            readLength = in.read(bData, off, length);
        }while(readLength!=length);
    }

socket接收硬件字節(jié)數(shù)據(jù)并解析

第一次接觸這種類(lèi)型的項(xiàng)目，在處理數(shù)據(jù)過(guò)程中，發(fā)現(xiàn)了許多問(wèn)題，記錄一下，加深記憶。

硬件將數(shù)據(jù)寫(xiě)在一個(gè)buffer中，傳輸過(guò)來(lái)的是字節(jié)。

一開(kāi)始我們想到的是按照字節(jié)流來(lái)接收，但是，C語(yǔ)言中，byte類(lèi)型沒(méi)有符號(hào)位，最大值位255，java中byte類(lèi)型帶有符號(hào)位，最大值為127，問(wèn)題就出現(xiàn)了，當(dāng)接收到的字節(jié)數(shù)據(jù)超過(guò)127時(shí)，會(huì)取第一位為符號(hào)位，后幾位補(bǔ)碼，取反再加一變成負(fù)數(shù)。（處理方法后面有寫(xiě)到）

后來(lái)想偷懶不處理數(shù)據(jù)的基礎(chǔ)上，考慮用char數(shù)組接收。char一共十六位，絕對(duì)是可以接收下硬件發(fā)來(lái)的八位數(shù)據(jù)的。但是再接收數(shù)據(jù)的時(shí)候，還是出現(xiàn)了問(wèn)題。在對(duì)字節(jié)流轉(zhuǎn)變?yōu)樽址鞑⒈４娴絚har數(shù)組中的時(shí)候，char類(lèi)型會(huì)自動(dòng)對(duì)數(shù)據(jù)進(jìn)行處理。在char類(lèi)型中，字符所對(duì)應(yīng)的最大十六進(jìn)制是7F，但硬件傳輸來(lái)的數(shù)據(jù)存在如0X80,0X8D的情況。當(dāng)char類(lèi)型接收到大于7F的數(shù)據(jù)時(shí)，無(wú)法處理，字符會(huì)變成亂碼的格式，數(shù)據(jù)相對(duì)應(yīng)的也會(huì)發(fā)生改變。在接收數(shù)據(jù)的時(shí)候就無(wú)法正確存儲(chǔ)，更別提后期對(duì)數(shù)據(jù)進(jìn)行正確處理和校驗(yàn)了。放棄。

最終還是要回到byte接收的方向上。和同事討論了下，對(duì)于超過(guò)java byte類(lèi)型的數(shù)據(jù)，進(jìn)行相應(yīng)處理后，存放在Int中，即可保證數(shù)據(jù)正確性。

處理方法：

對(duì)byte數(shù)組中的數(shù)據(jù)進(jìn)行判斷，當(dāng)為負(fù)數(shù)時(shí)，與0xff相與，并存放在Int數(shù)組中，可以保證數(shù)據(jù)正常

ServerSocket serverSocket;
    try {
 serverSocket = new ServerSocket(9090);
 System.out.println("***等待客戶(hù)端連接***");
 Socket socket = serverSocket.accept();
 InputStream is = socket.getInputStream();
   
 byte[] datas = new byte[500];
 int count = is.read(datas);
   
 int[] dataFormat=new int[500];
 for(int i=0;i<datas.length;i++){
  if(datas[i]<0){
   dataFormat[i]=datas[i]&0xff;
  }else{
   dataFormat[i]=datas[i];
  }
 }
     } catch (IOException e) {
 e.printStackTrace();
     }

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: