快捷導(dǎo)航

如何解決TCP?socket的阻塞問題

更新時(shí)間：2021年12月13日 15:49:48 作者：shusy411

這篇文章主要介紹了如何解決TCP?socket的阻塞問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

解決TCP socket的阻塞問題

大家知道，tcp的讀和寫是阻塞的，即讀的時(shí)候不知道什么時(shí)候讀完，寫的時(shí)候不知道什么時(shí)候?qū)懲辏虼司€程就一直暫停在哪里，一般tcp程序用在上位機(jī)下位機(jī)之間對(duì)吧！

下位機(jī)一些設(shè)備一般會(huì)發(fā)心跳報(bào)文給我們機(jī)器，假設(shè)為10s發(fā)一次吧，當(dāng)機(jī)器超過10s沒接收到數(shù)據(jù)，那么我們就要考慮把socket斷開，因?yàn)椴粩嚅_的話設(shè)備重新連接可能又會(huì)建立新的socket，這樣如果設(shè)備反復(fù)斷開連接的話，將產(chǎn)生大量的socket，占用大量系統(tǒng)資源，這里我們用socket.setSoTimeout(500)方法解決read方法的阻塞問題，同時(shí)設(shè)定一個(gè)標(biāo)志位

在異常處理程序當(dāng)中退出socket連接

 public void run(){
     InputStream is = null;
  OutputStream os = null;
  int flag = 0;
  try {
   socket.setSoTimeout(500); //  0.5秒就退出read()方法的阻塞
   is = socket.getInputStream();
   os = socket.getOutputStream();

  } catch (Exception e2) {
   e2.printStackTrace();
  }

 while (true) {
   try {
    // 讀取數(shù)據(jù)
    int readlen = is.read(buff);
    if (readlen > 0) {
     flag = 0;
    }
    byte data[] = Arrays.copyOfRange(buff, 0, readlen);
    resolveData(data);
   } catch (IOException e) {
    try {

     flag++;
     if (flag == 200) {    
      is.close();
      os.close();
      socket.close();

     }
    } catch (Exception e1) {
     e1.printStackTrace();
    }

   }
  }
  }