示例: 并發的Echo服務 · The Go Programming Language

## 8.3. 示例: 并發的Echo服務 clock服務器每一個連接都會起一個goroutine。在本節中我們會創建一個echo服務器，這個服務在每個連接中會有多個goroutine。大多數echo服務僅僅會返回他們讀取到的內容，就像下面這個簡單的handleConn函數所做的一樣： ```go func handleConn(c net.Conn) { io.Copy(c, c) // NOTE: ignoring errors c.Close() } ``` 一個更有意思的echo服務應該模擬一個實際的echo的“回響”，并且一開始要用大寫HELLO來表示“聲音很大”，之后經過一小段延遲返回一個有所緩和的Hello，然后一個全小寫字母的hello表示聲音漸漸變小直至消失，像下面這個版本的handleConn(譯注：笑看作者腦洞大開)： gopl.io/ch8/reverb1 ```go func echo(c net.Conn, shout string, delay time.Duration) { fmt.Fprintln(c, "\t", strings.ToUpper(shout)) time.Sleep(delay) fmt.Fprintln(c, "\t", shout) time.Sleep(delay) fmt.Fprintln(c, "\t", strings.ToLower(shout)) } func handleConn(c net.Conn) { input := bufio.NewScanner(c) for input.Scan() { echo(c, input.Text(), 1*time.Second) } // NOTE: ignoring potential errors from input.Err() c.Close() } ``` 我們需要升級我們的客戶端程序，這樣它就可以發送終端的輸入到服務器，并把服務端的返回輸出到終端上，這使我們有了使用并發的另一個好機會： gopl.io/ch8/netcat2 ```go func main() { conn, err := net.Dial("tcp", "localhost:8000") if err != nil { log.Fatal(err) } defer conn.Close() go mustCopy(os.Stdout, conn) mustCopy(conn, os.Stdin) } ``` 當main goroutine從標準輸入流中讀取內容并將其發送給服務器時，另一個goroutine會讀取并打印服務端的響應。當main goroutine碰到輸入終止時，例如，用戶在終端中按了Control-D(^D)，在windows上是Control-Z，這時程序就會被終止，盡管其它goroutine中還有進行中的任務。(在8.4.1中引入了channels后我們會明白如何讓程序等待兩邊都結束)。下面這個會話中，客戶端的輸入是左對齊的，服務端的響應會用縮進來區別顯示。客戶端會向服務器“喊三次話”： ``` $ go build gopl.io/ch8/reverb1 $ ./reverb1 & $ go build gopl.io/ch8/netcat2 $ ./netcat2 Hello? HELLO? Hello? hello? Is there anybody there? IS THERE ANYBODY THERE? Yooo-hooo! Is there anybody there? is there anybody there? YOOO-HOOO! Yooo-hooo! yooo-hooo! ^D $ killall reverb1 ``` 注意客戶端的第三次shout在前一個shout處理完成之前一直沒有被處理，這貌似看起來不是特別“現實”。真實世界里的回響應該是會由三次shout的回聲組合而成的。為了模擬真實世界的回響，我們需要更多的goroutine來做這件事情。這樣我們就再一次地需要go這個關鍵詞了，這次我們用它來調用echo： gopl.io/ch8/reverb2 ```go func handleConn(c net.Conn) { input := bufio.NewScanner(c) for input.Scan() { go echo(c, input.Text(), 1*time.Second) } // NOTE: ignoring potential errors from input.Err() c.Close() } ``` go后跟的函數的參數會在go語句自身執行時被求值；因此input.Text()會在main goroutine中被求值。現在回響是并發并且會按時間來覆蓋掉其它響應了： ``` $ go build gopl.io/ch8/reverb2 $ ./reverb2 & $ ./netcat2 Is there anybody there? IS THERE ANYBODY THERE? Yooo-hooo! Is there anybody there? YOOO-HOOO! is there anybody there? Yooo-hooo! yooo-hooo! ^D $ killall reverb2 ``` 讓服務使用并發不只是處理多個客戶端的請求，甚至在處理單個連接時也可能會用到，就像我們上面的兩個go關鍵詞的用法。然而在我們使用go關鍵詞的同時，需要慎重地考慮net.Conn中的方法在并發地調用時是否安全，事實上對于大多數類型來說也確實不安全。我們會在下一章中詳細地探討并發安全性。