最近需要做一个消息通知的推送，开始在实践 websocket
server port:9091
package main import ( "fmt" "log" "net/http" "github.com/gorilla/websocket" ) var upgrader = websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true }, } // use default options func Echo(w http.ResponseWriter, r *http.Request) { c, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Print("upgrade:", err) return } defer c.Close() for { mt, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) break } log.Printf("recv: %s", message) err = c.WriteMessage(mt, message) if err != nil { log.Println("write:", err) break } }} func main() { http.HandleFunc("/echo", Echo) fmt.Println("start server port:9091") if err := http.ListenAndServe(":9091", nil); err != nil { log.Fatal("ListenAndServe:1234:", err) }}
client:
<!DOCTYPE html> <html> <head> <title>websocket</title> </head> <body> <h1>Echo Test</h1> <input type="text" id="sendTxt"> <button id="sendBtn">发送</button> <div id="recv"></div> <script type="text/javascript"> let ws = new WebSocket("ws://127.0.0.1:9091/echo") ws.onopen = function () { // body... console.log("websocket open"); document.getElementById('recv').innerHTML = 'Connected'; } ws.oncolse = function (e) { // body... console.log("consoled"); } ws.onmessage=function (e) { // body... console.log(e.data) document.getElementById('recv').innerHTML = e.data; } document.getElementById('sendBtn').onclick=function(){ var txt=document.getElementById('sendTxt').value; console.log(txt) ws.send(txt) } </script> </body> </html>
欢迎来到这里！
我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。
注册 关于