我們可以看到 gorilla/websocket中的examples中有一個聊天室的demo。
創(chuàng)新互聯(lián)公司專業(yè)為企業(yè)提供阿拉爾網(wǎng)站建設(shè)、阿拉爾做網(wǎng)站、阿拉爾網(wǎng)站設(shè)計、阿拉爾網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、阿拉爾企業(yè)網(wǎng)站模板建站服務(wù)，十多年阿拉爾做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。
我們進(jìn)入該項(xiàng)目可以看到里面有這樣的一些內(nèi)容
按照官方的運(yùn)行方式來運(yùn)行這個項(xiàng)目
在瀏覽器中打開8080端口，可以看到該項(xiàng)目可以被成功運(yùn)行了。
就是這樣一個簡單的demo。
然后我們?nèi)タ匆幌滤木唧w實(shí)現(xiàn)。
在這個項(xiàng)目中首先定義了一個hub的結(jié)構(gòu)體：
這個結(jié)構(gòu)體中，clients代表所有已經(jīng)注冊的用戶，broadcast管道會存儲客戶端發(fā)送來的信息。 register是一個*Client類型的管道，用于存儲新注冊的用戶，unregister管道反之。
我們打開main.go，main函數(shù)的源碼為：
在這里首先會新開一個goroutine，去跑hub的run方法，run方法中一個死循環(huán)，不停地去輪詢hub中的內(nèi)容
如果取到了新用戶，就加入到clients中，如果取到了信息，就循環(huán)所有的client,將信息寫到client.send中。
我們看到在請求路徑為根的時候，它會請求一個函數(shù)，而這個函數(shù)就是將home.html發(fā)送到客戶端。
而在請求路徑為“/ws”的時候，他會執(zhí)行一個serveWS的函數(shù)。
每當(dāng)一個新的用戶進(jìn)來之后，首先將連接升級為長連接，然后將當(dāng)前的client寫到register中，由hub.run函數(shù)去做處理。然后開啟兩個goroutine,一個去讀client中發(fā)送來的數(shù)據(jù)，一個將數(shù)據(jù)寫入到所有的client中，去發(fā)送給用戶。
這就是整個聊天室的實(shí)現(xiàn)原理。
TCP 和 UDP 服務(wù)端隨處可見，它們基于 TCP/IP 協(xié)議棧，通過網(wǎng)絡(luò)為客戶端提供服務(wù)。在這篇文章中，我將介紹如何使用 Go 語言開發(fā)一個用于返回隨機(jī)數(shù)、支持并發(fā)的 TCP 服務(wù)端。對于每一個來自 TCP 客戶端的連接，它都會啟動一個新的 goroutine（輕量級線程）來處理相應(yīng)的請求。
你可以在 GitHub 上找到本項(xiàng)目的源碼：concTcp.go。
這個程序的主要邏輯在 handleConnection 函數(shù)中，具體實(shí)現(xiàn)如下：
在 main 函數(shù)的實(shí)現(xiàn)部分，每當(dāng) TCP 服務(wù)端收到 TCP 客戶端的連接請求，它都會啟動一個新的 goroutine 來為這個請求提供服務(wù)。
首先， main 確保程序至少有一個命令行參數(shù)。注意，現(xiàn)有代碼并沒有檢查這個參數(shù)是否為有效的 TCP 端口號。不過，如果它是一個無效的 TCP 端口號， net.Listen 就會調(diào)用失敗，并返回一個錯誤信息，類似下面這樣：
net.Listen 函數(shù)用于告訴 Go 接受網(wǎng)絡(luò)連接，因而承擔(dān)了服務(wù)端的角色。它的返回值類型是 net.Conn ，后者實(shí)現(xiàn)了 io.Reader 和 io.Writer 接口。此外， main 函數(shù)中還調(diào)用了 rand.Seed 函數(shù)，用于初始化隨機(jī)數(shù)生成器。最后， for 循環(huán)允許程序一直使用 Accept 函數(shù)來接受 TCP 客戶端的連接請求，并以 goroutine 的方式來運(yùn)行 handleConnection(c) 函數(shù)，處理客戶端的后續(xù)請求。
net.Listen 函數(shù)的第一個參數(shù)定義了使用的網(wǎng)絡(luò)類型，而第二個參數(shù)定義了服務(wù)端監(jiān)聽的地址和端口號。第一個參數(shù)的有效值為 tcp 、 tcp4 、 tcp6 、 udp 、 udp4 、 udp6 、 ip 、 ip4 、 ip6 、 Unix （Unix 套接字）、 Unixgram 和 Unixpacket ，其中： tcp4 、 udp4 和 ip4 只接受 IPv4 地址，而 tcp6 、 udp6 和 ip6 只接受 IPv6 地址。
concTCP.go 需要一個命令行參數(shù)，來指定監(jiān)聽的端口號。當(dāng)它開始服務(wù) TCP 客戶端時，你會得到類似下面的輸出：
netstat 的輸出可以確認(rèn) congTCP.go 正在為多個 TCP 客戶端提供服務(wù)，并且仍在繼續(xù)監(jiān)聽建立連接的請求：
在上面輸出中，最后一行顯示了有一個進(jìn)程正在監(jiān)聽 8001 端口，這意味著你可以繼續(xù)連接 TCP 的 8001 端口。第一行和第二行顯示了有一個已建立的 TCP 網(wǎng)絡(luò)連接，它占用了 8001 和 62556 端口。相似地，第三行和第四行顯示了有另一個已建立的 TCP 連接，它占用了 8001 和 62554 端口。
下面這張圖片顯示了 concTCP.go 在服務(wù)多個 TCP 客戶端時的輸出：
類似地，下面這張圖片顯示了兩個 TCP 客戶端的輸出（使用了 nc 工具）：
你可以在 維基百科上找到更多關(guān)于 nc （即 netcat ）的信息。
現(xiàn)在，你學(xué)會了如何用大約 65 行 Go 代碼來開發(fā)一個生成隨機(jī)數(shù)、支持并發(fā)的 TCP 服務(wù)端，這真是太棒了！如果你想要讓你的 TCP 服務(wù)端執(zhí)行別的任務(wù)，只需要修改 handleConnection 函數(shù)即可。
via:
作者：Mihalis Tsoukalos選題：lkxed譯者：lkxed校對：wxy
三次握手：
1. 主動發(fā)起連接請求端（客戶端），發(fā)送 SYN 標(biāo)志位，攜帶數(shù)據(jù)包、包號
2. 被動接收連接請求端（服務(wù)器），接收 SYN，回復(fù) ACK，攜帶應(yīng)答序列號。同時，發(fā)送SYN標(biāo)志位，攜帶數(shù)據(jù)包、包號
3. 主動發(fā)起連接請求端（客戶端），接收SYN 標(biāo)志位，回復(fù) ACK。
被動端（服務(wù)器）接收 ACK —— 標(biāo)志著 三次握手建立完成（ Accept()/Dial() 返回 ）
四次揮手：
1. 主動請求斷開連接端（客戶端）， 發(fā)送 FIN標(biāo)志，攜帶數(shù)據(jù)包
2. 被動接受斷開連接端（服務(wù)器）， 發(fā)送 ACK標(biāo)志，攜帶應(yīng)答序列號。 —— 半關(guān)閉完成。
3. 被動接受斷開連接端（服務(wù)器）， 發(fā)送 FIN標(biāo)志，攜帶數(shù)據(jù)包
4. 主動請求斷開連接端（客戶端）， 發(fā)送 最后一個 ACK標(biāo)志，攜帶應(yīng)答序列號?！?發(fā)送完成，客戶端不會直接退出，等 2MSL時長。
等 2MSL待目的：確保服務(wù)器 收到最后一個ACK
滑動窗口：
通知對端本地存儲數(shù)據(jù)的 緩沖區(qū)容量。—— write 函數(shù)在對端 緩沖區(qū)滿時，有可能阻塞。
TCP狀態(tài)轉(zhuǎn)換：
1. 主動發(fā)起連接請求端：
CLOSED —— 發(fā)送SYN —— SYN_SENT(了解) —— 接收ACK、SYN，回發(fā) ACK —— ESTABLISHED (數(shù)據(jù)通信)
2. 主動關(guān)閉連接請求端：
ESTABLISHED —— 發(fā)送FIN —— FIN_WAIT_1 —— 接收ACK —— FIN_WAIT_2 (半關(guān)閉、主動端)
—— 接收FIN、回復(fù)ACK —— TIME_WAIT (主動端) —— 等 2MSL 時長 —— CLOSED
3. 被動建立連接請求端：
CLOSED —— LISTEN —— 接收SYN、發(fā)送ACK、SYN —— SYN_RCVD —— 接收 ACK —— ESTABLISHED (數(shù)據(jù)通信)
4. 被動斷開連接請求端：
ESTABLISHED —— 接收 FIN、發(fā)送 ACK —— CLOSE_WAIT —— 發(fā)送 FIN —— LAST_ACK —— 接收ACK —— CLOSED
windows下查看TCP狀態(tài)轉(zhuǎn)換：
netstat -an | findstr? 端口號
Linux下查看TCP狀態(tài)轉(zhuǎn)換：
netstat -an | grep? 端口號
TCP和UDP對比:?
TCP: 面向連接的可靠的數(shù)據(jù)包傳遞。 針對不穩(wěn)定的 網(wǎng)絡(luò)層，完全彌補(bǔ)。ACK
UDP：無連接不可靠的報文傳輸。 針對不穩(wěn)定的 網(wǎng)絡(luò)層，完全不彌補(bǔ)。還原網(wǎng)絡(luò)真實(shí)狀態(tài)。
優(yōu)點(diǎn)???????????????????????????????????????????????????????????? 缺點(diǎn)
TCP： 可靠、順序、穩(wěn)定 ???????????????????????????????????? 系統(tǒng)資源消耗大，程序?qū)崿F(xiàn)繁復(fù)、速度慢
UDP：系統(tǒng)資源消耗小，程序?qū)崿F(xiàn)簡單、速度快 ???????????????????????? 不可靠、無序、不穩(wěn)定
使用場景：
TCP：大文件、可靠數(shù)據(jù)傳輸。 對數(shù)據(jù)的 穩(wěn)定性、準(zhǔn)確性、一致性要求較高的場合。
UDP：應(yīng)用于對數(shù)據(jù)時效性要求較高的場合。 網(wǎng)絡(luò)直播、電話會議、視頻直播、網(wǎng)絡(luò)游戲。
UDP-CS-Server實(shí)現(xiàn)流程：
1.? 創(chuàng)建 udp地址結(jié)構(gòu) ResolveUDPAddr(“協(xié)議”， “IP：port”) —— udpAddr 本質(zhì) struct{IP、port}
2.? 創(chuàng)建用于 數(shù)據(jù)通信的 socket ListenUDP(“協(xié)議”, udpAddr ) —— udpConn (socket)
3.? 從客戶端讀取數(shù)據(jù)，獲取對端的地址 udpConn.ReadFromUDP() —— 返回：n，clientAddr， err
4.? 發(fā)送數(shù)據(jù)包給 客戶端 udpConn.WriteToUDP("數(shù)據(jù)"， clientAddr)
UDP-CS-Client實(shí)現(xiàn)流程：
1.? 創(chuàng)建用于通信的 socket。 net.Dial("udp", "服務(wù)器IP：port") —— udpConn (socket)
2.? 以后流程參見 TCP客戶端實(shí)現(xiàn)源碼。
UDPserver默認(rèn)就支持并發(fā)！
------------------------------------
命令行參數(shù)： 在main函數(shù)啟動時，向整個程序傳參。 【重點(diǎn)】
語法： go run xxx.go ? argv1 argv2? argv3? argv4 。。。
xxx.exe:? 第 0 個參數(shù)。
argv1 ：第 1 個參數(shù)。
argv2 ：第 2 個參數(shù)。
argv3 ：第 3 個參數(shù)。
argv4 ：第 4 個參數(shù)。
使用： list := os.Args? 提取所有命令行參數(shù)。
獲取文件屬性函數(shù)：
os.stat(文件訪問絕對路徑) —— fileInfo 接口
fileInfo 包含 兩個接口。
Name() 獲取文件名。 不帶訪問路徑
Size() 獲取文件大小。
網(wǎng)絡(luò)文件傳輸 —— 發(fā)送端（客戶端）
1.? 獲取命令行參數(shù)，得到文件名（帶路徑）filePath list := os.Args
2.? 使用 os.stat() 獲取 文件名（不帶路徑）fileName
3.? 創(chuàng)建 用于數(shù)據(jù)傳輸?shù)?socket? net.Dial("tcp"， “服務(wù)器IP+port”) —— conn
4.? 發(fā)送文件名(不帶路徑)? 給接收端， conn.write()
5.? 讀取 接收端回發(fā)“ok”，判斷無誤。封裝函數(shù) sendFile(filePath, conn) 發(fā)送文件內(nèi)容
6.? 實(shí)現(xiàn) sendFile(filePath,? conn)
1) 只讀打開文件 os.Open(filePath)
for {
2) 從文件中讀數(shù)據(jù)? f.Read(buf)
3) 將讀到的數(shù)據(jù)寫到socket中? conn.write(buf[:n])
4）判斷讀取文件的 結(jié)尾。 io.EOF. 跳出循環(huán)
}
網(wǎng)絡(luò)文件傳輸 —— 接收端（服務(wù)器）
1. 創(chuàng)建用于監(jiān)聽的 socket net.Listen() —— listener
2. 借助listener 創(chuàng)建用于 通信的 socket listener.Accpet()? —— conn
3. 讀取 conn.read() 發(fā)送端的 文件名， 保存至本地。
4. 回發(fā) “ok”應(yīng)答 發(fā)送端。
5. 封裝函數(shù)，接收文件內(nèi)容 recvFile(文件路徑)
1) f = os.Create(帶有路徑的文件名)
for {
2）從 socket中讀取發(fā)送端發(fā)送的 文件內(nèi)容 。 conn.read(buf)
3)? 將讀到的數(shù)據(jù) 保存至本地文件 f.Write(buf[:n])
4)? 判斷 讀取conn 結(jié)束， 代表文件傳輸完成。 n == 0? break
}
TL;DR 在使用 Golang 編寫 TCP/UDP socket 的時候，第一步做的就是地址解析。
該函數(shù)返回的地址包含的信息如下：
TCPAddr 里， IP 既可以是 IPv4 地址，也可以是 IPv6 地址。 Port 就是端口了。 Zone 是 IPv6 本地地址所在的區(qū)域。
從返回結(jié)果看該函數(shù)的參數(shù)， network 指 address 的網(wǎng)絡(luò)類型； address 指要解析的地址，會從中解析出我們想要的 IP , Port 和 Zone 。
從源碼中可以看出，參數(shù) network 只能是如下四個值，否則會得到一個錯誤。
解析過程跟 ResolveTCPAddr 的一樣，不過得到的是 *UDPAddr 。
UDPAddr 包含的信息如下：
我們在mian函數(shù)中，首先初始化配置文件，然后新建http連接。
這個連接創(chuàng)建之后，監(jiān)聽服務(wù)器的9999端口。如果url的路徑后綴為 "/ws",就轉(zhuǎn)發(fā)到ws/ws.go中的IndexHandler方法中。
這個方法中首先我們創(chuàng)建一個websocket的Upgrader實(shí)例，然后我們使用Upgrader的upgrade方法來升級一下我們的連接為長連接。
升級完成之后會返回一個*websocket.Conn的連接，我們之后所有的關(guān)于連接的操作，都是基于該conn的。
在該連接完成之后，我們將連接存放到一個名為Client的map中，以便之后管理更為方便。
之后，我們啟動一個goroutine來讀取連接中發(fā)送的信息內(nèi)容，再根據(jù)內(nèi)容進(jìn)行相應(yīng)的操作。
用戶數(shù)據(jù)報協(xié)議（User Datagram Protocol，縮寫為UDP），又稱用戶數(shù)據(jù)報文協(xié)議，是一個簡單的面向數(shù)據(jù)報(package-oriented)的傳輸層協(xié)議，正式規(guī)范為RFC 768。
UDP只提供數(shù)據(jù)的不可靠傳遞，它一旦把應(yīng)用程序發(fā)給網(wǎng)絡(luò)層的數(shù)據(jù)發(fā)送出去，就不保留數(shù)據(jù)備份（所以UDP有時候也被認(rèn)為是不可靠的數(shù)據(jù)報協(xié)議）。
UDP在IP數(shù)據(jù)報的頭部僅僅加入了復(fù)用和數(shù)據(jù)校驗(yàn)。
由于缺乏可靠性且屬于非連接導(dǎo)向協(xié)議，UDP應(yīng)用一般必須允許一定量的丟包、出錯和復(fù)制粘貼。
1 在接收udp包時，如果接收包時給定的buffer太小的話，就要自己解決粘包問題。
2 udp包的發(fā)送和接收不保證一定成功，不保證按正確順序抵達(dá)。
3 如果不允許丟包的情況出現(xiàn)的話，要有重發(fā)機(jī)制來保證，如：反饋機(jī)制確認(rèn)。
服務(wù)端
客戶端
重慶分公司
重慶分公司
