gin-gonic Go輕量級restful服務(wù)

資源目錄

https://github.com/gin-gonic

https://github.com/gin-gonic/gin#quick-start

package main

import (
    "fmt"
    "github.com/gin-gonic/gin"
)
type RequestBody struct {
    Hello string `json:"hello"`
}

func main(){
    fmt.Println("http server setup")
    r := gin.Default()
    r.POST("/hello", helloHandler)
    _ = r.Run() // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")
}

func helloHandler (context *gin.Context) {
    var req RequestBody
    param1 := context.Query("id")
    fmt.Printf("receive param1 : %s\n",param1)
    if err := context.ShouldBindJSON(&req); err != nil{

        context.JSON(500,gin.H{
            "status":-1,
            "message":"request error",
            "success":false,
        })
    }
    fmt.Printf("receive jsonbody : %s\n",req.Hello)
    context.JSON(200,gin.H{
        "status":0,
        "message":"success",
        "success":true,
    })
}

指定port

_ = r.Run(":8081")

啟動完成之后丰包,就可以使用HTTP工具進行訪問尉尾,如同一個tomcat长豁,而且比較輕量級。

一般Json請求的處理方式

package main

import (
    "errors"
    "github.com/gin-gonic/gin"
    "log"
)
type RequestBody struct {
    Hello string `json:"hello"`
}

func main(){
    log.Println("http server setup")
    r := gin.Default()
    r.POST("/hello/:id" , jsonApi(helloHandler))
    _ = r.Run(":8081") // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")

}
type Any interface {}
type HandlerFunc func(*gin.Context)(Any,error)

func jsonApi(handler HandlerFunc) gin.HandlerFunc{
    return func(c *gin.Context) {
        id := c.Param("id")
        log.Printf("id : %v\n", id)
        code := 200
        var resMap  = make(map[string]interface{})
        out,err := handler(c)
        if err != nil{
            code = 500
            resMap["message"] = err.Error()
            resMap["success"] = false
        } else {
            resMap["message"] = out
            resMap["success"] = true
        }
        c.JSON(code,resMap)
    }
}

func helloHandler (context *gin.Context)(Any,error) {

    type Result struct {
        Status int `json:"status"`
        GetMessage string `json:"get_message"`
    }
    type Request struct {
        Name string `json:"name"`
    }
    var req Request
    if err := context.ShouldBindJSON(&req); err != nil{
        log.Fatalf("get an error %v\n",err)
        return nil,err
    }

    log.Printf("helloHandler get name %v\n",req.Name)
    if req.Name == "exp"{
        return nil,errors.New("this is a target error")
    }else{
         result := &Result{
            Status: 200,
            GetMessage: req.Name,
        }
        return result,nil
    }
}


上傳文件

// 上傳文件
func upload(context *gin.Context)(Any,error) {

    type Response struct {
        Status int `json:"status"`
    }

    file,header,err := context.Request.FormFile("img")
    if err != nil{
        log.Fatalf("file read error,%v\n",err)
        return nil,err
    }
    log.Printf("get file name : %v\n",header.Filename)
    log.Printf("file size : %v\n",header.Size)
    data,_:= ioutil.ReadAll(file)
    defer file.Close()
    if strings.HasSuffix(header.Filename,".txt") {
        content := string(data)
        log.Printf("content : %v\n",content)
    }
    resp := &Response{
        Status: 200,
    }
    return resp,nil
}

websocket功能

Server.GET("/ping" , Ping)
// websocket 協(xié)議
func Ping(context * gin.Context){
    // 升級協(xié)議
    ws,err := upGrader.Upgrade(context.Writer,context.Request,nil)
    if err != nil {
        log.Printf("get an error on connecting: %v\n",err)
        return
    }
    defer ws.Close()
    for{
        mt,message,err := ws.ReadMessage()
        str := string(message)
        if err != nil{
            log.Printf("get an error : %v\n",err)
        }
        log.Printf("get message type : %v\n",mt)
        log.Printf("get message : %v\n",str)

        var resp []byte
        if str == "ping"{
            resp = []byte("pong")
        } else if str == "exit"{
            resp = []byte("bye")
        } else {
            resp = message
        }
        err = ws.WriteMessage(mt,resp)
        if err != nil || str == "exit"{
            break
        }
    }
}

客戶端我就抄了一個可用的损肛,畢竟我不會寫

