关于Go语言在服务端做Restful接口和socket通信

<span style= "font-size:16px;" > package  main<br data-filtered= "filtered" > import  (<br data-filtered= "filtered" >     "fmt" <br data-filtered= "filtered" >     "github.com/drone/routes" <br data-filtered= "filtered" >     "net/http" <br data-filtered= "filtered" >)<br data-filtered= "filtered" >func getuser(w http.ResponseWriter, r *http.Request) {<br data-filtered= "filtered" >    params := r.URL.Query()<br data-filtered= "filtered" >    uid := params.Get( ":uid" )<br data-filtered= "filtered" >    fmt.Fprintf(w,  "you are get user %s" , uid)<br data-filtered= "filtered" >}<br data-filtered= "filtered" >func modifyuser(w http.ResponseWriter, r *http.Request) {<br data-filtered= "filtered" >    params := r.URL.Query()<br data-filtered= "filtered" >    uid := params.Get( ":uid" )<br data-filtered= "filtered" >    fmt.Fprintf(w,  "you are modify user %s" , uid)<br data-filtered= "filtered" >}<br data-filtered= "filtered" >func deleteuser(w http.ResponseWriter, r *http.Request) {<br data-filtered= "filtered" >    params := r.URL.Query()<br data-filtered= "filtered" >    uid := params.Get( ":uid" )<br data-filtered= "filtered" >    fmt.Fprintf(w,  "you are delete user %s" , uid)<br data-filtered= "filtered" >}<br data-filtered= "filtered" >func adduser(w http.ResponseWriter, r *http.Request) {<br data-filtered= "filtered" >    params := r.URL.Query()<br data-filtered= "filtered" >    uid := params.Get( ":uid" )<br data-filtered= "filtered" >    fmt.Fprint(w,  "you are add user %s" , uid)<br data-filtered= "filtered" >    fmt.Printf( "you are add user %s" , uid)<br data-filtered= "filtered" >}<br data-filtered= "filtered" > //xiaorui.cc<br data-filtered="filtered">func main() {<br data-filtered="filtered">    mux := routes.New()<br data-filtered="filtered">    mux.Get("/user/:uid", getuser)<br data-filtered="filtered">    mux.Post("/user/:uid", modifyuser)<br data-filtered="filtered">    mux.Del("/user/:uid", deleteuser)<br data-filtered="filtered">    mux.Put("/user/:uid", adduser)<br data-filtered="filtered">    http.Handle("/", mux)<br data-filtered="filtered">    http.ListenAndServe(":8088", nil)<br data-filtered="filtered">}<br data-filtered="filtered">//xiaorui.cc<br data-filtered="filtered"></span>

<span style= "font-size:16px;" > package  main<br data-filtered= "filtered" > import  (<br data-filtered= "filtered" >     "fmt" <br data-filtered= "filtered" >     "net" <br data-filtered= "filtered" >     "os" <br data-filtered= "filtered" >)<br data-filtered= "filtered" >func main() {<br data-filtered= "filtered" >     var  (<br data-filtered= "filtered" >        host   =  "127.0.0.1" <br data-filtered= "filtered" >        port   =  "8080" <br data-filtered= "filtered" >        remote = host +  ":"  + port<br data-filtered= "filtered" >        data   = make([]byte,  1024 )<br data-filtered= "filtered" >    )<br data-filtered= "filtered" >    fmt.Println( "Initiating server... (Ctrl-C to stop)" )<br data-filtered= "filtered" >    lis, err := net.Listen( "tcp" , remote)<br data-filtered= "filtered" >    defer lis.Close()<br data-filtered= "filtered" >     if  err != nil {<br data-filtered= "filtered" >        fmt.Println( "Error when listen: " , remote)<br data-filtered= "filtered" >        os.Exit(- 1 )<br data-filtered= "filtered" >    }<br data-filtered= "filtered" >     for  {<br data-filtered= "filtered" >         var  res string<br data-filtered= "filtered" >        conn, err := lis.Accept()<br data-filtered= "filtered" >         if  err != nil {<br data-filtered= "filtered" >            fmt.Println( "Error accepting client: " , err.Error())<br data-filtered= "filtered" >            os.Exit( 0 )<br data-filtered= "filtered" >        }<br data-filtered= "filtered" >        go func(con net.Conn) {<br data-filtered= "filtered" >            fmt.Println( "New connection: " , con.RemoteAddr())<br data-filtered= "filtered" >             for  {<br data-filtered= "filtered" >                length, err := con.Read(data)<br data-filtered= "filtered" >                 if  err != nil {<br data-filtered= "filtered" >                    fmt.Printf( "Client %v quit.\n" , con.RemoteAddr())<br data-filtered= "filtered" >                    con.Close()<br data-filtered= "filtered" >                     return <br data-filtered= "filtered" >                }<br data-filtered= "filtered" >                res = string(data[ 0 :length])<br data-filtered= "filtered" >                fmt.Printf( "%s said: %s\n" , con.RemoteAddr(), res)<br data-filtered= "filtered" >                res =  "You said:"  + res<br data-filtered= "filtered" >                con.Write([]byte(res))<br data-filtered= "filtered" >            }<br data-filtered= "filtered" >        }(conn)<br data-filtered= "filtered" >    }<br data-filtered= "filtered" >}<br data-filtered= "filtered" ></span>

