Go有同步和沟通的渠道,请使用它们!
使您的连接处于循环状态,并让它等待某种消息返回通道。
...errCh := make(chan error)for { lsconn, err = net.Dial("tcp", logStashHost) // check error! go ReadLogStash(lsconn, errCh) err = <-errCh if err != nil { // bad error break } // sleep to backoff on retries?}...func ReadLogStash(conn net.Conn, errCh chan error) { _, err := io.Copy(os.Stderr, conn) if err != nil { fmt.Println(err) } // a nil error from io.Copy means you reached EOF. errCh <- err}除非您在ReadLogStash中具有更多功能,否则您可能只能使用io.Copy内联,而忘了整个功能,但是无论如何,此模式可能对您很有用。



