Golang使用redis阻塞讀brpop實(shí)現(xiàn)即時(shí)響應(yīng)并發(fā)執(zhí)行

主要利用redis的brpop阻塞讀和Golang的goroutine并發(fā)控制以及os/exec執(zhí)行程序，實(shí)現(xiàn)隊(duì)列有數(shù)據(jù)就立即執(zhí)行對(duì)應(yīng)程序并把結(jié)果set任務(wù)key。

創(chuàng)新互聯(lián)公司專注于企業(yè)營(yíng)銷型網(wǎng)站建設(shè)、網(wǎng)站重做改版、黃陵網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5高端網(wǎng)站建設(shè)、成都做商城網(wǎng)站、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)營(yíng)銷網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁(yè)設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為黃陵等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

go語(yǔ)言中的tcpconn是阻塞還是非阻塞的

阻塞socket和非阻塞socket的區(qū)別： 1、讀操作 對(duì)于阻塞的socket,當(dāng)socket的接收緩沖區(qū)中沒有數(shù)據(jù)時(shí)，read調(diào)用會(huì)一直阻塞住，直到有數(shù)據(jù)到來才返回。當(dāng)socket緩沖區(qū)中的數(shù)據(jù)量小于期望讀取的數(shù)據(jù)量時(shí)，返回實(shí)際讀取的字節(jié)數(shù)。

Go語(yǔ)言的特點(diǎn)

類型 在變量名后邊

也可不顯式聲明類型, 類型推斷, 但是是靜態(tài)語(yǔ)言, name一開始放字符串就不能再賦值數(shù)字

方法,屬性 分開 方法名首字母大寫就是就是外部可調(diào)的

面向?qū)ο笤O(shè)計(jì)的一個(gè)重要原則：“優(yōu)先使用組合而不是繼承”

Dog 也是Animal , 要復(fù)用Animal 的屬性和方法,

只需要在結(jié)構(gòu)體 type 里面寫 Animal

入口也是main, 用用試試

多態(tài), 有這個(gè)方法就是這個(gè)接口的實(shí)現(xiàn), 具體的類 不需要知道自己實(shí)現(xiàn)了什么接口,

使用: 在一個(gè)函數(shù)調(diào)用之前加上關(guān)鍵字go 就啟動(dòng)了一個(gè)goroutine

創(chuàng)建一個(gè)goroutine,它會(huì)被加入到一個(gè)全局的運(yùn)行隊(duì)列當(dāng)中，

調(diào)度器 會(huì)把他們分配給某個(gè) 邏輯處理器 的隊(duì)列，

一個(gè)邏輯處理器 綁定到一個(gè) 操作系統(tǒng)線程 ，在上面運(yùn)行g(shù)oroutine，

如果goroutine需要讀寫文件, 阻塞 ,就脫離邏輯處理器 直接 goroutine - 系統(tǒng)線程 綁定

編譯成同名.exe 來執(zhí)行, 不通過虛擬機(jī), 直接是機(jī)器碼, 和C 一樣, 所以非?？?/p>

但是也有自動(dòng)垃圾回收,每個(gè)exe文件當(dāng)中已經(jīng)包含了一個(gè)類似于虛擬機(jī)的runtime,進(jìn)行g(shù)oroutine的調(diào)度

默認(rèn)是靜態(tài)鏈接的，那個(gè)exe會(huì)把運(yùn)行時(shí)所需要的所有東西都加進(jìn)去，這樣就可以把exe復(fù)制到任何地方去運(yùn)行了, 因此 生成的 .exe 文件非常大

Go 語(yǔ)言 channel 的阻塞問題

Hello，大家好，又見面了！上一遍我們將 channel 相關(guān)基礎(chǔ)以及使用場(chǎng)景。這一篇，還需要再次進(jìn)階理解channel 阻塞問題。以下創(chuàng)建一個(gè)chan類型為int，cap 為3。

channel 內(nèi)部其實(shí)是一個(gè)環(huán)形buf數(shù)據(jù)結(jié)構(gòu) ，是一種滑動(dòng)窗口機(jī)制，當(dāng)make完后，就分配在 Heap 上。

上面，向 chan 發(fā)送一條“hello”數(shù)據(jù)：

如果 G1 發(fā)送數(shù)據(jù)超過指定cap時(shí)，會(huì)出現(xiàn)什么情況？

看下面實(shí)例：

以上會(huì)出現(xiàn)什么，chan 緩沖區(qū)允許大小為1，如果再往chan仍數(shù)據(jù)，滿了就會(huì)被阻塞，那么是如何實(shí)現(xiàn)阻塞的呢？當(dāng) chan 滿時(shí)，會(huì)進(jìn)入 gopark，此時(shí) G1 進(jìn)入一個(gè) waiting 狀態(tài)，然后會(huì)創(chuàng)建一個(gè) sudog 對(duì)象，其實(shí)就sendq隊(duì)列，把 200放進(jìn)去。等 buf 不滿的時(shí)候，再喚醒放入buf里面。

通過如下源碼，你會(huì)更加清晰：

上面，從 chan 獲取數(shù)據(jù)：

Go 語(yǔ)言核心思想：“Do not communicate by sharing memory; instead, share memory by communicating.” 你可以看看這本書名叫：Effective Go

如果接收者，接收一個(gè)空對(duì)象，也會(huì)發(fā)生什么情況？

代碼示例 ：

也會(huì)報(bào)錯(cuò)如下：

上面，從 chan 取出數(shù)據(jù)，可是沒有數(shù)據(jù)了。此時(shí)，它會(huì)把 接收者 G2 阻塞掉，也是和G1發(fā)送者一樣，也會(huì)執(zhí)行 gopark 將狀態(tài)改為 waiting，不一樣的點(diǎn)就是。

正常情況下，接收者G2作為取出數(shù)據(jù)是去 buf 讀取數(shù)據(jù)的，但現(xiàn)在，buf 為空了，此時(shí)，接收者G2會(huì)將sudog導(dǎo)出來，因?yàn)楝F(xiàn)在G2已經(jīng)被阻塞了嘛，會(huì)把G2給G，然后將 t := -ch 中變量 t 是在棧上的地址，放進(jìn)去 elem ，也就是說，只存它的地址指針在sudog里面。

最后， ch - 200 當(dāng)G1往 chan 添加200這個(gè)數(shù)據(jù)，正常情況是將數(shù)據(jù)添加到buf里面，然后喚醒 G2 是吧，而現(xiàn)在是將 G1 的添加200數(shù)據(jù)直接干到剛才G2阻塞的t這里變量里面。

你會(huì)認(rèn)為，這樣真的可以嗎？想一想，G2 本來就是已經(jīng)阻塞了，然后我們直接這么干肯定沒有什么毛病，而且效率提高了，不需要再次放入buf再取出，這個(gè)過程也是需要時(shí)間。不然，不得往chan添加數(shù)據(jù)需要加鎖、拷貝、解鎖一序列操作，那肯定就慢了，我想Go語(yǔ)言是為了高效及內(nèi)存使用率的考慮這樣設(shè)計(jì)的。（注意，一般都是在runtime里面完成，不然會(huì)出現(xiàn)象安全問題。）

總結(jié) ：

chan 類型的特點(diǎn)：chan 如果為空，receiver 接收數(shù)據(jù)的時(shí)候就會(huì)阻塞等待，直到 chan 被關(guān)閉或者有新的數(shù)據(jù)到來。有這種個(gè)機(jī)制，就可以實(shí)現(xiàn) wait/notify 的設(shè)計(jì)模式。

相關(guān)面試題：