This commit is contained in:
chai2010
2015-12-21 17:25:03 +08:00
parent 38e249c65a
commit f699e83e46
6 changed files with 45 additions and 42 deletions

View File

@@ -1,7 +1,7 @@
## 8.10. 示例: 聊天服務
用一聊天服务器来终结本章节的内容,这个程序可以一些用户通过服务器向其它所有用户广播文本消息。这个程序中有四goroutine。main和broadcaster各自是一goroutine例,每一个客户端的接都有一handleConn和clientWriter的goroutine。broadcaster是select用法的不错的样例,因它需要理三不同型的消息。
下面演示的main goroutine的工作是listen和accept(译注:网络编程里的概念)从客户端过来的连接。每一个连接,程序都建立一新的handleConn的goroutine就像我在本章开头的并发的echo服器里所做的那
用一聊天服務器來終結本章節的內容,這個程序可以一些用戶通過服務器向其它所有用戶廣播文本消息。這個程序中有四goroutine。main和broadcaster各自是一goroutine例,每一個客戶端的接都有一handleConn和clientWriter的goroutine。broadcaster是select用法的不錯的樣例,因它需要理三不同型的消息。
下面演示的main goroutine的工作是listen和accept(譯註:網絡編程里的概念)從客戶端過來的連接。每一個連接,程序都建立一新的handleConn的goroutine就像我在本章開頭的併發的echo服器里所做的那
```go
gopl.io/ch8/chat
@@ -22,7 +22,7 @@ func main() {
}
```
是broadcaster的goroutine。他的内部变量clients会记录当前建立接的客端集合。其记录的内容是每一个客户端的消息发出channel的"格"信息。
是broadcaster的goroutine。他的內部變量clients會記録當前建立接的客端集合。其記録的內容是每一個客戶端的消息發齣channel的"格"信息。
```go
@@ -55,9 +55,9 @@ func broadcaster() {
}
```
broadcaster监听来自全局的entering和leaving的channel来获知客端的到来和离开事件。其接收到其中的一事件时,会更新clients集合当该事件是离开行为时,它会关闭客户端的消息发出channel。broadcaster也会监听全局的消息channel所有的客端都会向这个channel中送消息。broadcaster接收到什消息,就会将其广播至所有接到服端的客端。
broadcaster監聽來自全局的entering和leaving的channel來穫知客端的到來和離開事件。其接收到其中的一事件時,會更新clients集合當該事件是離開行爲時,它會關閉客戶端的消息發齣channel。broadcaster也會監聽全局的消息channel所有的客端都會向這個channel中送消息。broadcaster接收到什消息,就會將其廣播至所有接到服端的客端。
现在让我们看看每一个客户端的goroutine。handleConn函数会为它的客户端创建一消息发出channel并通过entering channel通知客端的到。然后它会读取客户端发来的每一行文本,并通过全局的消息channel来将这些文本发送出去,并为每条消息带上发送者的前缀来标明消息身份。当客户端发送完毕后handleConn会通过leaving这个channel通知客端的离开并关闭连接。
現在讓我們看看每一個客戶端的goroutine。handleConn函數會爲它的客戶端創建一消息發齣channel併通過entering channel通知客端的到。然後它會讀取客戶端發來的每一行文本,併通過全局的消息channel來將這些文本發送齣去,併爲每條消息帶上發送者的前綴來標明消息身份。當客戶端發送完畢後handleConn會通過leaving這個channel通知客端的離開併關閉連接。
```go
func handleConn(conn net.Conn) {
@@ -87,9 +87,9 @@ func clientWriter(conn net.Conn, ch <-chan string) {
}
```
另外handleConn每一个客户端创建了一clientWriter的goroutine接收向客户端发出消息channel中送的广播消息,并将它们写入到客端的网络连接。客端的取方循环会在broadcaster接收到leaving通知并关闭了channel后终止。
另外handleConn每一個客戶端創建了一clientWriter的goroutine接收向客戶端發齣消息channel中送的播消息,併將它們寫入到客端的網絡連接。客端的取方循環會在broadcaster接收到leaving通知併關閉了channel後終止。
下面演示的是当服务器有两个活动的客户端连接,且在两个窗口中行的情使用netcat聊天:
下面演示的是當服務器有兩個活動的客戶端連接,且在兩個窗口中行的情使用netcat聊天:
```
$ go build gopl.io/ch8/chat
$ go build gopl.io/ch8/netcat3
@@ -113,9 +113,9 @@ You are 127.0.0.1:64216 127.0.0.1:64216 has arrived
```
当与n个客户端保持聊天session时,这个程序有2n+2个并发的goroutine然而这个程序却并不需要式的(§9.2)。clients这个map被限在了一个独立的goroutine中broadcaster所以它不能被并发地访问。多goroutine共享的变量只有这些channel和net.Conn的例,两个东西都是并发安全的。我们会在下一章中更多地解决约束,并发安全以及goroutine中共享量的含
當與n個客戶端保持聊天session時,這個程序有2n+2個併發的goroutine然而這個程序卻併不需要式的(§9.2)。clients這個map被限在了一個獨立的goroutine中broadcaster所以它不能被併發地訪問。多goroutine共享的變量隻有這些channel和net.Conn的例,兩個東西都是併發安全的。我們會在下一章中更多地解決約束,併發安全以及goroutine中共享量的含
练习8.12: 使broadcaster能够将arrival事件通知前所有的客端。为了达成这个目的,你需要有一个客户端的集合,且在entering和leaving的channel中记录客户端的名字。
练习8.13: 使聊天服器能够断开空闲的客户端连接,比如最近五分钟之后没有发送任何消息的那些客端。提示可以在其它goroutine中用conn.Close()解除Read就像input.Scanner()所做的那
练习8.14: 改聊天服器的网络协议这样每一个客户端就可以在entering可以提供它的名字。消息前由之前的网络地址改为这个名字。
练习8.15: 如果一个客户端没有及时地读取数据可能会导致所有的客端被阻塞。改broadcaster来跳过一条消息,而不是等待这个客户端一直到其准备好写。或者每一个客户端的消息发出channel建立缓冲区,这样大部分的消息便不会被丢broadcaster应该用一非阻塞的send向这个channel中消息。
練習8.12: 使broadcaster能夠將arrival事件通知前所有的客端。爲了達成這個目的,你需要有一個客戶端的集合,且在entering和leaving的channel中記録客戶端的名字。
練習8.13: 使聊天服器能夠斷開空閒的客戶端連接,比如最近五分鐘之後沒有發送任何消息的那些客端。提示可以在其它goroutine中調用conn.Close()解除Read調就像input.Scanner()所做的那
練習8.14: 改聊天服器的網絡協議這樣每一個客戶端就可以在entering可以提供它的名字。消息前由之前的網絡地址改爲這個名字。
練習8.15: 如果一個客戶端沒有及時地讀取數據可能會導致所有的客端被阻塞。改broadcaster來跳過一條消息,而不是等待這個客戶端一直到其準備好寫。或者每一個客戶端的消息發齣channel建立緩衝區,這樣大部分的消息便不會被丟broadcaster應該用一非阻塞的send向這個channel中消息。