go語言聊天室實現（七）websocket收消息設置

上一節中，我們為每個連接都創建了一個goroutine來讀取其中的消息，現在我們將這個讀取消息的方法實現一下。

成都創新互聯從2013年創立，是專業互聯網技術服務公司，擁有項目網站設計制作、做網站網站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元景谷做網站,已為上家服務,為景谷各地企業和個人服務,聯系電話:18980820575

我們在application目錄下新建controllers目錄，并在其中創建一個MessageController.go文件。

首先我們新建一個MessageController的結構體，內容如下

這個結構體包括兩個內容，一個是我們將連接放在數組之后，返回的索引，另一個是連接本身.

這個是具體的方法。

我們首先設置了一下讀消息的大小、超時時間以及超時后需要的操作。

超時時間如果設置為0,那么就是永不超時。之前在這里直接寫0，被告知需要傳一個time.Time類型的數據。最終谷歌后才得到了這個值time.Time{}為"0001-01-01 00:00:00 +0000 UTC"。

我們將用戶手法消息的內容定義為一個結構體，然后將用戶的訂閱信息的json通過json.unmarshal轉換成這個結構體。

之后的switch操作與我們在Swoole中的操作基本雷同，在查詢到login之后，調用service中 的login方法來進行注冊。

下一節中我們再介紹具體的注冊邏輯。

go語言聊天室實現（二）gorilla/websocket中的聊天室示例

我們可以看到 gorilla/websocket中的examples中有一個聊天室的demo。

我們進入該項目可以看到里面有這樣的一些內容

按照官方的運行方式來運行這個項目

在瀏覽器中打開8080端口，可以看到該項目可以被成功運行了。

就是這樣一個簡單的demo。

然后我們去看一下它的具體實現。

在這個項目中首先定義了一個hub的結構體：

這個結構體中，clients代表所有已經注冊的用戶，broadcast管道會存儲客戶端發送來的信息。 register是一個*Client類型的管道，用于存儲新注冊的用戶，unregister管道反之。

我們打開main.go，main函數的源碼為：

在這里首先會新開一個goroutine，去跑hub的run方法，run方法中一個死循環，不停地去輪詢hub中的內容

如果取到了新用戶，就加入到clients中，如果取到了信息，就循環所有的client,將信息寫到client.send中。

我們看到在請求路徑為根的時候，它會請求一個函數，而這個函數就是將home.html發送到客戶端。

而在請求路徑為“/ws”的時候，他會執行一個serveWS的函數。

每當一個新的用戶進來之后，首先將連接升級為長連接，然后將當前的client寫到register中，由hub.run函數去做處理。然后開啟兩個goroutine,一個去讀client中發送來的數據，一個將數據寫入到所有的client中，去發送給用戶。

這就是整個聊天室的實現原理。

入門看什么go語言編程和go并發編程實戰

把基本的tutorial 在官網上過一遍。

然后自己寫個telnet的聊天室， 多人none blocking的就可以了。不用和別人學，別人寫的也不一定好。

另外多看看go容易犯的錯誤。

Go語言——goroutine并發模型

參考：

Goroutine并發調度模型深度解析手擼一個協程池

Golang 的 goroutine 是如何實現的？

Golang - 調度剖析【第二部分】

OS線程初始棧為2MB。Go語言中，每個goroutine采用動態擴容方式，初始2KB，按需增長，最大1G。此外GC會收縮棧空間。

BTW，增長擴容都是有代價的，需要copy數據到新的stack，所以初始2KB可能有些性能問題。

更多關于stack的內容，可以參見大佬的文章。 聊一聊goroutine stack

用戶線程的調度以及生命周期管理都是用戶層面，Go語言自己實現的，不借助OS系統調用，減少系統資源消耗。

Go語言采用兩級線程模型，即用戶線程與內核線程KSE（kernel scheduling entity）是M:N的。最終goroutine還是會交給OS線程執行，但是需要一個中介，提供上下文。這就是G-M-P模型

Go調度器有兩個不同的運行隊列：

go1.10\src\runtime\runtime2.go

Go調度器根據事件進行上下文切換。

調度的目的就是防止M堵塞，空閑，系統進程切換。

詳見 Golang - 調度剖析【第二部分】

Linux可以通過epoll實現網絡調用，統稱網絡輪詢器N（Net Poller）。

文件IO操作

上面都是防止M堵塞，任務竊取是防止M空閑

每個M都有一個特殊的G，g0。用于執行調度，gc，棧管理等任務，所以g0的棧稱為調度棧。g0的棧不會自動增長，不會被gc，來自os線程的棧。

go1.10\src\runtime\proc.go

G沒辦法自己運行，必須通過M運行

M通過通過調度，執行G

從M掛載P的runq中找到G，執行G

本文標題：go語言并發聊天,go語言 并發
本文來源：http://vcdvsql.cn/article32/hecopc.html

成都網站建設公司_創新互聯，為您提供網站策劃、微信小程序、品牌網站建設、網站導航、外貿建站、域名注冊

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