重慶分公司,新征程啟航
為企業提供網站建設、域名注冊、服務器等服務
為企業提供網站建設、域名注冊、服務器等服務
Go語言由Google公司開發,并于2009年開源,相比Java/Python/C等語言,Go尤其擅長并發編程,性能堪比C語言,開發效率肩比Python,被譽為“21世紀的C語言”。
孫吳網站建設公司創新互聯,孫吳網站設計制作,有大型網站制作公司豐富經驗。已為孫吳上1000家提供企業網站建設服務。企業網站搭建\成都外貿網站建設公司要多少錢,請找那個售后服務好的孫吳做網站的公司定做!
Go語言在云計算、大數據、微服務、高并發領域應用應用非常廣泛。BAT大廠正在把Go作為新項目開發的首選語言。
Go語言能干什么?
1、服務端開發:以前你使用C或者C++做的那些事情,用Go來做很合適,例如日志處理、文件系統、監控系統等;
2、DevOps:運維生態中的Docker、K8s、prometheus、grafana、open-falcon等都是使用Go語言開發;
3、網絡編程:大量優秀的Web框架如Echo、Gin、Iris、beego等,而且Go內置的 net/http包十分的優秀;
4、Paas云平臺領域:Kubernetes和Docker Swarm等;
5、分布式存儲領域:etcd、Groupcache、TiDB、Cockroachdb、Influxdb等;
6、區塊鏈領域:區塊鏈里面有兩個明星項目以太坊和fabric都使用Go語言;
7、容器虛擬化:大名鼎鼎的Docker就是使用Go語言實現的;
8、爬蟲及大數據:Go語言天生支持并發,所以十分適合編寫分布式爬蟲及大數據處理。
我們在mian函數中,首先初始化配置文件,然后新建http連接。
這個連接創建之后,監聽服務器的9999端口。如果url的路徑后綴為 "/ws",就轉發到ws/ws.go中的IndexHandler方法中。
這個方法中首先我們創建一個websocket的Upgrader實例,然后我們使用Upgrader的upgrade方法來升級一下我們的連接為長連接。
升級完成之后會返回一個*websocket.Conn的連接,我們之后所有的關于連接的操作,都是基于該conn的。
在該連接完成之后,我們將連接存放到一個名為Client的map中,以便之后管理更為方便。
之后,我們啟動一個goroutine來讀取連接中發送的信息內容,再根據內容進行相應的操作。
基本設計思路:
類型轉換、類型斷言、動態派發。iface,eface。
反射對象具有的方法:
編譯優化:
內部實現:
實現 Context 接口有以下幾個類型(空實現就忽略了):
互斥鎖的控制邏輯:
設計思路:
(以上為寫被讀阻塞,下面是讀被寫阻塞)
總結,讀寫鎖的設計還是非常巧妙的:
設計思路:
WaitGroup 有三個暴露的函數:
部件:
設計思路:
結構:
Once 只暴露了一個方法:
實現:
三個關鍵點:
細節:
讓多協程任務的開始執行時間可控(按順序或歸一)。(Context 是控制結束時間)
設計思路: 通過一個鎖和內置的 notifyList 隊列實現,Wait() 會生成票據,并將等待協程信息加入鏈表中,等待控制協程中發送信號通知一個(Signal())或所有(Boardcast())等待者(內部實現是通過票據通知的)來控制協程解除阻塞。
暴露四個函數:
實現細節:
部件:
包: golang.org/x/sync/errgroup
作用:開啟 func() error 函數簽名的協程,在同 Group 下協程并發執行過程并收集首次 err 錯誤。通過 Context 的傳入,還可以控制在首次 err 出現時就終止組內各協程。
設計思路:
結構:
暴露的方法:
實現細節:
注意問題:
包: "golang.org/x/sync/semaphore"
作用:排隊借資源(如錢,有借有還)的一種場景。此包相當于對底層信號量的一種暴露。
設計思路:有一定數量的資源 Weight,每一個 waiter 攜帶一個 channel 和要借的數量 n。通過隊列排隊執行借貸。
結構:
暴露方法:
細節:
部件:
細節:
包: "golang.org/x/sync/singleflight"
作用:防擊穿。瞬時的相同請求只調用一次,response 被所有相同請求共享。
設計思路:按請求的 key 分組(一個 *call 是一個組,用 map 映射存儲組),每個組只進行一次訪問,組內每個協程會獲得對應結果的一個拷貝。
結構:
邏輯:
細節:
部件:
如有錯誤,請批評指正。
本文介紹一些Go語言的基礎語法。
先來看一個簡單的go語言代碼:
go語言的注釋方法:
代碼執行結果:
下面來進一步介紹go的基礎語法。
go語言中格式化輸出可以使用 fmt 和 log 這兩個標準庫,
常用方法:
示例代碼:
執行結果:
更多格式化方法可以訪問中的fmt包。
log包實現了簡單的日志服務,也提供了一些格式化輸出的方法。
執行結果:
下面來介紹一下go的數據類型
下表列出了go語言的數據類型:
int、float、bool、string、數組和struct屬于值類型,這些類型的變量直接指向存在內存中的值;slice、map、chan、pointer等是引用類型,存儲的是一個地址,這個地址存儲最終的值。
常量是在程序編譯時就確定下來的值,程序運行時無法改變。
執行結果:
執行結果:
Go 語言的運算符主要包括算術運算符、關系運算符、邏輯運算符、位運算符、賦值運算符以及指針相關運算符。
算術運算符:
關系運算符:
邏輯運算符:
位運算符:
賦值運算符:
指針相關運算符:
下面介紹一下go語言中的if語句和switch語句。另外還有一種控制語句叫select語句,通常與通道聯用,這里不做介紹。
if語法格式如下:
if ... else :
else if:
示例代碼:
語法格式:
另外,添加 fallthrough 會強制執行后面的 case 語句,不管下一條case語句是否為true。
示例代碼:
執行結果:
下面介紹幾種循環語句:
執行結果:
執行結果:
也可以通過標記退出循環:
--THE END--
上一節中,我們為每個連接都創建了一個goroutine來讀取其中的消息,現在我們將這個讀取消息的方法實現一下。
我們在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方法來進行注冊。
下一節中我們再介紹具體的注冊邏輯。
我們可以看到 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中,去發送給用戶。
這就是整個聊天室的實現原理。