sorry 事情有点多,我做的比较简单的处理
// Ping keep each session alive
func (cli *NebulaCli) Ping() {
stmt := "show hosts"
fmt.Println("Ping...")
for i := 0; i < cli.max; i++ {
cli.Query(stmt)
}
}
func main() {
defer nCli.Close()
go func() {
for {
nCli.Ping()
time.Sleep(9 * time.Minute) // 比过期时间短一些
}
}()
}