社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
效果图片
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>
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!