WebSocket在Golang中的應(yīng)用實(shí)踐

WebSocket是一種HTTP協(xié)議的增強(qiáng)協(xié)議，它在TCP之上提供了雙向通信功能。這個(gè)協(xié)議很適合實(shí)時(shí)性要求高的應(yīng)用場(chǎng)景，比如在線(xiàn)游戲、即時(shí)通訊和股票行情等等。本文將介紹WebSocket在Golang中的應(yīng)用實(shí)踐。

WebSocket工作原理

WebSocket協(xié)議使用HTTP協(xié)議建立連接，并在連接建立后，將HTTP協(xié)議升級(jí)為WebSocket協(xié)議。WebSocket連接是由客戶(hù)端發(fā)起的，通過(guò)一個(gè)HTTP請(qǐng)求，請(qǐng)求頭包括“Upgrade”字段，值為“websocket”，請(qǐng)求成功后，服務(wù)端返回HTTP響應(yīng)，包括“Upgrade”字段和“Connection”字段，值分別為“websocket”和“Upgrade”。客戶(hù)端和服務(wù)端的通信以二進(jìn)制流的形式進(jìn)行，不像HTTP協(xié)議一樣需要每次發(fā)送完整的請(qǐng)求和響應(yīng)報(bào)文。在通信完成后，可以選擇關(guān)閉連接，也可以保持連接一直開(kāi)啟。

Golang中的WebSocket庫(kù)

Golang內(nèi)置了net/http包，這個(gè)包提供了一系列用于HTTP協(xié)議處理的函數(shù)和類(lèi)型。這個(gè)包也提供了一個(gè)實(shí)現(xiàn)了WebSocket協(xié)議的庫(kù)，即net/http包中的websocket包。

1. 創(chuàng)建WebSocket連接

在Golang中創(chuàng)建WebSocket連接非常容易。首先，需要引入net/http包和websocket包：

import (    "net/http"    "github.com/gorilla/websocket")

然后，可以使用http包中的HandleFunc函數(shù)創(chuàng)建一個(gè)HTTP監(jiān)聽(tīng)接口：

http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {    // 處理連接請(qǐng)求})

在處理連接請(qǐng)求的函數(shù)中，可以使用websocket包中的Upgrade函數(shù)將HTTP協(xié)議升級(jí)為WebSocket協(xié)議：

var upgrader = websocket.Upgrader{    ReadBufferSize: 1024,    WriteBufferSize: 1024,    CheckOrigin: func(r *http.Request) bool {        return true    },}func handler(w http.ResponseWriter, r *http.Request) {    conn, err := upgrader.Upgrade(w, r, nil)    if err != nil {        log.Println(err)        return    }    // 處理WebSocket連接}

在進(jìn)行Upgrade操作時(shí)，需要指定讀寫(xiě)緩沖區(qū)的大小以及CheckOrigin函數(shù)。CheckOrigin函數(shù)用于安全驗(yàn)證，當(dāng)WebSocket連接請(qǐng)求的來(lái)源域名與服務(wù)器域名不一致時(shí)，可以拒絕連接請(qǐng)求，默認(rèn)情況下這個(gè)函數(shù)返回false，即不允許連接，可以通過(guò)實(shí)現(xiàn)自定義的CheckOrigin函數(shù)來(lái)解決這個(gè)問(wèn)題。如果Upgrade操作成功，返回的conn對(duì)象就是一個(gè)WebSocket連接。

2. 發(fā)送和接收消息

WebSocket連接建立后，可以使用WriteMessage函數(shù)向客戶(hù)端發(fā)送消息：

func handler(conn *websocket.Conn) {    for {        messageType, p, err := conn.ReadMessage()        if err != nil {            log.Println(err)            return        }        err = conn.WriteMessage(messageType, p)        if err != nil {            log.Println(err)            return        }    }}

在這個(gè)例子中，通過(guò)調(diào)用conn.ReadMessage讀取客戶(hù)端發(fā)送的消息，然后通過(guò)conn.WriteMessage將消息發(fā)送回去。如果需要發(fā)送文本消息，可以使用WriteMessage函數(shù)的第一個(gè)參數(shù)設(shè)置消息類(lèi)型為文本類(lèi)型websocket.TextMessage，如果需要發(fā)送二進(jìn)制消息，可以使用websocket.BinaryMessage類(lèi)型。同樣地，讀取消息時(shí)，使用ReadMessage函數(shù)返回消息類(lèi)型和消息內(nèi)容。

3. 關(guān)閉WebSocket連接

在WebSocket連接不再使用時(shí)，需要關(guān)閉連接，可以使用Close函數(shù)關(guān)閉連接：

func handler(conn *websocket.Conn) {    defer conn.Close()    for {        messageType, p, err := conn.ReadMessage()        if err != nil {            log.Println(err)            return        }        err = conn.WriteMessage(messageType, p)        if err != nil {            log.Println(err)            return        }    }}

在這個(gè)例子中，使用defer語(yǔ)句在函數(shù)結(jié)束時(shí)自動(dòng)關(guān)閉連接。也可以在代碼中顯式地調(diào)用conn.Close函數(shù)關(guān)閉連接。

總結(jié)

本文介紹了WebSocket在Golang中的應(yīng)用實(shí)踐。WebSocket在實(shí)時(shí)性要求高的應(yīng)用場(chǎng)景中發(fā)揮著非常重要的作用。在Golang中，可以使用net/http包中的websocket包實(shí)現(xiàn)WebSocket協(xié)議。通過(guò)Upgrade函數(shù)可以將HTTP協(xié)議升級(jí)為WebSocket協(xié)議，使用WriteMessage和ReadMessage函數(shù)可以發(fā)送和接收消息，使用Close函數(shù)可以關(guān)閉WebSocket連接。

以上就是IT培訓(xùn)機(jī)構(gòu)千鋒教育提供的相關(guān)內(nèi)容，如果您有web前端培訓(xùn)，鴻蒙開(kāi)發(fā)培訓(xùn)，python培訓(xùn)，linux培訓(xùn)，java培訓(xùn)，UI設(shè)計(jì)培訓(xùn)等需求，歡迎隨時(shí)聯(lián)系千鋒教育。