golang ws使用json

使用Golang JSON在WebSocket上进行数据交互

WebSocket是一种在客户端和服务器之间进行双向通信的协议，它提供了一种实时的数据传输机制。在Golang中，我们可以使用标准库中的"gorilla/websocket"包来实现WebSocket的功能。本文将介绍如何使用Golang的JSON和WebSocket一起进行数据交互。

建立WebSocket连接

首先，我们需要导入"golang.org/x/net/websocket"和"github.com/gorilla/websocket"这两个包。然后，我们可以使用websocket库中的`Dial`函数来建立WebSocket连接：

```Go package main import ( "log" "net/http" "github.com/gorilla/websocket" ) func main() { upgrader := websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true }, } http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) { conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Fatal(err) } // 在这里处理WebSocket连接 }) log.Fatal(http.ListenAndServe(":8080", nil)) } ``` 上述代码中的`/ws`路径用于处理WebSocket连接，并且我们设置了`CheckOrigin`函数，允许来自任意源的HTTP请求。

发送JSON数据

要发送JSON数据，我们需要创建一个结构体类型来表示我们的数据，并使用`json.Marshal`函数将结构体序列化为JSON字符串。

```Go type Message struct { Content string `json:"content"` } func main() { // ... http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) { conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Fatal(err) } go func() { defer conn.Close() message := Message{ Content: "Hello, WebSocket!", } data, err := json.Marshal(message) if err != nil { log.Println(err) return } err = conn.WriteMessage(websocket.TextMessage, data) if err != nil { log.Println(err) return } }() // ... }) } ``` 在上述代码中，我们创建了一个名为`Message`的结构体，并定义了一个名为`Content`的字段。然后，我们使用`json.Marshal`函数将`Message`结构体序列化成JSON字符串并发送给客户端。

接收JSON数据

要接收JSON数据，我们可以使用`conn.ReadMessage`方法从WebSocket连接中读取消息，并使用`json.Unmarshal`函数将JSON字符串反序列化为结构体。

```Go func main() { // ... http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) { conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Fatal(err) } go func() { defer conn.Close() for { _, data, err := conn.ReadMessage() if err != nil { log.Println(err) return } message := &Message{} err = json.Unmarshal(data, message) if err != nil { log.Println(err) return } log.Printf("Received message: %s\n", message.Content) } }() // ... }) } ``` 在上述代码中，我们使用了一个无限循环来不断接收来自客户端的消息。我们首先使用`conn.ReadMessage`方法读取消息并存储在`data`变量中，然后使用`json.Unmarshal`函数将其反序列化为`Message`结构体，并打印出接收到的消息内容。

总结

使用Golang的JSON和WebSocket一起进行数据交互非常简单直观。我们可以通过WebSocket连接发送和接收JSON数据，实现实时通信的功能。借助`gorilla/websocket`包中提供的便捷工具和标准库中的JSON处理函数，我们可以轻松地在Golang中实现WebSocket的功能。

请注意，本文只是介绍了如何在Golang中使用JSON和WebSocket进行数据交互的基本原理和示例代码，并不涵盖所有可能的用法和场景。详细的WebSocket和JSON处理，请参考相关文档。