Go里面提供了一個(gè)關(guān)鍵字select，通過(guò)select可以監(jiān)聽(tīng)channel上的數(shù)據(jù)流動(dòng)。
創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括信陽(yáng)網(wǎng)站建設(shè)、信陽(yáng)網(wǎng)站制作、信陽(yáng)網(wǎng)頁(yè)制作以及信陽(yáng)網(wǎng)絡(luò)營(yíng)銷策劃等。多年來(lái)，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，信陽(yáng)網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到信陽(yáng)省份的部分城市，未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
select的用法與switch語(yǔ)言非常類似，由select開(kāi)始一個(gè)新的選擇塊，每個(gè)選擇條件由case語(yǔ)句來(lái)描述。
與switch語(yǔ)句相比， select有比較多的限制，其中最大的一條限制就是每個(gè)case語(yǔ)句里必須是一個(gè)IO操作，大致的結(jié)構(gòu)如下：
在一個(gè)select語(yǔ)句中，Go語(yǔ)言會(huì)按順序從頭至尾評(píng)估每一個(gè)發(fā)送和接收的語(yǔ)句。
如果其中的任意一語(yǔ)句可以繼續(xù)執(zhí)行(即沒(méi)有被阻塞)，那么就從那些可以執(zhí)行的語(yǔ)句中任意選擇一條來(lái)使用。
如果沒(méi)有任意一條語(yǔ)句可以執(zhí)行(即所有的通道都被阻塞)，那么有兩種可能的情況：
如果給出了default語(yǔ)句，那么就會(huì)執(zhí)行default語(yǔ)句，同時(shí)程序的執(zhí)行會(huì)從select語(yǔ)句后的語(yǔ)句中恢復(fù)。
如果沒(méi)有default語(yǔ)句，那么select語(yǔ)句將被阻塞，直到至少有一個(gè)通信可以進(jìn)行下去
有時(shí)候會(huì)出現(xiàn)goroutine阻塞的情況，那么我們?nèi)绾伪苊庹麄€(gè)程序進(jìn)入阻塞的情況呢？我們可以利用select來(lái)設(shè)置超時(shí)，通過(guò)如下的方式實(shí)現(xiàn)：
select總結(jié)：
作用： 用來(lái)監(jiān)聽(tīng) channel 上的數(shù)據(jù)流動(dòng)方向。 讀？寫(xiě)？
select實(shí)現(xiàn)fibonacci數(shù)列：
上一節(jié)中，我們?yōu)槊總€(gè)連接都創(chuàng)建了一個(gè)goroutine來(lái)讀取其中的消息，現(xiàn)在我們將這個(gè)讀取消息的方法實(shí)現(xiàn)一下。
我們?cè)赼pplication目錄下新建controllers目錄，并在其中創(chuàng)建一個(gè)MessageController.go文件。
首先我們新建一個(gè)MessageController的結(jié)構(gòu)體，內(nèi)容如下
這個(gè)結(jié)構(gòu)體包括兩個(gè)內(nèi)容，一個(gè)是我們將連接放在數(shù)組之后，返回的索引，另一個(gè)是連接本身.
這個(gè)是具體的方法。
我們首先設(shè)置了一下讀消息的大小、超時(shí)時(shí)間以及超時(shí)后需要的操作。
超時(shí)時(shí)間如果設(shè)置為0,那么就是永不超時(shí)。之前在這里直接寫(xiě)0，被告知需要傳一個(gè)time.Time類型的數(shù)據(jù)。最終谷歌后才得到了這個(gè)值time.Time{}為"0001-01-01 00:00:00 +0000 UTC"。
我們將用戶手法消息的內(nèi)容定義為一個(gè)結(jié)構(gòu)體，然后將用戶的訂閱信息的json通過(guò)json.unmarshal轉(zhuǎn)換成這個(gè)結(jié)構(gòu)體。
之后的switch操作與我們?cè)赟woole中的操作基本雷同，在查詢到login之后，調(diào)用service中 的login方法來(lái)進(jìn)行注冊(cè)。
下一節(jié)中我們?cè)俳榻B具體的注冊(cè)邏輯。
golang在1.6.2的時(shí)候還沒(méi)有自己的context，在1.7的版本中就把golang.org/x/net/context包被加入到了官方的庫(kù)中。中文譯作“上下文”，它主要包含了goroutine 的運(yùn)行狀態(tài)、環(huán)境等信息。
context 主要用來(lái)在 goroutine 之間傳遞上下文信息，包括：同步信號(hào)、超時(shí)時(shí)間、截止時(shí)間、請(qǐng)求相關(guān)值等。
該接口定義了四個(gè)需要實(shí)現(xiàn)的方法：
如果有個(gè)網(wǎng)絡(luò)請(qǐng)求Request，然后這個(gè)請(qǐng)求又可以開(kāi)啟多個(gè)goroutine做一些事情，當(dāng)這個(gè)網(wǎng)絡(luò)請(qǐng)求出現(xiàn)異常和超時(shí)時(shí)，這個(gè)請(qǐng)求結(jié)束了，這時(shí)候就可以通過(guò)context來(lái)跟蹤這些goroutine，并且通過(guò)Context來(lái)取消他們,然后系統(tǒng)才可回收所占用的資源。
為了更方便的創(chuàng)建Context，包里頭定義了Background來(lái)作為所有Context的根，它是一個(gè)emptyCtx的實(shí)例。
Background返回一個(gè)非空的Context。它永遠(yuǎn)不會(huì)被取消。它通常用來(lái)初始化和測(cè)試使用，作為一個(gè)頂層的context，也就是說(shuō)一般我們創(chuàng)建的context都是基于Background。
TODO返回一個(gè)非空的Context。當(dāng)不清楚要使用哪個(gè)上下文的時(shí)候可以使用TODO。
他們兩個(gè)本質(zhì)上都是emptyCtx結(jié)構(gòu)體類型，是一個(gè)不可取消，沒(méi)有設(shè)置截止時(shí)間，沒(méi)有攜帶任何值的Context。
有了如上的根Context，那么是如何衍生更多的子Context的呢？這就要靠context包為我們提供的With系列的函數(shù)了。
通過(guò)這些函數(shù)，就創(chuàng)建了一顆Context樹(shù)，樹(shù)的每個(gè)節(jié)點(diǎn)都可以有任意多個(gè)子節(jié)點(diǎn)，節(jié)點(diǎn)層級(jí)可以有任意多個(gè)。
WithCancel函數(shù)，最常用的派生 context 方法。該方法接受一個(gè)父 context。父 context 可以是一個(gè) background context 或其他 context。
WithDeadline函數(shù)，該方法會(huì)創(chuàng)建一個(gè)帶有 deadline 的 context。當(dāng) deadline 到期后，該 context 以及該 context 的可能子 context 會(huì)受到 cancel 通知。另外，如果 deadline 前調(diào)用 cancelFunc 則會(huì)提前發(fā)送取消通知。
WithTimeout和WithDeadline基本上一樣，這個(gè)表示是超時(shí)自動(dòng)取消，是多少時(shí)間后自動(dòng)取消Context的意思。
WithValue函數(shù)和取消Context無(wú)關(guān)，它是為了生成一個(gè)綁定了一個(gè)鍵值對(duì)數(shù)據(jù)的Context，這個(gè)綁定的數(shù)據(jù)可以通過(guò)Context.Value方法訪問(wèn)到，一般我們想要通過(guò)上下文來(lái)傳遞數(shù)據(jù)時(shí)，可以通過(guò)這個(gè)方法，如我們需要tarce追蹤系統(tǒng)調(diào)用棧的時(shí)候。
使用Context的程序應(yīng)遵循以下規(guī)則，以使各個(gè)包之間的接口保持一致：
1.不要將 Context 塞到結(jié)構(gòu)體里。直接將 Context 類型作為函數(shù)的第一參數(shù)，而且一般都命名為 ctx。
2.不要向函數(shù)傳入一個(gè) nil 的 context，如果你實(shí)在不知道傳什么，標(biāo)準(zhǔn)庫(kù)給你準(zhǔn)備好了一個(gè) context：todo。
3.不要把本應(yīng)該作為函數(shù)參數(shù)的類型塞到 context 中，context 存儲(chǔ)的應(yīng)該是一些共同的數(shù)據(jù)。例如：登陸的 session、cookie 等。
4.同一個(gè) context 可能會(huì)被傳遞到多個(gè) goroutine，別擔(dān)心，context 是并發(fā)安全的。
1. 介紹
最近在研究一些消息中間件，常用的MQ如RabbitMQ,ActiveMQ,Kafka等。NSQ是一個(gè)基于Go語(yǔ)言的分布式實(shí)時(shí)消息平臺(tái)，它基于MIT開(kāi)源協(xié)議發(fā)布，由bitly公司開(kāi)源出來(lái)的一款簡(jiǎn)單易用的消息中間件。
官方和第三方還為NSQ開(kāi)發(fā)了眾多客戶端功能庫(kù)，如官方提供的基于HTTP的nsqd、Go客戶端go-nsq、Python客戶端pynsq、基于Node.js的JavaScript客戶端nsqjs、異步C客戶端libnsq、Java客戶端nsq-java以及基于各種語(yǔ)言的眾多第三方客戶端功能庫(kù)。
1.1 Features
1). Distributed
NSQ提供了分布式的，去中心化，且沒(méi)有單點(diǎn)故障的拓?fù)浣Y(jié)構(gòu)，穩(wěn)定的消息傳輸發(fā)布保障，能夠具有高容錯(cuò)和HA（高可用）特性。
2). Scalable易于擴(kuò)展
NSQ支持水平擴(kuò)展，沒(méi)有中心化的brokers。內(nèi)置的發(fā)現(xiàn)服務(wù)簡(jiǎn)化了在集群中增加節(jié)點(diǎn)。同時(shí)支持pub-sub和load-balanced 的消息分發(fā)。
3). Ops Friendly
NSQ非常容易配置和部署，生來(lái)就綁定了一個(gè)管理界面。二進(jìn)制包沒(méi)有運(yùn)行時(shí)依賴。官方有Docker image。
4.Integrated高度集成
官方的 Go 和 Python庫(kù)都有提供。而且為大多數(shù)語(yǔ)言提供了庫(kù)。
1.2 組件
1.3 拓?fù)浣Y(jié)構(gòu)
NSQ推薦通過(guò)他們相應(yīng)的nsqd實(shí)例使用協(xié)同定位發(fā)布者，這意味著即使面對(duì)網(wǎng)絡(luò)分區(qū)，消息也會(huì)被保存在本地，直到它們被一個(gè)消費(fèi)者讀取。更重要的是，發(fā)布者不必去發(fā)現(xiàn)其他的nsqd節(jié)點(diǎn)，他們總是可以向本地實(shí)例發(fā)布消息。
NSQ
首先，一個(gè)發(fā)布者向它的本地nsqd發(fā)送消息，要做到這點(diǎn)，首先要先打開(kāi)一個(gè)連接，然后發(fā)送一個(gè)包含topic和消息主體的發(fā)布命令，在這種情況下，我們將消息發(fā)布到事件topic上以分散到我們不同的worker中。
事件topic會(huì)復(fù)制這些消息并且在每一個(gè)連接topic的channel上進(jìn)行排隊(duì)，在我們的案例中，有三個(gè)channel，它們其中之一作為檔案channel。消費(fèi)者會(huì)獲取這些消息并且上傳到S3。
nsqd
每個(gè)channel的消息都會(huì)進(jìn)行排隊(duì)，直到一個(gè)worker把他們消費(fèi)，如果此隊(duì)列超出了內(nèi)存限制，消息將會(huì)被寫(xiě)入到磁盤(pán)中。Nsqd節(jié)點(diǎn)首先會(huì)向nsqlookup廣播他們的位置信息，一旦它們注冊(cè)成功，worker將會(huì)從nsqlookup服務(wù)器節(jié)點(diǎn)上發(fā)現(xiàn)所有包含事件topic的nsqd節(jié)點(diǎn)。
nsqlookupd
2. Internals
2.1 消息傳遞擔(dān)保
1）客戶表示已經(jīng)準(zhǔn)備好接收消息
2）NSQ 發(fā)送一條消息，并暫時(shí)將數(shù)據(jù)存儲(chǔ)在本地（在 re-queue 或 timeout）
3）客戶端回復(fù) FIN（結(jié)束）或 REQ（重新排隊(duì)）分別指示成功或失敗。如果客戶端沒(méi)有回復(fù), NSQ 會(huì)在設(shè)定的時(shí)間超時(shí)，自動(dòng)重新排隊(duì)消息
這確保了消息丟失唯一可能的情況是不正常結(jié)束 nsqd 進(jìn)程。在這種情況下，這是在內(nèi)存中的任何信息（或任何緩沖未刷新到磁盤(pán)）都將丟失。
如何防止消息丟失是最重要的，即使是這個(gè)意外情況可以得到緩解。一種解決方案是構(gòu)成冗余 nsqd對(duì)（在不同的主機(jī)上）接收消息的相同部分的副本。因?yàn)槟銓?shí)現(xiàn)的消費(fèi)者是冪等的，以兩倍時(shí)間處理這些消息不會(huì)對(duì)下游造成影響，并使得系統(tǒng)能夠承受任何單一節(jié)點(diǎn)故障而不會(huì)丟失信息。
2.2 簡(jiǎn)化配置和管理
單個(gè) nsqd 實(shí)例被設(shè)計(jì)成可以同時(shí)處理多個(gè)數(shù)據(jù)流。流被稱為“話題”和話題有 1 個(gè)或多個(gè)“通道”。每個(gè)通道都接收到一個(gè)話題中所有消息的拷貝。在實(shí)踐中，一個(gè)通道映射到下行服務(wù)消費(fèi)一個(gè)話題。
在更底的層面，每個(gè) nsqd 有一個(gè)與 nsqlookupd 的長(zhǎng)期 TCP 連接，定期推動(dòng)其狀態(tài)。這個(gè)數(shù)據(jù)被 nsqlookupd 用于給消費(fèi)者通知 nsqd 地址。對(duì)于消費(fèi)者來(lái)說(shuō)，一個(gè)暴露的 HTTP /lookup 接口用于輪詢。為話題引入一個(gè)新的消費(fèi)者，只需啟動(dòng)一個(gè)配置了 nsqlookup 實(shí)例地址的 NSQ 客戶端。無(wú)需為添加任何新的消費(fèi)者或生產(chǎn)者更改配置，大大降低了開(kāi)銷和復(fù)雜性。
2.3 消除單點(diǎn)故障
NSQ被設(shè)計(jì)以分布的方式被使用。nsqd 客戶端（通過(guò) TCP ）連接到指定話題的所有生產(chǎn)者實(shí)例。沒(méi)有中間人，沒(méi)有消息代理，也沒(méi)有單點(diǎn)故障。
這種拓?fù)浣Y(jié)構(gòu)消除單鏈，聚合，反饋。相反，你的消費(fèi)者直接訪問(wèn)所有生產(chǎn)者。從技術(shù)上講，哪個(gè)客戶端連接到哪個(gè) NSQ 不重要，只要有足夠的消費(fèi)者連接到所有生產(chǎn)者，以滿足大量的消息，保證所有東西最終將被處理。對(duì)于 nsqlookupd，高可用性是通過(guò)運(yùn)行多個(gè)實(shí)例來(lái)實(shí)現(xiàn)。他們不直接相互通信和數(shù)據(jù)被認(rèn)為是最終一致。消費(fèi)者輪詢所有的配置的 nsqlookupd 實(shí)例和合并 response。失敗的，無(wú)法訪問(wèn)的，或以其他方式故障的節(jié)點(diǎn)不會(huì)讓系統(tǒng)陷于停頓。
2.4 效率
對(duì)于數(shù)據(jù)的協(xié)議，通過(guò)推送數(shù)據(jù)到客戶端最大限度地提高性能和吞吐量的，而不是等待客戶端拉數(shù)據(jù)。這個(gè)概念，稱之為 RDY 狀態(tài)，基本上是客戶端流量控制的一種形式。
efficiency
2.5 心跳和超時(shí)
組合應(yīng)用級(jí)別的心跳和 RDY 狀態(tài)，避免頭阻塞現(xiàn)象，也可能使心跳無(wú)用（即，如果消費(fèi)者是在后面的處理消息流的接收緩沖區(qū)中，操作系統(tǒng)將被填滿，堵心跳）為了保證進(jìn)度，所有的網(wǎng)絡(luò) IO 時(shí)間上限勢(shì)必與配置的心跳間隔相關(guān)聯(lián)。這意味著，你可以從字面上拔掉之間的網(wǎng)絡(luò)連接 nsqd 和消費(fèi)者，它會(huì)檢測(cè)并正確處理錯(cuò)誤。當(dāng)檢測(cè)到一個(gè)致命錯(cuò)誤，客戶端連接被強(qiáng)制關(guān)閉。在傳輸中的消息會(huì)超時(shí)而重新排隊(duì)等待傳遞到另一個(gè)消費(fèi)者。最后，錯(cuò)誤會(huì)被記錄并累計(jì)到各種內(nèi)部指標(biāo)。
2.6 分布式
因?yàn)镹SQ沒(méi)有在守護(hù)程序之間共享信息，所以它從一開(kāi)始就是為了分布式操作而生。個(gè)別的機(jī)器可以隨便宕機(jī)隨便啟動(dòng)而不會(huì)影響到系統(tǒng)的其余部分，消息發(fā)布者可以在本地發(fā)布，即使面對(duì)網(wǎng)絡(luò)分區(qū)。
這種“分布式優(yōu)先”的設(shè)計(jì)理念意味著NSQ基本上可以永遠(yuǎn)不斷地?cái)U(kuò)展，需要更高的吞吐量？那就添加更多的nsqd吧。唯一的共享狀態(tài)就是保存在lookup節(jié)點(diǎn)上，甚至它們不需要全局視圖，配置某些nsqd注冊(cè)到某些lookup節(jié)點(diǎn)上這是很簡(jiǎn)單的配置，唯一關(guān)鍵的地方就是消費(fèi)者可以通過(guò)lookup節(jié)點(diǎn)獲取所有完整的節(jié)點(diǎn)集。清晰的故障事件——NSQ在組件內(nèi)建立了一套明確關(guān)于可能導(dǎo)致故障的的故障權(quán)衡機(jī)制，這對(duì)消息傳遞和恢復(fù)都有意義。雖然它們可能不像Kafka系統(tǒng)那樣提供嚴(yán)格的保證級(jí)別，但NSQ簡(jiǎn)單的操作使故障情況非常明顯。
2.7 no replication
不像其他的隊(duì)列組件，NSQ并沒(méi)有提供任何形式的復(fù)制和集群，也正是這點(diǎn)讓它能夠如此簡(jiǎn)單地運(yùn)行，但它確實(shí)對(duì)于一些高保證性高可靠性的消息發(fā)布沒(méi)有足夠的保證。我們可以通過(guò)降低文件同步的時(shí)間來(lái)部分避免，只需通過(guò)一個(gè)標(biāo)志配置，通過(guò)EBS支持我們的隊(duì)列。但是這樣仍然存在一個(gè)消息被發(fā)布后馬上死亡，丟失了有效的寫(xiě)入的情況。
2.8 沒(méi)有嚴(yán)格的順序
雖然Kafka由一個(gè)有序的日志構(gòu)成，但NSQ不是。消息可以在任何時(shí)間以任何順序進(jìn)入隊(duì)列。在我們使用的案例中，這通常沒(méi)有關(guān)系，因?yàn)樗械臄?shù)據(jù)都被加上了時(shí)間戳，但它并不適合需要嚴(yán)格順序的情況。
2.9 無(wú)數(shù)據(jù)重復(fù)刪除功能
NSQ對(duì)于超時(shí)系統(tǒng)，它使用了心跳檢測(cè)機(jī)制去測(cè)試消費(fèi)者是否存活還是死亡。很多原因會(huì)導(dǎo)致我們的consumer無(wú)法完成心跳檢測(cè)，所以在consumer中必須有一個(gè)單獨(dú)的步驟確保冪等性。
3. 實(shí)踐安裝過(guò)程
本文將nsq集群具體的安裝過(guò)程略去，大家可以自行參考官網(wǎng)，比較簡(jiǎn)單。這部分介紹下筆者實(shí)驗(yàn)的拓?fù)?，以及nsqadmin的相關(guān)信息。
3.1 拓?fù)浣Y(jié)構(gòu)
topology
實(shí)驗(yàn)采用3臺(tái)NSQD服務(wù)，2臺(tái)LOOKUPD服務(wù)。
采用官方推薦的拓?fù)洌l(fā)布的服務(wù)和NSQD在一臺(tái)主機(jī)。一共5臺(tái)機(jī)器。
NSQ基本沒(méi)有配置文件，配置通過(guò)命令行指定參數(shù)。
主要命令如下:
LOOKUPD命令
NSQD命令
工具類，消費(fèi)后存儲(chǔ)到本地文件。
發(fā)布一條消息
3.2 nsqadmin
對(duì)Streams的詳細(xì)信息進(jìn)行查看，包括NSQD節(jié)點(diǎn)，具體的channel，隊(duì)列中的消息數(shù)，連接數(shù)等信息。
nsqadmin
channel
列出所有的NSQD節(jié)點(diǎn):
nodes
消息的統(tǒng)計(jì):
msgs
lookup主機(jī)的列表:
hosts
4. 總結(jié)
NSQ基本核心就是簡(jiǎn)單性，是一個(gè)簡(jiǎn)單的隊(duì)列，這意味著它很容易進(jìn)行故障推理和很容易發(fā)現(xiàn)bug。消費(fèi)者可以自行處理故障事件而不會(huì)影響系統(tǒng)剩下的其余部分。
事實(shí)上，簡(jiǎn)單性是我們決定使用NSQ的首要因素，這方便與我們的許多其他軟件一起維護(hù)，通過(guò)引入隊(duì)列使我們得到了堪稱完美的表現(xiàn)，通過(guò)隊(duì)列甚至讓我們?cè)黾恿藥讉€(gè)數(shù)量級(jí)的吞吐量。越來(lái)越多的consumer需要一套嚴(yán)格可靠性和順序性保障，這已經(jīng)超過(guò)了NSQ提供的簡(jiǎn)單功能。
結(jié)合我們的業(yè)務(wù)系統(tǒng)來(lái)看，對(duì)于我們所需要傳輸?shù)陌l(fā)票消息，相對(duì)比較敏感，無(wú)法容忍某個(gè)nsqd宕機(jī)，或者磁盤(pán)無(wú)法使用的情況，該節(jié)點(diǎn)堆積的消息無(wú)法找回。這是我們沒(méi)有選擇該消息中間件的主要原因。簡(jiǎn)單性和可靠性似乎并不能完全滿足。相比Kafka，ops肩負(fù)起更多負(fù)責(zé)的運(yùn)營(yíng)。另一方面，它擁有一個(gè)可復(fù)制的、有序的日志可以提供給我們更好的服務(wù)。但對(duì)于其他適合NSQ的consumer，它為我們服務(wù)的相當(dāng)好，我們期待著繼續(xù)鞏固它的堅(jiān)實(shí)的基礎(chǔ)。
為什么需要context
在go服務(wù)器中，對(duì)于每個(gè)請(qǐng)求的request都是在單獨(dú)的goroutine中進(jìn)行的，處理一個(gè)request也可能設(shè)計(jì)多個(gè)goroutine之間的交互， 使用context可以使開(kāi)發(fā)者方便的在這些goroutine里傳遞request相關(guān)的數(shù)據(jù)、取消goroutine的signal或截止日期
在并發(fā)程序中，由于超時(shí)、取消操作或者一些異常情況，往往需要進(jìn)行搶占操作或者中斷后續(xù)操作。熟悉channel的朋友應(yīng)該都見(jiàn)過(guò)使用done channel來(lái)處理此類問(wèn)題。比如以下這個(gè)例子：
上述例子中定義了一個(gè)buffer為0的channel done, 子協(xié)程運(yùn)行著定時(shí)任務(wù)。如果主協(xié)程需要在某個(gè)時(shí)刻發(fā)送消息通知子協(xié)程中斷任務(wù)退出，那么就可以讓子協(xié)程監(jiān)聽(tīng)這個(gè)done channel，一旦主協(xié)程關(guān)閉done channel，那么子協(xié)程就可以推出了，這樣就實(shí)現(xiàn)了主協(xié)程通知子協(xié)程的需求。這很好，但是這也是有限的。
如果我們可以在簡(jiǎn)單的通知上附加傳遞額外的信息來(lái)控制取消：為什么取消，或者有一個(gè)它必須要完成的最終期限，更或者有多個(gè)取消選項(xiàng)，我們需要根據(jù)額外的信息來(lái)判斷選擇執(zhí)行哪個(gè)取消選項(xiàng)。
考慮下面這種情況：假如主協(xié)程中有多個(gè)任務(wù)1, 2, …m，主協(xié)程對(duì)這些任務(wù)有超時(shí)控制；而其中任務(wù)1又有多個(gè)子任務(wù)1, 2, …n，任務(wù)1對(duì)這些子任務(wù)也有自己的超時(shí)控制，那么這些子任務(wù)既要感知主協(xié)程的取消信號(hào)，也需要感知任務(wù)1的取消信號(hào)。
如果還是使用done channel的用法，我們需要定義兩個(gè)done channel，子任務(wù)們需要同時(shí)監(jiān)聽(tīng)這兩個(gè)done channel。嗯，這樣其實(shí)好像也還行哈。但是如果層級(jí)更深，如果這些子任務(wù)還有子任務(wù)，那么使用done channel的方式將會(huì)變得非常繁瑣且混亂。
我們需要一種優(yōu)雅的方案來(lái)實(shí)現(xiàn)這樣一種機(jī)制：
上層任務(wù)取消后，所有的下層任務(wù)都會(huì)被取消；中間某一層的任務(wù)取消后，只會(huì)將當(dāng)前任務(wù)的下層任務(wù)取消，而不會(huì)影響上層的任務(wù)以及同級(jí)任務(wù)。
這個(gè)時(shí)候context就派上用場(chǎng)了。我們首先看看context的結(jié)構(gòu)設(shè)計(jì)和實(shí)現(xiàn)原理。
context接口
先看Context接口結(jié)構(gòu)，看起來(lái)非常簡(jiǎn)單。
}
Context接口包含四個(gè)方法：
Deadline返回綁定當(dāng)前context的任務(wù)被取消的截止時(shí)間；如果沒(méi)有設(shè)定期限，將返回ok == false。
Done 當(dāng)綁定當(dāng)前context的任務(wù)被取消時(shí)，將返回一個(gè)關(guān)閉的channel；如果當(dāng)前context不會(huì)被取消，將返回nil。
Err 如果Done返回的channel沒(méi)有關(guān)閉，將返回nil;如果Done返回的channel已經(jīng)關(guān)閉，將返回非空的值表示任務(wù)結(jié)束的原因。如果是context被取消，Err將返回Canceled；如果是context超時(shí)，Err將返回DeadlineExceeded。
Value 返回context存儲(chǔ)的鍵值對(duì)中當(dāng)前key對(duì)應(yīng)的值，如果沒(méi)有對(duì)應(yīng)的key,則返回nil。
可以看到Done方法返回的channel正是用來(lái)傳遞結(jié)束信號(hào)以搶占并中斷當(dāng)前任務(wù)；Deadline方法指示一段時(shí)間后當(dāng)前goroutine是否會(huì)被取消；以及一個(gè)Err方法，來(lái)解釋goroutine被取消的原因；而Value則用于獲取特定于當(dāng)前任務(wù)樹(shù)的額外信息。而context所包含的額外信息鍵值對(duì)是如何存儲(chǔ)的呢？其實(shí)可以想象一顆樹(shù)，樹(shù)的每個(gè)節(jié)點(diǎn)可能攜帶一組鍵值對(duì),如果當(dāng)前節(jié)點(diǎn)上無(wú)法找到key所對(duì)應(yīng)的值，就會(huì)向上去父節(jié)點(diǎn)里找，直到根節(jié)點(diǎn)。
emptyCtx
emptyCtx是一個(gè)int類型的變量，但實(shí)現(xiàn)了context的接口。emptyCtx沒(méi)有超時(shí)時(shí)間，不能取消，也不能存儲(chǔ)任何額外信息，所以emptyCtx用來(lái)作為context樹(shù)的根節(jié)點(diǎn)。
Background和TODO只是用于不同場(chǎng)景下： Background通常被用于主函數(shù)、初始化以及測(cè)試中，作為一個(gè)頂層的context，也就是說(shuō)一般我們創(chuàng)建的context都是基于Background；而TODO是在不確定使用什么context的時(shí)候才會(huì)使用。
用法 ：
重慶分公司
重慶分公司
