golang中websocket

发布时间:2024-11-21 23:02:46

WebSocket是一种在单个TCP连接上进行全双工通信的协议,它提供了一种实时、持久化的双向通信机制。在Golang中,我们可以使用第三方库`gorilla/websocket`来实现WebSocket功能。本文将介绍如何在Golang中使用WebSocket进行通信。 ## 准备工作 在开始之前,我们需要安装`gorilla/websocket`库。可以通过以下命令在终端中进行安装: ``` go get github.com/gorilla/websocket ``` 安装完成后,我们可以开始编写我们的代码。 ## 建立WebSocket连接 首先,我们需要在Golang中创建一个HTTP服务器并处理WebSocket请求。我们可以使用`http`包提供的`ListenAndServe`函数来创建一个简单的HTTP服务器。 ```go package main import ( "log" "net/http" "github.com/gorilla/websocket" ) func main() { http.HandleFunc("/websocket", handleWebSocket) log.Fatal(http.ListenAndServe(":8080", nil)) } func handleWebSocket(w http.ResponseWriter, r *http.Request) { // 建立WebSocket连接 var upgrader = websocket.Upgrader{} conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Println(err) return } // 处理WebSocket消息 for { messageType, message, err := conn.ReadMessage() if err != nil { log.Println(err) return } log.Printf("Received message: %s", message) // 回复消息 err = conn.WriteMessage(messageType, message) if err != nil { log.Println(err) return } } } ``` 在上面的代码中,我们使用`handleWebSocket`函数作为`http.HandleFunc`的处理函数。在这个函数中,我们首先使用`websocket.Upgrader`结构体来将HTTP连接升级为WebSocket连接。然后,我们使用`conn.ReadMessage`从WebSocket收取消息,并在控制台打印接收到的消息。最后,我们使用`conn.WriteMessage`将相同的消息发送回客户端。 ## 前端页面 在服务器端设置好WebSocket连接之后,我们需要编写前端页面来测试我们的WebSocket连接。以下是一个简单的HTML和Javascript示例: ```html WebSocket Example

WebSocket Example



``` 在这个示例中,我们创建了一个WebSocket对象,并将其连接到服务器上的`/websocket`端点。当连接建立时,我们在控制台打印一条消息。当收到来自服务器的消息时,我们将其添加到页面上的`
`元素中。当用户在输入框中键入并点击发送按钮时,我们使用`socket.send`发送消息到服务器。 ## 运行代码 要运行我们的示例代码,我们可以使用以下命令: ``` go run main.go ``` 然后,在浏览器中打开`http://localhost:8080`,您应该能够看到一个简单的页面和一个输入框。在输入框中键入一些消息并点击发送按钮,您将在控制台上看到相同的消息,并且消息也将显示在页面上。 ## 总结 通过`gorilla/websocket`库,我们可以轻松地在Golang中实现WebSocket功能。这种实时、持久化的双向通信机制可以广泛用于实时聊天、实时数据传输等场景。希望本文能够帮助您快速上手使用WebSocket。

相关推荐