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

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

成都創(chuàng)新互聯(lián)公司專業(yè)為企業(yè)提供儀征網(wǎng)站建設(shè)、儀征做網(wǎng)站、儀征網(wǎng)站設(shè)計(jì)、儀征網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)與制作、儀征企業(yè)網(wǎng)站模板建站服務(wù)，十余年儀征做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。

我們進(jìn)入該項(xiàng)目可以看到里面有這樣的一些內(nèi)容

按照官方的運(yùn)行方式來(lái)運(yùn)行這個(gè)項(xiàng)目

在瀏覽器中打開8080端口，可以看到該項(xiàng)目可以被成功運(yùn)行了。

就是這樣一個(gè)簡(jiǎn)單的demo。

然后我們?nèi)タ匆幌滤木唧w實(shí)現(xiàn)。

在這個(gè)項(xiàng)目中首先定義了一個(gè)hub的結(jié)構(gòu)體：

這個(gè)結(jié)構(gòu)體中，clients代表所有已經(jīng)注冊(cè)的用戶，broadcast管道會(huì)存儲(chǔ)客戶端發(fā)送來(lái)的信息。 register是一個(gè)*Client類型的管道，用于存儲(chǔ)新注冊(cè)的用戶，unregister管道反之。

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

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

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

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

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

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

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

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

我們?cè)趍ian函數(shù)中，首先初始化配置文件，然后新建http連接。

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

這個(gè)方法中首先我們創(chuàng)建一個(gè)websocket的Upgrader實(shí)例，然后我們使用Upgrader的upgrade方法來(lái)升級(jí)一下我們的連接為長(zhǎng)連接。

升級(jí)完成之后會(huì)返回一個(gè)*websocket.Conn的連接，我們之后所有的關(guān)于連接的操作，都是基于該conn的。

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

之后，我們啟動(dòng)一個(gè)goroutine來(lái)讀取連接中發(fā)送的信息內(nèi)容，再根據(jù)內(nèi)容進(jìn)行相應(yīng)的操作。

Go語(yǔ)言的應(yīng)用

Go語(yǔ)言由Google公司開發(fā)，并于2009年開源，相比Java/Python/C等語(yǔ)言，Go尤其擅長(zhǎng)并發(fā)編程，性能堪比C語(yǔ)言，開發(fā)效率肩比Python，被譽(yù)為“21世紀(jì)的C語(yǔ)言”。

Go語(yǔ)言在云計(jì)算、大數(shù)據(jù)、微服務(wù)、高并發(fā)領(lǐng)域應(yīng)用應(yīng)用非常廣泛。BAT大廠正在把Go作為新項(xiàng)目開發(fā)的首選語(yǔ)言。

Go語(yǔ)言應(yīng)用范圍：

1、服務(wù)端開發(fā)：以前你使用C或者C++做的那些事情，用Go來(lái)做很合適，例如日志處理、文件系統(tǒng)、監(jiān)控系統(tǒng)等;

2、DevOps：運(yùn)維生態(tài)中的Docker、K8s、prometheus、grafana、open-falcon等都是使用Go語(yǔ)言開發(fā);

3、網(wǎng)絡(luò)編程：大量?jī)?yōu)秀的Web框架如Echo、Gin、Iris、beego等，而且Go內(nèi)置的 net/http包十分的優(yōu)秀;

4、Paas云平臺(tái)領(lǐng)域：Kubernetes和Docker Swarm等;

5、分布式存儲(chǔ)領(lǐng)域：etcd、Groupcache、TiDB、Cockroachdb、Influxdb等;

6、區(qū)塊鏈領(lǐng)域：區(qū)塊鏈里面有兩個(gè)明星項(xiàng)目以太坊和fabric都使用Go語(yǔ)言;

7、容器虛擬化：大名鼎鼎的Docker就是使用Go語(yǔ)言實(shí)現(xiàn)的;

8、爬蟲及大數(shù)據(jù)：Go語(yǔ)言天生支持并發(fā)，所以十分適合編寫分布式爬蟲及大數(shù)據(jù)處理。

go語(yǔ)言聊天室實(shí)現(xiàn)（七）websocket收消息設(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í)。之前在這里直接寫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è)邏輯。

本文名稱：go語(yǔ)言即時(shí)聊天應(yīng)用 go語(yǔ)言即時(shí)聊天應(yīng)用在哪
文章轉(zhuǎn)載：http://vcdvsql.cn/article8/hepcop.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供電子商務(wù)、、響應(yīng)式網(wǎng)站、網(wǎng)站營(yíng)銷、移動(dòng)網(wǎng)站建設(shè)、靜態(tài)網(wǎng)站

廣告

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