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

请到我的个人博客看golang rest相关文章 聽聽http://xiaorui.cc

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

已经转到:聽

http://xiaorui.cc/2014/10/25/%E5%85%B3%E4%BA%8Ego%E8%AF%AD%E8%A8%80%E5%9C%A8%E6%9C%8D%E5%8A%A1%E7%AB%AF%E5%81%9Arestful%E6%8E%A5%E5%8F%A3%E5%92%8Csocket%E9%80%9A%E4%BF%A1/

下图即是REST的架构图：

当REST架构的约束条件作为一个整体应用时，将生成一个可以扩展到大量客户端的应用程序。它还降低了客户端和服务器之间的交互延迟。统一界面简化了整个系统架构，改进了子系统之间交互的可见性。REST简化了客户端和服务器的实现，而且对于使用REST开发的应用程序更加容易扩展。

其实说白了，就是根据不同的方法，来分类不同的任务~

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

结果：

接着咱们再说下 go的socket 。

客户端的情况

服务端的情况：

server.go

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

client.go

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

Go的并发模式

package main
import (
 聽 聽 聽 聽"fmt"
 聽 聽 聽 聽"runtime"
)
func say(s string) {
 聽 聽 聽 聽for i := 0; i < 5; i++ {
 聽 聽 聽 聽 聽 聽 聽 聽runtime.Gosched()
 聽 聽 聽 聽 聽 聽 聽 聽fmt.Println(s)
 聽 聽 聽 聽}
}
func main() {
 聽 聽 聽 聽go say("world")
 聽 聽 聽 聽say("end")
}

结果：

本文出自 “峰云，就她了。” 博客，谢绝转载！

有疑问加站长微信联系（非本文作者）