<span style= "font-size:16px;" > package  main<br data-filtered= "filtered" > import  (<br data-filtered= "filtered" >     "fmt" <br data-filtered= "filtered" >     "net" <br data-filtered= "filtered" >     "os" <br data-filtered= "filtered" >)<br data-filtered= "filtered" > var  str string<br data-filtered= "filtered" > var  msg = make([]byte,  1024 )<br data-filtered= "filtered" >func main() {<br data-filtered= "filtered" >     var  (<br data-filtered= "filtered" >        host   =  "127.0.0.1" <br data-filtered= "filtered" >        port   =  "8080" <br data-filtered= "filtered" >        remote = host +  ":"  + port<br data-filtered= "filtered" >    )<br data-filtered= "filtered" >    con, err := net.Dial( "tcp" , remote)<br data-filtered= "filtered" >    defer con.Close()<br data-filtered= "filtered" >     if  err != nil {<br data-filtered= "filtered" >        fmt.Println( "Server not found." )<br data-filtered= "filtered" >        os.Exit(- 1 )<br data-filtered= "filtered" >    }<br data-filtered= "filtered" >    fmt.Println( "Connection OK." )<br data-filtered= "filtered" >     for  {<br data-filtered= "filtered" >        fmt.Printf( "Enter a sentence:" )<br data-filtered= "filtered" >        fmt.Scanf( "%s\n" , &str)<br data-filtered= "filtered" >         if  str ==  "quit"  {<br data-filtered= "filtered" >            fmt.Println( "Communication terminated." )<br data-filtered= "filtered" >            os.Exit( 1 )<br data-filtered= "filtered" >        }<br data-filtered= "filtered" >         in , err := con.Write([]byte(str))<br data-filtered= "filtered" >         if  err != nil {<br data-filtered= "filtered" >            fmt.Printf( "Error when send to server: %d\n" ,  in )<br data-filtered= "filtered" >            os.Exit( 0 )<br data-filtered= "filtered" >        }<br data-filtered= "filtered" >        length, err := con.Read(msg)<br data-filtered= "filtered" >         if  err != nil {<br data-filtered= "filtered" >            fmt.Printf( "Error when read from server.\n" )<br data-filtered= "filtered" >            os.Exit( 0 )<br data-filtered= "filtered" >        }<br data-filtered= "filtered" >        str = string(msg[ 0 :length])<br data-filtered= "filtered" >        fmt.Println(str)<br data-filtered= "filtered" >    }<br data-filtered= "filtered" >}<br data-filtered= "filtered" ></span>

<span style= "font-size:16px;" > package  main<br data-filtered= "filtered" > import  (<br data-filtered= "filtered" >         "fmt" <br data-filtered= "filtered" >         "runtime" <br data-filtered= "filtered" >)<br data-filtered= "filtered" >func say(s string) {<br data-filtered= "filtered" >         for  i :=  0 ; i <  5 ; i++ {<br data-filtered= "filtered" >                runtime.Gosched()<br data-filtered= "filtered" >                fmt.Println(s)<br data-filtered= "filtered" >        }<br data-filtered= "filtered" >}<br data-filtered= "filtered" >func main() {<br data-filtered= "filtered" >        go say( "world" )<br data-filtered= "filtered" >        say( "end" )<br data-filtered= "filtered" >}<br data-filtered= "filtered" ></span>