session.Close

IoTServ · IoTServ · commit e7876f4ecb7b · 2025-07-21T22:06:50.000+08:00
diff --git a/services/serverSession.go b/services/serverSession.go
@@ -72,6 +72,7 @@ func (ss *ServerSession) loopStream() {
 		stream, err := ss.session.AcceptStream()
 		if err != nil {
 			log.Println("accpStreamErr：" + err.Error())
+			ss.session.Close()
 			break
 		}
 		log.Println("获取到一个连接需要处理")

Original file line number	Diff line number	Diff line change
`@@ -72,6 +72,7 @@ func (ss *ServerSession) loopStream() {`
`72`	`72`	`stream, err := ss.session.AcceptStream()`
`73`	`73`	`if err != nil {`
`74`	`74`	`log.Println("accpStreamErr：" + err.Error())`
	`75`	`+ ss.session.Close()`
`75`	`76`	`break`
`76`	`77`	`}`
`77`	`78`	`log.Println("获取到一个连接需要处理")`