func dealConn(conn net.Conn){
//defer conn.Close()
//defer conn.Flush()
//長連接里邊的讀寫操作必須放到循環(huán)里面這樣才能進行多次的讀寫
// 如果連接已經(jīng)斷開，就把這個線程中斷掉，怎么判斷這個連接已經(jīng)斷開？
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("運行時錯誤:%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(),"超過100秒未讀取到內(nèi)容，本連接將關(guān)閉")
conn.Close();
c--;
break;
}
frame,op_err:=readAllShut(conn)
if op_err!=nil{
log.Println(conn.RemoteAddr(),"出現(xiàn)讀寫錯誤，連接不可用，將會被關(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請求:報文的長度是%v,詳細內(nèi)容如下:%s,轉(zhuǎn)換成16進制是:%x", len(frame),frame,frame)
//TODO
//這里寫自己的業(yè)務(wù)代碼
}
}
func readAllShut(conn net.Conn) ([]byte,error){ //這個手動方法可以避免粘包的問題
//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) //在這個死循環(huán)里面，不要有任何的輸出
// if errors.As(err,*net.OpError) //
if _,ok:=err.( *net.OpError) ;ok{
return nil,err
}
break
}
//conn
//log.Println(lens,text)
if lensN{
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)錯誤%T:%v",err,err)
}
return data;*/
}
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)
}
}
