关于Go语言在服务端做Restful接口和socket通信
关于Go语言在服务端做Restful接口和socket通信
李海彬
发布于 2018-03-22 15:01:50
发布于 2018-03-22 15:01:50
关于REST的定义，我就不扯了~ 大家可以看我以前的博文。
下图即是REST的架构图：
当REST架构的约束条件作为一个整体应用时，将生成一个可以扩展到大量客户端的应用程序。它还降低了客户端和服务器之间的交互延迟。统一界面简化了整个系统架构，改进了子系统之间交互的可见性。REST简化了客户端和服务器的实现，而且对于使用REST开发的应用程序更加容易扩展。
其实说白了，就是根据不同的方法，来分类不同的任务~
package mainimport (
"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.ccfunc 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 mainimport (
"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 mainimport (
"fmt"
"net"
"os")var str stringvar 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 mainimport (
"fmt"
"runtime")func say(s string) {
for i := 0; i < 5; i++ {
runtime.Gosched()
fmt.Println(s)
}}func main() {
go say("world")
say("end")}这里就简单的讲讲，深入的话，大家自己找官方的资料。
本文参与 腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2016-08-09，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读