很多朋友可能知道Go語言的優(yōu)勢在哪，卻不知道Go語言適合用于哪些地方。
創(chuàng)新互聯(lián)-云計(jì)算及IDC服務(wù)提供商，涵蓋公有云、IDC機(jī)房租用、西部信息機(jī)房、等保安全、私有云建設(shè)等企業(yè)級(jí)互聯(lián)網(wǎng)基礎(chǔ)服務(wù)，聯(lián)系電話：18980820575
1、 Go語言作為服務(wù)器編程語言，很適合處理日志、數(shù)據(jù)打包、虛擬機(jī)處理、文件系統(tǒng)、分布式系統(tǒng)、數(shù)據(jù)庫代理等；網(wǎng)絡(luò)編程方面。Go語言廣泛應(yīng)用于Web應(yīng)用、API應(yīng)用、下載應(yīng)用等；除此之外，Go語言還可用于內(nèi)存數(shù)據(jù)庫和云平臺(tái)領(lǐng)域，目前國外很多云平臺(tái)都是采用Go開發(fā)。
2、 其實(shí)Go語言主要用作服務(wù)器端開發(fā)。其定位是用來開發(fā)"大型軟件"的，適合于很多程序員一起開發(fā)大型軟件，并且開發(fā)周期長，支持云計(jì)算的網(wǎng)絡(luò)服務(wù)。Go語言能夠讓程序員快速開發(fā)，并且在軟件不斷的增長過程中，它能讓程序員更容易地進(jìn)行維護(hù)和修改。它融合了傳統(tǒng)編譯型語言的高效性和腳本語言的易用性和富于表達(dá)性。
3、 Go語言成功案例。Nsq：Nsq是由Go語言開發(fā)的高性能、高可用消息隊(duì)列系統(tǒng)，性能非常高，每天能處理數(shù)十億條的消息；
4、 Docker：基于lxc的一個(gè)虛擬打包工具，能夠?qū)崿F(xiàn)PAAS平臺(tái)的組建。
5、 Packer：用來生成不同平臺(tái)的鏡像文件，例如VM、vbox、AWS等，作者是vagrant的作者
6、 Skynet：分布式調(diào)度框架。
7、 Doozer：分布式同步工具，類似ZooKeeper。
8、 Heka：mazila開源的日志處理系統(tǒng)。
9、 Cbfs：couchbase開源的分布式文件系統(tǒng)。
10、 Tsuru：開源的PAAS平臺(tái)，和SAE實(shí)現(xiàn)的功能一模一樣。
11、 Groupcache：memcahe作者寫的用于Google下載系統(tǒng)的緩存系統(tǒng)。
12、 God：類似redis的緩存系統(tǒng)，但是支持分布式和擴(kuò)展性。
13、 Gor：網(wǎng)絡(luò)流量抓包和重放工具。
以上的就是關(guān)于go語言能做什么的內(nèi)容介紹了。
golangchannel和mq的區(qū)別
我是一個(gè)著迷于產(chǎn)品和運(yùn)營的技術(shù)人，樂于跨界的終身學(xué)習(xí)者。歡迎關(guān)注我喲～
每周五12點(diǎn) 按時(shí)送達(dá)～
我的第「218」篇原創(chuàng)敬上
大家好，我是Z哥。
最近在項(xiàng)目中遇到了一個(gè)使用 RabbitMQ 時(shí)的問題，這個(gè)問題我覺得還是有一定普適性的，和大家分享一下，避免大家后續(xù)在同一個(gè)問題上犯錯(cuò)。
消息隊(duì)列（MQ）是在軟件開發(fā)中很常用的中間件，如果一個(gè)程序需要協(xié)調(diào)另一個(gè)程序進(jìn)行數(shù)據(jù)的“write”操作，并且不關(guān)心“write”的結(jié)果，則便會(huì)選擇它。它是一個(gè)保存消息（數(shù)據(jù)）的容器，由它來確保消息一定被送達(dá)到目標(biāo)程序。
打個(gè)比喻來說，消息隊(duì)列就是一個(gè)郵差，它負(fù)責(zé)將信件（消息）從源頭送往目的地，并且根據(jù)信件重要性的不同，提供當(dāng)面簽收確認(rèn)或者直接投放兩種服務(wù)。
RabbitMQ 就是一個(gè)典型的消息隊(duì)列，以 AMQP 為標(biāo)準(zhǔn)。歷史也比較悠久，大概是從 2007年研發(fā)出來的，用的編程語言Erlang也同樣具有年代感。
需要簡單介紹一下 Erlang 的特點(diǎn)，它對(duì)我們理解 RabbitMQ 有很大的幫助。
Erlang 是一種運(yùn)行于“虛擬機(jī)”（類似 JVM）的解釋性語言。是一個(gè)結(jié)構(gòu)化，動(dòng)態(tài)類型編程語言，內(nèi)建并行計(jì)算支持。使用 Erlang 編寫出的應(yīng)用運(yùn)行時(shí)通常由成千上萬個(gè)輕量級(jí)“進(jìn)程”（并非傳統(tǒng)意義上的進(jìn)程）組成，并通過消息傳遞相互通訊。進(jìn)程間上下文切換對(duì)于 Erlang 來說僅僅 只是一兩個(gè)環(huán)節(jié)，比起 C 程序的線程切換要高效得多得多了。
——整理于百度百科的資料
不管是什么 MQ 中間件，作為消息的生產(chǎn)方和消費(fèi)方都需要和 MQ 的服務(wù)端建立連接進(jìn)行通訊。
?
一般這個(gè)連接都會(huì)使用 TCP 協(xié)議，在 RabbitMQ 里也不例外。大多數(shù) RabbitMQ 的 SDK 都會(huì)將連接封裝為一個(gè)「Connection」對(duì)象。
還沒完，大多數(shù)的 MQ 中間件還會(huì)在「Connection」的基礎(chǔ)上增加一個(gè)「Channel」的概念，以通過復(fù)用的方式提高 TCP 連接的利用率，因?yàn)榻⒑弯N毀 TCP 連接是非常昂貴的開銷。在 RabbitMQ 中的復(fù)用 TCP 連接方式是「Non-blocking I/O」的模式。
關(guān)于NIO，「Non-blocking I/O」的概念，有感興趣的話可以跳轉(zhuǎn)去看之前寫的這篇文章。（用最通俗的話講明白阻塞/非阻塞/異步/同步，到底啥區(qū)別？）
?
多說一句，任何方案都不是“銀彈”。當(dāng)每個(gè) Channel 的流量不是很大時(shí)，復(fù)用單一的 Connection 可以在產(chǎn)生性能瓶頸的情況下有效地節(jié)省 TCP 連接資源。但是 Channel 本身的流量很大時(shí)，這時(shí)候多個(gè) Channel 復(fù)用一個(gè) Connection 就會(huì)產(chǎn)生性能瓶頸，進(jìn)而使整體的流量被限制了。此時(shí)就需要開辟多個(gè) Connection，將這些 Channel 均攤到這些 Connection 中，至于哪些 Channel 使用那個(gè) Connection 以及Connection 與 Channel 之間的數(shù)量關(guān)系是多少，需要根據(jù)業(yè)務(wù)自身的實(shí)際情況進(jìn)行調(diào)節(jié)。
Channel 在 AMQP 中是一個(gè)很重要的概念，大多數(shù)操作都是在信道這個(gè)層面展開的。比如, channel.exchangeDeclare、channel.queueDeclare、channel.basicPublish、channel.basicConsume 等方法。RabbitMQ 相關(guān)的 API 與 AMQP 緊密相連，比如 channel.basicPublish 對(duì)應(yīng) AMQP 的 Basic.Publish 命令。
可能你要問了，Channel 是不是也能像 Connection 一樣被復(fù)用？這是個(gè)好問題，也是我們這次遇到問題的關(guān)鍵點(diǎn)。
結(jié)論是：可以，但是需要自己保證客戶端對(duì) Channel 訪問的線程安全問題，因?yàn)樵?Channel 的另一端，在 RabbitMQ 的服務(wù)端，每個(gè) Channel 由一個(gè)單獨(dú)的“進(jìn)程”所管理，如果由于多線程復(fù)用Channel 導(dǎo)致數(shù)據(jù)幀亂序了，RabbitMQ 的服務(wù)端會(huì)主動(dòng)關(guān)閉整個(gè) Connection 。
因此，我們這次犯的錯(cuò)誤就是多線程復(fù)用了同一個(gè) Channel 導(dǎo)致的問題。所以，如果你也用到 streadway/amqp 這個(gè)庫的話，需要特別注意這點(diǎn)。
不過，不同語言的SDK內(nèi)部實(shí)現(xiàn)不同，我們分別使用 Golang 的 AMQP 庫 streadway/amqp，和 RabbitMQ 官方提供的 C# 版本的庫分別模擬過同樣的場景，前者出現(xiàn)問題，后者卻沒有問題。
受限于時(shí)間原因，沒有具體去核實(shí) C# 庫的源碼，主觀猜測是 C# 庫內(nèi)部多做了一些對(duì)于單個(gè) Channel 的線程安全處理。
最后，我整理了三點(diǎn)使用 streadway/amqp 庫的最佳實(shí)踐，你可以看看：
01
golang 中使用 streadway/amqp 時(shí)，需要保證每一個(gè)線程單獨(dú)一個(gè) Channel。
streadway/amqp 庫中的獲取一個(gè) Channel 的方法「Connection.channel()」是線程安全的。但是內(nèi)部有一個(gè) defaultChannelMax 的參數(shù)對(duì) Channel 的數(shù)量進(jìn)行了限制，默認(rèn)是 (2 10) - 1，2047。這個(gè)需要注意：
?
02
我們可以通過調(diào)用 amqp.DialConfig(url string, config Config) 來調(diào)整個(gè)限制。
?
但是，并不是你調(diào)整了多少就是多少，還需要和 RabbitMQ 服務(wù)端的配置進(jìn)行 min() 函數(shù)的處理，最終為兩者的最小值。
Tips：特別是用云廠商的 MQ 產(chǎn)品，因?yàn)殡A梯收費(fèi)的原因會(huì)對(duì)很多性能參數(shù)做限制，需要格外關(guān)注這點(diǎn)，比如某版本的阿里云 RabbitMQ 實(shí)例限制是單個(gè) Connection 最多 64 個(gè) Channel）
03
正如前面對(duì) Erlang 的簡單介紹，Erlang 是一個(gè)天然支持多“進(jìn)程”設(shè)計(jì)的語言，所以在 RabbitMQ 的服務(wù)端設(shè)計(jì)中，每一個(gè) Queue，每一個(gè) Connection 都是單獨(dú)的一個(gè)“進(jìn)程”。因此如果你想盡可能地壓榨 RabbitMQ 性能，可以通過建立更多的 Connection 或者創(chuàng)建更多的 Queue 來實(shí)現(xiàn)，當(dāng)然需要注意到 Connection 的創(chuàng)建和銷毀的性能開銷問題。
推薦閱讀：
減少聯(lián)調(diào)、高效集成，試試這個(gè)工具
golang使用3周總結(jié)
也可以「關(guān)注」我，帶你以技術(shù)思維看世界～
想更進(jìn)一步和我一起玩耍，歡迎「搜索微信公號(hào)：跨界架構(gòu)師」。
內(nèi)容包括：架構(gòu)設(shè)計(jì)丨分布式系統(tǒng)丨產(chǎn)品丨運(yùn)營丨個(gè)人深度思考。
最近一直在尋找一個(gè)高性能，高可用的消息隊(duì)列做內(nèi)部服務(wù)之間的通訊。一開始想到用zeromq，但在查找資料的過程中，意外的發(fā)現(xiàn)了Nsq這個(gè)由golang開發(fā)的消息隊(duì)列，畢竟是golang原汁原味的東西，功能齊全，關(guān)鍵是性能還不錯(cuò)。其中支持動(dòng)態(tài)拓展，消除單點(diǎn)故障等特性， 都可以很好的滿足我的需求
下面上一張Nsq與其他mq的對(duì)比圖，看上去的確強(qiáng)大。下面簡單記錄一下Nsq的使用方法
圖片來自golang2017開發(fā)者大會(huì)
在使用Nsq服務(wù)之前，還是有必要了解一下Nsq的幾個(gè)核心組件
整個(gè)Nsq服務(wù)包含三個(gè)主要部分
先看看官方的原話是怎么說：
nsqlookupd是守護(hù)進(jìn)程負(fù)責(zé)管理拓?fù)湫畔??？蛻舳送ㄟ^查詢 nsqlookupd 來發(fā)現(xiàn)指定話題（topic）的生產(chǎn)者，并且 nsqd 節(jié)點(diǎn)廣播話題（topic）和通道（channel）信息
簡單的說nsqlookupd就是中心管理服務(wù)，它使用tcp(默認(rèn)端口4160)管理nsqd服務(wù)，使用http(默認(rèn)端口4161)管理nsqadmin服務(wù)。同時(shí)為客戶端提供查詢功能
總的來說，nsqlookupd具有以下功能或特性
官方原話：是一套 WEB UI，用來匯集集群的實(shí)時(shí)統(tǒng)計(jì)，并執(zhí)行不同的管理任務(wù)
總的來說，nsqadmin具有以下功能或特性
nsqadmin默認(rèn)的訪問地址是
官方原話：nsqd 是一個(gè)守護(hù)進(jìn)程，負(fù)責(zé)接收，排隊(duì)，投遞消息給客戶端
簡單的說，真正干活的就是這個(gè)服務(wù)，它主要負(fù)責(zé)message的收發(fā)，隊(duì)列的維護(hù)。nsqd會(huì)默認(rèn)監(jiān)聽一個(gè)tcp端口(4150)和一個(gè)http端口(4151)以及一個(gè)可選的https端口
總的來說，nsqd 具有以下功能或特性
這是官方的圖，第一個(gè)channel(meteics)因?yàn)橛卸鄠€(gè)消費(fèi)者，所以觸發(fā)了負(fù)載均衡機(jī)制。后面兩個(gè)channel由于沒有消費(fèi)者，所有的message均會(huì)被緩存在相應(yīng)的隊(duì)列里，直到消費(fèi)者出現(xiàn)
這里想到一個(gè)問題是，如果一個(gè)channel只有生產(chǎn)者不停的在投遞message，會(huì)不會(huì)導(dǎo)致服務(wù)器資源被耗盡？也許nsqd內(nèi)部做了相應(yīng)處理，但還是要避免這種情況的出現(xiàn)
了解nsqlookupd，nsqd與客戶端中消費(fèi)者和生產(chǎn)者的關(guān)系
消費(fèi)者有兩種方式與nsqd建立連接
生產(chǎn)者必須直連nsqd去投遞message(網(wǎng)上說，可以連接到nsqlookupd，讓nsqlookupd自動(dòng)選擇一個(gè)nsqd去完成投遞，但是我用Producer的tcp是連不上nsqlookupd的，不知道http可不可以…)，
這里有一個(gè)問題就是如果生產(chǎn)者所連接的nsqd炸了，那么message就會(huì)投遞失敗，所以在客戶端必須自己實(shí)現(xiàn)相應(yīng)的備用方案
執(zhí)行完后檢查godep是否已經(jīng)安裝在bin目錄下，一般都會(huì)自動(dòng)安裝，如果沒有，用go install手動(dòng)安裝下
如果安裝成功，bin目錄里就會(huì)出現(xiàn)一大堆nsq_…開頭的可執(zhí)行文件
nsqd是一個(gè)獨(dú)立的服務(wù)，啟動(dòng)一個(gè)nsqd就可以完成message的收發(fā)，啟動(dòng)一個(gè)單機(jī)的nsqd，很簡單
客戶端可以使用http，也可以使用tcp，這里我使用是官方的go-nsq包做客戶端，使用tcp進(jìn)行message的收發(fā)
//Nsq發(fā)送測試
//Nsq接收測試
重點(diǎn)提示:
這樣我們就啟動(dòng)了一個(gè) nsqd 的實(shí)例
編寫一個(gè)消息生產(chǎn)者
nsq_single_product.go
編寫一個(gè)消息消費(fèi)者
nsq_single_consumer.go
添加第一個(gè)實(shí)例
添加第二個(gè)實(shí)例
消息生產(chǎn)者
nsq_cluster_product.go
消息消費(fèi)者
nsq_cluster_consumer.go
重慶分公司
重慶分公司
