快捷導(dǎo)航

golang判斷net.Conn 是否已關(guān)閉的操作

更新時(shí)間：2020年12月24日 15:02:12 作者：zhenshanrenhao

這篇文章主要介紹了golang判斷net.Conn 是否已關(guān)閉的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

在多線程的線程里邊，用一個(gè)線程處理一條連接，如何判斷連接已經(jīng)關(guān)閉？

試了一下，如果連接中斷，讀寫(xiě)會(huì)出現(xiàn)這種net.OpError，這個(gè)就可以判斷是否斷開(kāi)

但是我也不確定有沒(méi)有更好的方法？如果有的話，希望朋友們不吝賜教

func dealConn(conn net.Conn){
	//defer conn.Close()
	//defer conn.Flush()
 //長(zhǎng)連接里邊的讀寫(xiě)操作必須放到循環(huán)里面這樣才能進(jìn)行多次的讀寫(xiě)
 // 如果連接已經(jīng)斷開(kāi)，就把這個(gè)線程中斷掉，怎么判斷這個(gè)連接已經(jīng)斷開(kāi)？ 
 thread_c:=0;//如果連續(xù)100秒中讀取不到內(nèi)容，就終止循環(huán)
 for{
  defer func() {
   if r := recover(); r != nil {
    buf:=make([]byte,666)
    buf=buf[:runtime.Stack(buf,false)]
    log.Printf("運(yùn)行時(shí)錯(cuò)誤:%v.Runtime error caught: %s",r, buf)
   }
  }()
  // 注意continue這里也要等待，不然造成內(nèi)存耗盡，處理器耗盡
  time.Sleep(50*time.Millisecond)
  //#log.Println(len,string(text))
  thread_c++
  if thread_c>20*100{
  	log.Println(conn.RemoteAddr(),"超過(guò)100秒未讀取到內(nèi)容，本連接將關(guān)閉")
  	conn.Close();
  	c--;
  	break;
  }
  frame,op_err:=readAllShut(conn)
  if op_err!=nil{
  	log.Println(conn.RemoteAddr(),"出現(xiàn)讀寫(xiě)錯(cuò)誤，連接不可用，將會(huì)被關(guān)閉")
  	conn.Close();
  	c--;
  	break;//這種已經(jīng)關(guān)閉的連接，要終止循環(huán)，退出這條線程
  }
  if(len(frame)==0){
  	//
  	//time.Sleep(50*time.Millisecond)
   continue
  }
  thread_c=0;
  log.Printf("-----------------收到tcp請(qǐng)求:報(bào)文的長(zhǎng)度是%v,詳細(xì)內(nèi)容如下:%s,轉(zhuǎn)換成16進(jìn)制是:%x", len(frame),frame,frame)
  //TODO
  //這里寫(xiě)自己的業(yè)務(wù)代碼
  }
 }
func readAllShut(conn net.Conn) ([]byte,error){	//這個(gè)手動(dòng)方法可以避免粘包的問(wèn)題
	//bufio.NewWriter
	re:=bytes.NewBuffer(nil)
	const N=666
	for{
		var text [N]byte
		lens,err:=conn.Read(text[0:])
		re.Write(text[:lens])
		if lens==0 || err!=nil{
			//log.Println(err) //在這個(gè)死循環(huán)里面，不要有任何的輸出
			// if errors.As(err,*net.OpError) 	//
			if _,ok:=err.( *net.OpError) ;ok{		
				return nil,err
			}
			break
		}
		//conn
		//log.Println(lens,text)
		if lens<N{
			break
		}
	}
	rb:= re.Bytes()
	//log.Println(rb,"len",len(rb))
	return rb,nil
	/*data,err:=ioutil.ReadAll(conn)
	if err!=nil{
		log.Printf("讀取出現(xiàn)錯(cuò)誤%T:%v",err,err)
	}
	return data;*/
}

補(bǔ)充：Go -- 判斷chan channel是否關(guān)閉的方法

如果不判斷chan是否關(guān)閉

Notice: 以下代碼會(huì)產(chǎn)生死循環(huán)

代碼如下:

package main
import (
 "fmt"
)
func main() {
 c := make(chan int, 10)
 c <- 1
 c <- 2
 c <- 3
 close(c)
 for {
  fmt.Println(<-c)
 }
}

判斷短chan是否關(guān)閉

代碼如下:

package main
import (
 "fmt"
)
func main() {
 c := make(chan int, 10)
 c <- 1
 c <- 2
 c <- 3
 close(c)
 for {
  i, isClose := <-c
  if !isClose {
   fmt.Println("channel closed!")
   break
  }
  fmt.Println(i)
 }
}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。

您可能感興趣的文章: