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

rfyiamcool · · 140 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

请到我的个人博客看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的架构图:

164501711.png


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

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


165521917.png


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


结果:

164646894.jpg


接着咱们再说下 go的socket 。

客户端的情况

164847759.jpg


服务端的情况:

164930482.jpg


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")
}


结果:

165326909.jpg


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

本文来自:51CTO博客

感谢作者:rfyiamcool

查看原文:关于Go语言在服务端做Restful接口和socket通信

140 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传