| 1234567891011121314151617181920212223242526272829 |
- // websocket_server.go
- package main
- import (
- "fmt"
- "net/http"
- "code.google.com/p/go.net/websocket"
- )
- func server(ws *websocket.Conn) {
- fmt.Printf("new connection\n")
- buf := make([]byte, 100)
- for {
- if _, err := ws.Read(buf); err != nil {
- fmt.Printf("%s", err.Error())
- break
- }
- }
- fmt.Printf(" => closing connection\n")
- ws.Close()
- }
- func main() {
- http.Handle("/websocket", websocket.Handler(server))
- err := http.ListenAndServe(":12345", nil)
- if err != nil {
- panic("ListenAndServe: " + err.Error())
- }
- }
|