使用golang怎么对net.Conn进行判断?针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
func dealConn(conn net.Conn){
//defer conn.Close()
//defer conn.Flush()
//长连接里边的读写操作必须放到循环里面这样才能进行多次的读写
// 如果连接已经断开,就把这个线程中断掉,怎么判断这个连接已经断开?
thread_c:=0;//如果连续100秒中读取不到内容,就终止循环
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这里也要等待,不然造成内存耗尽,处理器耗尽
time.Sleep(50*time.Millisecond)
//#log.Println(len,string(text))
thread_c++
if thread_c>20*100{
log.Println(conn.RemoteAddr(),"超过100秒未读取到内容,本连接将关闭")
conn.Close();
c--;
break;
}
frame,op_err:=readAllShut(conn)
if op_err!=nil{
log.Println(conn.RemoteAddr(),"出现读写错误,连接不可用,将会被关闭")
conn.Close();
c--;
break;//这种已经关闭的连接,要终止循环,退出这条线程
}
if(len(frame)==0){
//
//time.Sleep(50*time.Millisecond)
continue
}
thread_c=0;
log.Printf("-----------------收到tcp请求:报文的长度是%v,详细内容如下:%s,转换成16进制是:%x", len(frame),frame,frame)
//TODO
//这里写自己的业务代码
}
}
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) //在这个死循环里面,不要有任何的输出
// 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("读取出现错误%T:%v",err,err)
}
return data;*/
}
补充:Go -- 判断chan channel是否关闭的方法
Notice: 以下代码会产生死循环
代码如下:
package main
import (
"fmt"
)
func main() {
c := make(chan int, 10)
c <- 1
c <- 2
c <- 3
close(c)
for {
fmt.Println(<-c)
}
}
代码如下:
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)
}
}
关于使用golang怎么对net.Conn进行判断问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。