使用Golang實現Websocket編程

目前創新互聯已為上1000家的企業提供了網站建設、域名、網絡空間、網站托管維護、企業網站設計、大慶網站維護等服務，公司將堅持客戶導向、應用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協力一起成長，共同發展。

Websocket是一種在瀏覽器和服務器之間進行全雙工通信的技術。在傳統的HTTP通信中，瀏覽器只能向服務器發起請求，服務器在處理請求后會返回響應。但在Websocket中，瀏覽器和服務器之間建立了一個長連接，使得數據可以在雙方之間實時傳輸。

本文將介紹如何使用Golang實現Websocket編程。我們將使用標準庫中的net/http和golang.org/x/net/websocket包來完成這個任務。

準備工作

在開始之前，要確保你已經安裝了Golang。如果還沒有安裝，可以參考這個鏈接來安裝：https://golang.org/doc/install

接著我們來創建一個新的Go模塊，首先創建一個文件夾：

mkdir websocket-democd websocket-demo

然后執行下面的命令來初始化一個新的Go模塊：

go mod init websocket-demo

這個命令將會創建一個go.mod文件，用來記錄模塊依賴關系。

實現Websocket服務器

現在我們開始實現Websocket服務器。創建一個main.go文件，并在其中添加如下代碼：

go

package main

import (

"fmt"

"golang.org/x/net/websocket"

"net/http"

)

func main() {

http.Handle("/ws", websocket.Handler(wsHandler))

fmt.Println("Server started at http://localhost:8080")

http.ListenAndServe(":8080", nil)

}

func wsHandler(ws *websocket.Conn) {

fmt.Println("Websocket connection established")

var msg = ""

for {

err := websocket.Message.Receive(ws, &msg)

if err != nil {

fmt.Println("Connection closed")

break

}

fmt.Printf("Received message: %s\n", msg)

err = websocket.Message.Send(ws, msg)

if err != nil {

fmt.Println("Connection closed")

break

}

}

}

這段代碼中，我們首先使用http.Handle()函數來為Websocket連接監聽路徑/ws，并將監聽函數wsHandler作為參數傳入。wsHandler用來處理客戶端和服務器之間的通信，它接收一個websocket.Conn類型的參數，表示一個Websocket連接。在wsHandler中，我們首先打印一條"Websocket connection established"的日志，表示連接已經建立。然后使用websocket.Message.Receive()函數來接收客戶端發送的消息，并使用websocket.Message.Send()函數將接收到的消息回傳給客戶端。如果有任何錯誤發生，我們將打印一條"Connection closed"的日志，并退出循環。現在我們來運行這個程序，執行下面的命令：

go run main.go

這個命令將會運行我們的Websocket服務器。在瀏覽器中輸入http://localhost:8080`，并打開控制臺，在控制臺中輸入以下代碼即可連接到Websocket服務器：`javascriptvar ws = new WebSocket("ws://localhost:8080/ws");ws.onopen = function() { console.log("Websocket connection established"); ws.send("Hello, server!");};ws.onmessage = function(evt) { console.log("Received message: " + evt.data);};ws.onclose = function() { console.log("Websocket connection closed");};

這段代碼中，我們首先使用WebSocket對象來建立一個與服務器的連接。當連接建立成功后，我們打印一條"Websocket connection established"的日志，并使用ws.send()函數來向服務器發送一條消息。當我們接收到服務器返回的消息時，我們會打印一條"Received message: "的日志，并將消息內容輸出。最后，當連接關閉時，我們將會打印一條"Websocket connection closed"的日志。

現在我們來嘗試在控制臺中輸入Hello, server!，看看程序是否能夠將消息回傳給我們。如果一切正常，我們將在控制臺中看到以下輸出：

Received message: Hello, server!

總結

在本文中，我們介紹了如何使用Golang實現Websocket編程。我們使用標準庫中的net/http和golang.org/x/net/websocket包來實現了一個簡單的Websocket服務器，并用瀏覽器發送了一個測試消息。希望這個示例可以幫助你更好地理解Websocket的工作原理，以及如何使用Golang來實現Websocket編程。

網頁名稱：使用Golang實現Websocket編程
標題來源：http://m.newbst.com/article43/dghoies.html

成都網站建設公司_創新互聯，為您提供網站收錄、網站改版、網站營銷、建站公司、外貿建站、網站制作

廣告

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