golang判断net.Conn 是否已关闭的操作

在多线程的线程里边，用一个线程处理一条连接，如何判断连接已经关闭？

试了一下，如果连接中断，读写会出现这种net.OpError，这个就可以判断是否断开

但是我也不确定有没有更好的方法？如果有的话，希望朋友们不吝赐教

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是否关闭的方法

如果不判断chan是否关闭

Notice: 以下代码会产生死循环

代码如下:

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

判断短chan是否关闭

代码如下:

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)
 }
}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。如有错误或未考虑完全的地方，望不吝赐教。

赞 (0)

相关推荐

  • 解决Golang json序列化字符串时多了\的情况

    解决Golang json序列化字符串时多了\的情况

    我们在对外提供API接口,返回响应的时候,很多时候需要使用如下的数据结构 type Response struct { Code int `json:"code"` Msg string `json:"msg"` Data interface{} `json:"data"` } 该API接口返回一个状体码,状态信息,以及具体的值.但是具体的值可能根据各个接口的不同而不同. 在实际的开发过程中我们可能会得到一个实际的数据值,并将这个值赋值给data

  • 详解mongodb搭建Replica Set的方法

    1.创建数据文件夹: mkdir -p /data/master mkdir -p /data/slaver mkdir -p /data/arbiter 效果: data 文件夹包含 arbiter   master  slaver 三个文件夹 2.创建日志存放文件 vi /log/master.log vi /log/slaver.log vi /log/arbiter.log 效果: log文件夹包含 master.log  slaver.log  arbiter.log 三个文件(注意,

  • go语言 bool类型的使用操作

    我就废话不多说了,大家还是直接看代码吧~ // 1 声明类型,没有初始化,零值(false) var a bool a = true fmt.Println("a = ", a) // 2 自动推导类型 var b = false fmt.Println("b = ", b) c := false fmt.Println("c = ", c) 补充:Go语言基础:变量,常量,Boolean,字符串,iota枚举 定义变量 格式:var 变量名 变

  • golang获取网卡信息操作

    golang获取网卡信息操作

    我就废话不多说了,大家还是直接看代码吧~ package main import ( "fmt" "os/exec" "strings" "github.com/safchain/ethtool" ) func main() { baseNicPath := "/sys/class/net/" cmd := exec.Command("ls", baseNicPath) buf, err

  • golang:json 反序列化的[]和nil操作

    我就废话不多说了,大家还是直接看代码吧~ package main import ( "encoding/json" "log" ) type JS struct { A []string } func main() { v1 := &JS{} v2 := &JS{A: []string{}} o1, err := json.Marshal(&v1) log.Println(string(o1), err) o2, err2 := json.

  • Go语言获取系统性能数据gopsutil库的操作

    psutil是一个跨平台进程和系统监控的Python库,而gopsutil是其Go语言版本的实现.本文介绍了它的基本使用. Go语言部署简单.性能好的特点非常适合做一些诸如采集系统信息和监控的服务,本文介绍的gopsutil库是知名Python库:psutil的一个Go语言版本的实现. 一.安装 go get github.com/shirou/gopsutil 二.使用 2.1 CPU 采集CPU相关信息. import "github.com/shirou/gopsutil/cpu"

  • golang判断net.Conn 是否已关闭的操作

    在多线程的线程里边,用一个线程处理一条连接,如何判断连接已经关闭? 试了一下,如果连接中断,读写会出现这种net.OpError,这个就可以判断是否断开 但是我也不确定有没有更好的方法?如果有的话,希望朋友们不吝赐教 func dealConn(conn net.Conn){ //defer conn.Close() //defer conn.Flush() //长连接里边的读写操作必须放到循环里面这样才能进行多次的读写 // 如果连接已经断开,就把这个线程中断掉,怎么判断这个连接已经断开? t

  • golang判断chan channel是否关闭的方法

    本文实例讲述了golang判断chan channel是否关闭的方法.分享给大家供大家参考,具体如下: 群里有朋友问,怎么判断chan是否关闭,因为close的channel不会阻塞,并返回类型的nil值,会导致死循环.在这里写个例子记录一下,并且分享给大家 如果不判断chan是否关闭 Notice: 以下代码会产生死循环 复制代码 代码如下: package main import (     "fmt" ) func main() {     c := make(chan int,

  • Java中如何判断线程池任务已执行完成

    Java中如何判断线程池任务已执行完成

    目录 不判断的问题 方法1:isTerminated 缺点分析 扩展:线程池的所有状态 方法2:getCompletedTaskCount 方法说明 优缺点分析 方法3:CountDownLatch 优缺点分析 方法4:CyclicBarrier 方法说明 优缺点分析 总结 前言: 很多场景下,我们需要等待线程池的所有任务都执行完,然后再进行下一步操作.对于线程 Thread 来说,很好实现,加一个 join 方法就解决了,然而对于线程池的判断就比较麻烦了. 我们本文提供 4 种判断线程池任务是

  • Android编程判断应用程序是否已安装的方法

    本文实例讲述了Android编程判断应用程序是否已安装的方法.分享给大家供大家参考,具体如下: 这里以twitter程序为例,假设twitter程序包名为"com.twitter.android".这时候可用以下代码来判断是否被安装. PackageInfo packageInfo; try { packageInfo = this.getPackageManager().getPackageInfo( "com.twitter.android", 0); } ca

  • Golang判断struct/slice/map是否相等以及对比的方法总结

    目录 前言 == 的对比方式 == 适用的类型 slice和map使用 == channel使用 == struct结构体使用== reflect.DeepEqual() 和cmp.Equal() reflect.DeepEqual() cmp.Equal() cmp和DeepEqual的区别 性能比较 总结 前言 平时开发中对比两个struct或者map.slice是否相等是经常遇到的,有很多对比的方式,比如==,reflect.DeepEqual(),cmp.Equal()等也是经常容易混淆

  • JS监控关闭浏览器操作的实例详解

    JS监控关闭浏览器操作的实例详解 需求如下: 用户关闭浏览器通知后台. 方案如下: 1.采用js监控关闭浏览器操作. 2.用户关闭浏览器的时候发ajax请求到后台,执行相应的业务操作 代码如下: <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head> &l

  • JS switch判断 三目运算 while 及 属性操作代码

    三 目运算:如var a = 10: var b= 12: c = a>b ?a:b; 若成立执行a否则执行b var isHide = true; 若用if判断语句如下 if(isHide) { box.style.display = "block"; } else { box.style.display = "none"; } 三目运算替代if box.style.display = isHide?"block":"none&

  • python中threading开启关闭线程操作

    在python中启动和关闭线程: 首先导入threading import threading 然后定义一个方法 def serial_read(): ... ... 然后定义线程,target指向要执行的方法 myThread = threading.Thread(target=serial_read) 启动它 myThread.start() 二.停止线程 不多说了直接上代码 import inspect import ctypes def _async_raise(tid, exctype

  • Python判断字符串是否为合法标示符操作

    这学期在学习编译原理,最近的上机作业就是做一个简单的词法分析器,在做的过程中,突然有个需求就是判断一个字符串是否为合法的标示符,因为我是用python语言做的,做的是Python的词法分析器,于是下面分享以下怎样判断一个字符串是合法的标示符. 首先,我们来熟悉以下python标示符的定义是什么? 定义:以字母或下划线开始的,由字母,数字或下划线组成,但是不能是python的保留字. 又有疑问了,python有哪些保留字,分别是什么? # python2.x import keyword prin

  • SQL判断是否"存在",还在用 count 操作?很耗时的！

    根据某一条件从数据库表中查询 『有』与『没有』,只有两种状态,那为什么在写SQL的时候,还要select count(*) 呢? 无论是刚入道的程序员新星,还是精湛沙场多年的程序员老白,都是一如既往的count. 目前多数人的写法 多次 review 代码时,发现如现现象: 业务代码中,需要根据一个或多个条件,查询是否存在记录,不关心有多少条记录.普遍的SQL及代码写法如下 SQL写法: SELECT count(*) FROM table WHERE a = 1 AND b = 2 Java写

随机推荐