go語言循環(huán)隊列的實現(xiàn)

隊列的概念在 順序隊列 中，而使用循環(huán)隊列的目的主要是規(guī)避假溢出造成的空間浪費，在使用循環(huán)隊列處理假溢出時，主要有三種解決方案

創(chuàng)新互聯(lián)公司成立于2013年，是專業(yè)互聯(lián)網(wǎng)技術服務公司，擁有項目網(wǎng)站制作、成都網(wǎng)站設計網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元臨湘做網(wǎng)站,已為上家服務,為臨湘各地企業(yè)和個人服務,聯(lián)系電話:028-86922220

本文提供后兩種解決方案。

順序隊和循環(huán)隊列是一種特殊的線性表，與順序棧類似，都是使用一組地址連續(xù)的存儲單元依次存放自隊頭到隊尾的數(shù)據(jù)元素，同時附設隊頭(front)和隊尾(rear)兩個指針，但我們要明白一點，這個指針并不是指針變量，而是用來表示數(shù)組當中元素下標的位置。

本文使用切片來完成的循環(huán)隊列，由于一開始使用三個參數(shù)的make關鍵字創(chuàng)建切片，在輸出的結果中不包含nil值(看起來很舒服)，而且在驗證的過程中發(fā)現(xiàn)使用append()函數(shù)時切片內置的cap會發(fā)生變化，在消除了種種障礙后得到了一個四不像的循環(huán)隊列，即設置的指針是順序隊列的指針，但實際上進行的操作是順序隊列的操作。最后是對make()函數(shù)和append()函數(shù)的一些使用體驗和小結，隊列的應用放在鏈隊好了。

官方描述(片段)

即切片是一個抽象層，底層是對數(shù)組的引用。

當我們使用

構建出來的切片的每個位置的值都被賦為interface類型的初始值nil，但是nil值也是有大小的。

而使用

來進行初始化時，雖然生成的切片中不包含nil值，但是無法通過設置的指針變量來完成入隊和出隊的操作，只能使用append()函數(shù)來進行操作

在go語言中，切片是一片連續(xù)的內存空間加上長度與容量的標識，比數(shù)組更為常用。使用 append 關鍵字向切片中追加元素也是常見的切片操作

正是基于此，在使用go語言完成循環(huán)隊列時，首先想到的就是使用make(type, len, cap)關鍵字方式完成切片初始化，然后使用append()函數(shù)來操作該切片，但這一方式出現(xiàn)了很多問題。在使用append()函數(shù)時，切片的cap可能會發(fā)生變化，用不好就會發(fā)生擴容或收縮。最終造成的結果是一個四不像的結果，入隊和出隊操作變得與指針變量無關，失去了作為循環(huán)隊列的意義，用在順序隊列還算合適。

參考博客：

Go語言中的Nil

Golang之nil

Go 語言設計與實現(xiàn)

go語言聊天室實現(xiàn)（七）websocket收消息設置

上一節(jié)中，我們?yōu)槊總€連接都創(chuàng)建了一個goroutine來讀取其中的消息，現(xiàn)在我們將這個讀取消息的方法實現(xiàn)一下。

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

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

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

這個是具體的方法。

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

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

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

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

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

go語言聊天室實現(xiàn)（二）gorilla/websocket中的聊天室示例

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

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

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

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

就是這樣一個簡單的demo。

然后我們去看一下它的具體實現(xiàn)。

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

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

我們打開main.go，main函數(shù)的源碼為：

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

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

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

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

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

這就是整個聊天室的實現(xiàn)原理。

go語言實現(xiàn)一個簡單的簡單網(wǎng)關

網(wǎng)關=反向代理+負載均衡+各種策略，技術實現(xiàn)也有多種多樣，有基于 nginx 使用 lua 的實現(xiàn)，比如 openresty、kong；也有基于 zuul 的通用網(wǎng)關；還有就是 golang 的網(wǎng)關，比如 tyk。

這篇文章主要是講如何基于 golang 實現(xiàn)一個簡單的網(wǎng)關。

轉自： troy.wang/docs/golang/posts/golang-gateway/

整理：go語言鐘文文檔:

啟動兩個后端 web 服務（代碼）

這里使用命令行工具進行測試

具體代碼

直接使用基礎庫 httputil 提供的NewSingleHostReverseProxy即可，返回的reverseProxy對象實現(xiàn)了serveHttp方法，因此可以直接作為 handler。

具體代碼

director中定義回調函數(shù)，入?yún)?http.Request，決定如何構造向后端的請求，比如 host 是否向后傳遞，是否進行 url 重寫，對于 header 的處理，后端 target 的選擇等，都可以在這里完成。

director在這里具體做了：

modifyResponse中定義回調函數(shù)，入?yún)?http.Response，用于修改響應的信息，比如響應的 Body，響應的 Header 等信息。

最終依舊是返回一個ReverseProxy，然后將這個對象作為 handler 傳入即可。

參考 2.2 中的NewSingleHostReverseProxy，只需要實現(xiàn)一個類似的、支持多 targets 的方法即可，具體實現(xiàn)見后面。

作為一個網(wǎng)關服務，在上面 2.3 的基礎上，需要支持必要的負載均衡策略，比如：

