Go語言使用NSQ消息隊列

重點提示:

創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設計、網(wǎng)站建設、外貿(mào)網(wǎng)站建設與策劃設計,通化縣網(wǎng)站建設哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設十載,網(wǎng)設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:通化縣等地區(qū)。通化縣做網(wǎng)站價格咨詢:13518219792

這樣我們就啟動了一個 nsqd 的實例

編寫一個消息生產(chǎn)者

nsq_single_product.go

編寫一個消息消費者

nsq_single_consumer.go

添加第一個實例

添加第二個實例

消息生產(chǎn)者

nsq_cluster_product.go

消息消費者

nsq_cluster_consumer.go

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

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

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

首先我們新建一個MessageController的結構體，內(nèi)容如下

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

這個是具體的方法。

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

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

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

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

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

go語言能做什么？

很多朋友可能知道Go語言的優(yōu)勢在哪，卻不知道Go語言適合用于哪些地方。

1、 Go語言作為服務器編程語言，很適合處理日志、數(shù)據(jù)打包、虛擬機處理、文件系統(tǒng)、分布式系統(tǒng)、數(shù)據(jù)庫代理等；網(wǎng)絡編程方面。Go語言廣泛應用于Web應用、API應用、下載應用等；除此之外，Go語言還可用于內(nèi)存數(shù)據(jù)庫和云平臺領域，目前國外很多云平臺都是采用Go開發(fā)。

2、 其實Go語言主要用作服務器端開發(fā)。其定位是用來開發(fā)"大型軟件"的，適合于很多程序員一起開發(fā)大型軟件，并且開發(fā)周期長，支持云計算的網(wǎng)絡服務。Go語言能夠讓程序員快速開發(fā)，并且在軟件不斷的增長過程中，它能讓程序員更容易地進行維護和修改。它融合了傳統(tǒng)編譯型語言的高效性和腳本語言的易用性和富于表達性。

3、 Go語言成功案例。Nsq：Nsq是由Go語言開發(fā)的高性能、高可用消息隊列系統(tǒng)，性能非常高，每天能處理數(shù)十億條的消息；

4、 Docker：基于lxc的一個虛擬打包工具，能夠?qū)崿F(xiàn)PAAS平臺的組建。

5、 Packer：用來生成不同平臺的鏡像文件，例如VM、vbox、AWS等，作者是vagrant的作者

6、 Skynet：分布式調(diào)度框架。

7、 Doozer：分布式同步工具，類似ZooKeeper。

8、 Heka：mazila開源的日志處理系統(tǒng)。

9、 Cbfs：couchbase開源的分布式文件系統(tǒng)。

10、 Tsuru：開源的PAAS平臺，和SAE實現(xiàn)的功能一模一樣。

11、 Groupcache：memcahe作者寫的用于Google下載系統(tǒng)的緩存系統(tǒng)。

12、 God：類似redis的緩存系統(tǒng)，但是支持分布式和擴展性。

13、 Gor：網(wǎng)絡流量抓包和重放工具。

以上的就是關于go語言能做什么的內(nèi)容介紹了。

網(wǎng)站名稱：go語言消息 go語言 _
文章來源：http://www.chinadenli.net/article14/ddopsge.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供商城網(wǎng)站、移動網(wǎng)站建設、虛擬主機、網(wǎng)站建設、搜索引擎優(yōu)化、響應式網(wǎng)站

廣告

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