<html>
<head>
<title>Golang Chat</title>
<script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.2/jquery.min.js"></script>
<script type="text/javascript">
    $(function() {

    var conn;
    var msg = $("#msg");
    var log = $("#log");

    function appendLog(msg) {
        var d = log[0]
        var doScroll = d.scrollTop == d.scrollHeight - d.clientHeight;
        msg.appendTo(log)
        if (doScroll) {
            d.scrollTop = d.scrollHeight - d.clientHeight;
        }
    }

    $("#form").submit(function() {
        if (!conn) {
            return false;
        }
        if (!msg.val()) {
            return false;
        }
        conn.send(msg.val());
        msg.val("");
        return false
    });

    if (window["WebSocket"]) {
        conn = new WebSocket("ws://localhost:8081/ping");
        conn.onclose = function(evt) {
            appendLog($("<div><b>Connection Closed.</b></div>"))
        }
        conn.onmessage = function(evt) {
            appendLog($("<div/>").text(evt.data))
        }
    } else {
        appendLog($("<div><b>WebSockets Not Support.</b></div>"))
    }
    });
</script>
<style type="text/css">
html {
    overflow: hidden;
}

body {
    overflow: hidden;
    padding: 0;
    margin: 0;
    width: 100%;
    height: 100%;
    background: gray;
}

#log {
    background: white;
    margin: 0;
    padding: 0.5em 0.5em 0.5em 0.5em;
    position: absolute;
    top: 0.5em;
    left: 0.5em;
    right: 0.5em;
    bottom: 3em;
    overflow: auto;
}

#form {
    padding: 0 0.5em 0 0.5em;
    margin: 0;
    position: absolute;
    bottom: 1em;
    left: 0px;
    width: 100%;
    overflow: hidden;
}

</style>
</head>
<body>
<div id="log"></div>
<form id="form">
    <input type="submit" value="發(fā)送" />
    <input type="text" id="msg" size="64"/>
</form>
</body>
</html>
image.png
image.png
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子拴泌,更是在濱河造成了極大的恐慌贱案,老刑警劉巖肛炮,帶你破解...
    沈念sama閱讀 222,681評論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異宝踪,居然都是意外死亡侨糟,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,205評論 3 399
  • 文/潘曉璐 我一進店門瘩燥,熙熙樓的掌柜王于貴愁眉苦臉地迎上來秕重,“玉大人,你說我怎么就攤上這事厉膀∪茉牛” “怎么了?”我有些...
    開封第一講書人閱讀 169,421評論 0 362
  • 文/不壞的土叔 我叫張陵服鹅,是天一觀的道長凳兵。 經(jīng)常有香客問我,道長企软,這世上最難降的妖魔是什么庐扫? 我笑而不...
    開封第一講書人閱讀 60,114評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮仗哨,結(jié)果婚禮上形庭,老公的妹妹穿的比我還像新娘。我一直安慰自己藻治,他們只是感情好碘勉,可當我...
    茶點故事閱讀 69,116評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著桩卵,像睡著了一般验靡。 火紅的嫁衣襯著肌膚如雪倍宾。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,713評論 1 312
  • 那天胜嗓,我揣著相機與錄音高职,去河邊找鬼。 笑死辞州,一個胖子當著我的面吹牛怔锌,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播变过,決...
    沈念sama閱讀 41,170評論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼埃元,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了媚狰?” 一聲冷哼從身側(cè)響起岛杀,我...
    開封第一講書人閱讀 40,116評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎崭孤,沒想到半個月后类嗤,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,651評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡辨宠,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,714評論 3 342
  • 正文 我和宋清朗相戀三年遗锣,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片嗤形。...
    茶點故事閱讀 40,865評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡精偿,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出派殷,到底是詐尸還是另有隱情还最,我是刑警寧澤,帶...
    沈念sama閱讀 36,527評論 5 351
  • 正文 年R本政府宣布毡惜,位于F島的核電站拓轻,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏经伙。R本人自食惡果不足惜扶叉,卻給世界環(huán)境...
    茶點故事閱讀 42,211評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望帕膜。 院中可真熱鬧枣氧,春花似錦、人聲如沸垮刹。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,699評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽荒典。三九已至酪劫,卻和暖如春吞鸭,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背覆糟。 一陣腳步聲響...
    開封第一講書人閱讀 33,814評論 1 274
  • 我被黑心中介騙來泰國打工刻剥, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人滩字。 一個月前我還...
    沈念sama閱讀 49,299評論 3 379
  • 正文 我出身青樓造虏,卻偏偏與公主長得像,于是被迫代替她去往敵國和親麦箍。 傳聞我的和親對象是個殘疾皇子漓藕,可洞房花燭夜當晚...
    茶點故事閱讀 45,870評論 2 361