use of closed network connection

[qyk1995]

当我成功连接到k8s集群之后，发送一个请求会出现下面错误：
{
"type": "stdout",
"data": "exit\r\n",
"cols": 0,
"rows": 0
}
和
E0727 11:09:46.370144 29472 v2.go:104] write tcp xx.xx.xx:61184->xx.xx.xx.xx:443: use of closed network connection

自己的代码：
conn, err :=websocket.Upgrade(c.Writer,` c.Request, nil, 1024, 1024)
if err != nil {
fmt.Println("Upgrade", err)
c.AbortWithStatusJSON(http.StatusOK, gin.H{"code": http.StatusInternalServerError, "msg": err.Error()})
return
}

// 通过 集群名称获取config
config, err := common.Getk8sclusterConfig(params.ClusterName)
config.ContentConfig.GroupVersion = &v1.Unversioned
config.ContentConfig.NegotiatedSerializer = scheme.Codecs

if err != nil {
	elog.Errorw("ContainerExec", "config", err)
	// c.JSONE(core.CodeErr, "cluster not found", nil)
	return
}
wsTransport := transport.NewWSTransport(conn)

tml, err := terminal.NewWebTerminal(config, params.Namespace, params.PodName, params.ContainerName, wsTransport)
if err != nil {
	elog.Errorw("ContainerExec", "terminal", err)
	_, _ = wsTransport.Write([]byte("连接终端失败，该Pod可能已经下线\n" + err.Error()))
	return
}
err = tml.Run()
if err != nil {
	elog.Errorw("ContainerExec", "run", err)
	_, _ = wsTransport.Write([]byte("连接终端失败:" + err.Error()))
	return
}

`