So verwenden Sie WebSocket für die Fernsteuerung in der Go-Sprache
Einführung:
WebSocket ist eine Technologie, die eine bidirektionale Kommunikation in Echtzeit in Webanwendungen ermöglicht. In der Go-Sprache können wir die Pakete net/http
und github.com/gorilla/websocket
in der Standardbibliothek verwenden, um die WebSocket-Kommunikation zu implementieren. In diesem Artikel wird die Verwendung von WebSocket für die Fernsteuerung in der Go-Sprache vorgestellt und spezifische Codebeispiele bereitgestellt. net/http
和github.com/gorilla/websocket
包来实现WebSocket通信。本文将介绍如何使用WebSocket在Go语言中进行远程控制,并提供具体的代码示例。
步骤:
go get github.com/gorilla/websocket
package main import ( "log" "net/http" "github.com/gorilla/websocket" ) var upgrader = websocket.Upgrader{} func wsHandler(w http.ResponseWriter, r *http.Request) { conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Fatal(err) } defer conn.Close() for { // 读取客户端消息 messageType, p, err := conn.ReadMessage() if err != nil { log.Println(err) return } // 处理客户端消息 // doSomething(p) // 响应客户端消息 err = conn.WriteMessage(messageType, p) if err != nil { log.Println(err) return } } } func main() { http.HandleFunc("/ws", wsHandler) log.Fatal(http.ListenAndServe(":8080", nil)) }
package main import ( "log" "net/url" "os" "os/signal" "time" "github.com/gorilla/websocket" ) func main() { interrupt := make(chan os.Signal, 1) signal.Notify(interrupt, os.Interrupt) u := url.URL{Scheme: "ws", Host: "localhost:8080", Path: "/ws"} log.Printf("connecting to %s", u.String()) c, _, err := websocket.DefaultDialer.Dial(u.String(), nil) if err != nil { log.Fatal("dial:", err) } defer c.Close() done := make(chan struct{}) // 启动读取协程 go func() { defer c.Close() defer close(done) for { _, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) return } // 处理服务器消息 // doSomething(message) } }() // 启动写入协程 go func() { defer c.Close() defer close(done) for { // 写入消息到服务器 err := c.WriteMessage(websocket.TextMessage, []byte("Hello, Server!")) if err != nil { log.Println("write:", err) return } time.Sleep(time.Second) } }() // 等待中断信号,优雅地关闭连接 for { select { case <-done: return case <-interrupt: log.Println("interrupt") return } } }
$ go build server.go $ go build client.go $ ./server $ ./client
总结:
通过上述步骤,我们可以在Go语言中使用WebSocket进行远程控制。在服务器端,我们使用github.com/gorilla/websocket
包来创建和管理WebSocket连接,并通过conn.ReadMessage()
和conn.WriteMessage()
方法读取和发送消息。在客户端,我们可以通过websocket.DefaultDialer.Dial()
来进行WebSocket的连接,在读取和发送消息时使用ReadMessage()
和WriteMessage()
github.com/gorilla/websocket
, um WebSocket-Verbindungen zu erstellen und zu verwalten, und übergeben conn.ReadMessage()
und conn. WriteMessage( )
-Methode zum Lesen und Senden von Nachrichten. Auf der Clientseite können wir über websocket.DefaultDialer.Dial()
eine Verbindung zu WebSocket herstellen und beim Lesen und Senden von Nachrichten ReadMessage()
und WriteMessage verwenden. )
Methode. Auf diese Weise können wir flexibel aus der Ferne steuern und eine Echtzeitkommunikation erreichen. 🎜Das obige ist der detaillierte Inhalt vonSo verwenden Sie WebSocket zur Fernsteuerung in Golang. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!