package main import ( "code.google.com/p/go.net/websocket" "fmt" "log" "net/http" "html/template" ) func Echo(ws *websocket.Conn){ var err error for{ fmt.Println("start") var reply string if err = websocket.Message.Receive(ws, &reply); err != nil{ fmt.Println("can't receive") break } fmt.Println("received back from client:"+ reply) msg := "Received : " + reply fmt.Println("Sending to cient: " + msg) if err = websocket.Message.Send(ws, msg); err != nil{ fmt.Println("Can't send") break } } } func chat(w http.ResponseWriter, r *http.Request){ r.ParseForm() fmt.Println(r.Form) t,_ := template.ParseFiles("websocket_demo.html") t.Execute(w, nil) } func main(){ http.Handle("/", websocket.Handler(Echo)) http.HandleFunc("/chat", chat) if err := http.ListenAndServe(":9999", nil); err != nil{ log.Fatal("ListentAndServe:", err) } } ========================================================================================== <html> <head> <body> <script type="text/javascript"> var sock = null; var wsuri = "ws://127.0.0.1:9999"; window.onload = function(){ console.log("onload"); sock = new WebSocket(wsuri); sock.onopen = function(){ console.log("connected to " + wsuri); } sock.onclose = function(e) { console.log("connection closed (" + e.code + ")"); } sock.onmessage = function(e){ console.log("message received:" + e.data); } }; function send(){ console.log("send") var msg = document.getElementById('message').value; console.log(msg) sock.send(msg); }; </script> <h1> Websocket Echo Test</h1> <form> <p> Message: <input id = "message" type = "text" value ="hello dumx"> </p> </form> <button onclick="send();">Send Msg</button> </body> </head> </html>
有疑问加站长微信联系(非本文作者)