隨便 random 一個整數(shù)作為索引，然后取對應的地址即可，實現(xiàn)比較簡單。

具體代碼

使用curIndex進行累加計數(shù)，一旦超過 rss 數(shù)組的長度，則重置。

具體代碼

輪詢帶權重，如果使用計數(shù)遞減的方式，如果權重是5,1,1那么后端 rs 依次為a,a,a,a,a,b,c,a,a,a,a…，其中 a 后端會瞬間壓力過大；參考 nginx 內部的加權輪詢，或者應該稱之為平滑加權輪詢，思路是：

后端真實節(jié)點包含三個權重：

操作步驟：

具體代碼

一致性 hash 算法，主要是用于分布式 cache 熱點/命中問題；這里用于基于某 key 的 hash 值，路由到固定后端，但是只能是基本滿足流量綁定，一旦后端目標節(jié)點故障，會自動平移到環(huán)上最近的那么個節(jié)點。

實現(xiàn)：

具體代碼

每一種不同的負載均衡算法，只需要實現(xiàn)添加以及獲取的接口即可。

然后使用工廠方法，根據(jù)傳入的參數(shù)，決定使用哪種負載均衡策略。

具體代碼

作為網(wǎng)關，中間件必不可少，這類包括請求響應的模式，一般稱作洋蔥模式，每一層都是中間件，一層層進去，然后一層層出來。

中間件的實現(xiàn)一般有兩種，一種是使用數(shù)組，然后配合 index 計數(shù)；一種是鏈式調用。

具體代碼

Go語言設計與實現(xiàn)（上）

基本設計思路：

類型轉換、類型斷言、動態(tài)派發(fā)。iface，eface。

反射對象具有的方法：

編譯優(yōu)化：

內部實現(xiàn)：

實現(xiàn) Context 接口有以下幾個類型（空實現(xiàn)就忽略了）：

互斥鎖的控制邏輯：

設計思路：

（以上為寫被讀阻塞，下面是讀被寫阻塞）

總結，讀寫鎖的設計還是非常巧妙的：

設計思路：

WaitGroup 有三個暴露的函數(shù):

部件：

設計思路：

結構：

Once 只暴露了一個方法：

實現(xiàn)：

三個關鍵點：

細節(jié)：

讓多協(xié)程任務的開始執(zhí)行時間可控（按順序或歸一）。（Context 是控制結束時間）

設計思路： 通過一個鎖和內置的 notifyList 隊列實現(xiàn)，Wait() 會生成票據(jù)，并將等待協(xié)程信息加入鏈表中，等待控制協(xié)程中發(fā)送信號通知一個（Signal()）或所有（Boardcast()）等待者（內部實現(xiàn)是通過票據(jù)通知的）來控制協(xié)程解除阻塞。

暴露四個函數(shù)：

實現(xiàn)細節(jié)：

部件：

包： golang.org/x/sync/errgroup

作用：開啟 func() error 函數(shù)簽名的協(xié)程，在同 Group 下協(xié)程并發(fā)執(zhí)行過程并收集首次 err 錯誤。通過 Context 的傳入，還可以控制在首次 err 出現(xiàn)時就終止組內各協(xié)程。

設計思路：

結構：

暴露的方法：

實現(xiàn)細節(jié)：

注意問題：

包： "golang.org/x/sync/semaphore"

作用：排隊借資源（如錢，有借有還）的一種場景。此包相當于對底層信號量的一種暴露。

設計思路：有一定數(shù)量的資源 Weight，每一個 waiter 攜帶一個 channel 和要借的數(shù)量 n。通過隊列排隊執(zhí)行借貸。

結構：

暴露方法：

細節(jié)：

部件：

細節(jié)：

包： "golang.org/x/sync/singleflight"

作用：防擊穿。瞬時的相同請求只調用一次，response 被所有相同請求共享。

設計思路：按請求的 key 分組（一個 *call 是一個組，用 map 映射存儲組），每個組只進行一次訪問，組內每個協(xié)程會獲得對應結果的一個拷貝。

結構：

邏輯：

細節(jié)：

部件：

如有錯誤，請批評指正。

go語言聊天室實現(xiàn)（六）創(chuàng)建HTTP連接，并升級為長連接

我們在mian函數(shù)中，首先初始化配置文件，然后新建http連接。

這個連接創(chuàng)建之后，監(jiān)聽服務器的9999端口。如果url的路徑后綴為 "/ws",就轉發(fā)到ws/ws.go中的IndexHandler方法中。

這個方法中首先我們創(chuàng)建一個websocket的Upgrader實例，然后我們使用Upgrader的upgrade方法來升級一下我們的連接為長連接。

升級完成之后會返回一個*websocket.Conn的連接，我們之后所有的關于連接的操作，都是基于該conn的。

在該連接完成之后，我們將連接存放到一個名為Client的map中，以便之后管理更為方便。

之后，我們啟動一個goroutine來讀取連接中發(fā)送的信息內容，再根據(jù)內容進行相應的操作。

當前文章：go語言方法實現(xiàn),go語言 函數(shù)
網(wǎng)站地址：http://jinyejixie.com/article0/hsisio.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供App開發(fā)、品牌網(wǎng)站建設、響應式網(wǎng)站、靜態(tài)網(wǎng)站、電子商務、網(wǎng)站建設

廣告

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