1. package main
    3. import (
    4.     "fmt"
    5.   "log"
    6.   "net/http"
    8.   "code.google.com/p/go.net/websocket"
    9. )
    11. func main() {
    12.   http.Handle("/", websocket.Handler(Echo))
    13.   if err := http.ListenAndServe(":1234", nil); err != nil {
    14.       log.Fatal("ListenAndServer: ", err)
    15.   }
    16. }
    18. func Echo(ws *websocket.Conn) {
    19.   var err error
    21.   for {
    22.     var reply string
    23.     if err = websocket.Message.Receive(ws, &reply); err != nil {
    24.       fmt.Println("Can’t receive")
    25.       break
    26.     }
    28.     fmt.Println("Received back from client: ", reply)
    30.     msg := "Received: " + reply
    31.     fmt.Println("Sending to client" + msg)
    33.     if err = websocket.Message.Send(ws, msg); err != nil {
    34.       fmt.Println("Can’t send")
    35.       break
    36.     }
    37.   }
    38. }