如何使用golang建立WebSocket伺服器
WebSocket是一種在客戶端和伺服器之間實現雙向通訊的協定。它允許我們透過一個持久的連接在客戶端和伺服器之間傳輸資料。在這篇文章中,我將向你介紹如何使用golang建立一個簡單的WebSocket伺服器,並提供具體的程式碼範例。
net/http
和github.com/gorilla/websocket
這兩個依賴套件。 net/http
用於建立HTTP伺服器,gorilla/websocket
用於處理WebSocket連線。 import ( "net/http" "github.com/gorilla/websocket" )
http.HandleFunc()
函數來處理WebSocket連線請求,並使用websocket.Upgrade()
函數將HTTP協定升級為WebSocket協定。 func wsHandler(w http.ResponseWriter, r *http.Request) { upgrader := websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true }, } conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Println("Upgrade error:", err) return } // 在这里处理WebSocket连接 }
在wsHandler()
函數中,我們建立了一個Upgrader
對象,並設定了CheckOrigin
屬性為一個匿名函數,傳回true表示接受所有的跨域請求。
接下來,我們使用Upgrade()
函數將HTTP協議升級為WebSocket協議,如果升級失敗則列印錯誤訊息並返回。如果升級成功,我們可以使用conn
物件來處理WebSocket連線。
conn
物件進行讀寫作業。以下是一個簡單的處理範例:for { messageType, message, err := conn.ReadMessage() if err != nil { log.Println("Read error:", err) break } log.Println("received message:", string(message)) err = conn.WriteMessage(messageType, message) if err != nil { log.Println("Write error:", err) break } }
在上面的範例中,我們使用ReadMessage()
函數讀取客戶端傳送的訊息,並使用WriteMessage ()
函數將訊息回傳給客戶端。如果讀取或寫入過程中出現錯誤,我們會列印錯誤訊息並跳出循環。
http.HandleFunc()
函數將wsHandler()
函數註冊為處理WebSocket連接的處理器,並使用http.ListenAndServe()
函數在指定連接埠上啟動WebSocket伺服器。 func main() { http.HandleFunc("/ws", wsHandler) log.Println("WebSocket server started.") err := http.ListenAndServe(":8080", nil) if err != nil { log.Fatal("ListenAndServe error:", err) } }
在上面的範例中,我們將wsHandler()
函數註冊為"/ws"路徑的處理器。你可以根據需要自訂路徑。
總結
本文介紹如何使用golang建立一個簡單的WebSocket伺服器,並提供了具體的程式碼範例。使用golang建立WebSocket伺服器非常簡單,而且能夠很方便地實現雙向通訊。希望這篇文章對你理解和使用WebSocket有幫助。
以上是如何使用golang建立WebSocket伺服器的詳細內容。更多資訊請關注PHP中文網其他相關文章!