最近需要做一个消息通知的推送，开始在实践 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>
欢迎来到这里！
我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。
注册 关于