婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av

主頁 > 知識庫 > golang 實現一個restful微服務的操作

golang 實現一個restful微服務的操作

熱門標簽:評價高的400電話辦理 涿州代理外呼系統 電話機器人軟件免費 百度地圖標注后傳給手機 excel地圖標注分布數據 外呼系統顯本地手機號 壽光微信地圖標注 阿克蘇地圖標注 外呼系統用什么卡

如何用net/http構建一個簡單的web服務

Golang提供了簡潔的方法來構建web服務

package main 
import (
    "net/http"
)
 
func HelloResponse(rw http.ResponseWriter, request *http.Request) {
    fmt.Fprintf(w, "Hello world.")
}
 
func main() {
    http.HandleFunc("/", HelloResponse)
    http.ListenAndServe(":3000", nil)
}

其中核心的兩個方法:

func HandleFunc(pattern string, handler func(ResponseWriter, *Request)):HandleFunc注冊一個handler function對應到給定的pattern。

func ListenAndServe(addr string, handler Handler) error:ListenAndServe監聽給定的TCP網絡地址,接著帶上handler調用Serve方法來接收請求。

在go build之后,執行編譯后的文件就能在客戶端看到hello world了

有了web服務,就可以制定小目標了

我認為作為第一版本,不需要復雜的設計,只需要接收到用戶的請求,并且找到對應的handler,執行其邏輯,然后返回JSON響應就好了。

小目標有了,那怎么實現呢?

1.設計用戶如何注冊Controller和Action

據我觀察,一些框架是在Controller里預先設定了GET,POST,PUT等一系列方法,負責接收GET,POST,PUT的HTTP請求。

我認為這樣設計的確有其優勢,因為用戶只需要實現這些方法就好了,但在業務層面也有其劣勢,因為我們沒有辦法保證負責一個頁面或者功能的Controller只接收一個GET請求,如果有2個GET請求,那就需要再建立一個Controller,單單實現其GET方法。

因此我借鑒了PHP社區中Laravel注冊Controller和Action的語法:Get("/", "IndexController@Index")。

用戶只需要定義:

type IndexController struct {
}
 
func (IndexController *IndexController) Index(//params) (//return values) {
}

當然這樣思考后,就給框架帶入了一點動態腳本語言的特性,肯定會用到Golang的reflect庫。

2.設計Path和Controller還有Action的關系容器

我運用了Golang的map,定義了map[string]map[string]map[string]string這樣的數據結構

以["/":["GET":["IndexController":"Get"], "POST":["IndexController":"Post"]], "/foo":["GET":["IndexController":"Foo"]]]舉例:

這個說明了在"/"這個PATH下面,有GET和POST請求,分別對應了IndexController下的Get和Post方法,在"/foo"這個PATH下面,有GET請求,對應IndexController下的Foo方法。

在接受請求時候,如果沒有找到對應的方法,就返回405。

3.如何將注冊了的一系列Method與PATH綁定來接收外部請求

我們可以看到,func HandleFunc(pattern string, handler func(ResponseWriter, *Request))要求的handler類型是func(ResponseWriter, *Request)),這和我們設計的functionfunc (IndexController *IndexController) Index(//params) (//return values) {}有所差距。

這時候我發現由于Golang具備First Class Functions特性,因此我們可以將函數做如下處理:

http.HandleFunc(path, HandleRequest()) 
func HandleRequest() {
    return func(rw http.ResponseWriter, request *http.Request) {
        // do your logic
    }
}

4.和encoding/json說Hi

當我們接收到function的返回值后,我們就需要對結果進行json encode,而encoding/json正是負責這個功能。 我用的是json.Marshal():

func Marshal(v interface{}) ([]byte, error): Marshal返回v的encoding結果。

如何使用

package main 
import (
    "net/url"
    "net/http"
    "github.com/ZhenhangTung/GoGym"
)
 
type IndexController struct {
}
 
func (IndexController *IndexController) Index(request map[string]url.Values, headers http.Header) (statusCode int, response interface{}) {
    return 200, map[string]string{"hello": "world"}
}
 
type BarController struct {
}
 
func (*BarController) Bar(request map[string]url.Values, headers http.Header) (statusCode int, response interface{}, responseHeader http.Header) {
    return 200, map[string]string{"GoTo": "Bar"}, http.Header{"Foo": {"Bar", "Baz"}}
}
 
func main() {
    var apiService = GoGym.Prepare()
    apiService.Get("index", "IndexController@Index")
    apiService.Post("bar", "BarController@Bar")
    controllers := []interface{}{IndexController{}}
    apiService.RegisterControllers(controllers)
    apiService.RegisterController(BarController{})
    apiService.Serve(3000)
}

項目完整代碼

package GoGym 
import (
    "encoding/json"
    "fmt"
    "net/http"
    "net/url"
    "reflect"
    "strings"
)
 
const (
    GETMethod     = "GET"
    POSTMethod    = "POST"
    PUTMethod     = "PUT"
    PATCHMethod   = "PATCH"
    DELETEMethod  = "DELETE"
    OPTIONSMethod = "OPTIONS"
)
 
const (
    HTTPMethodNotAllowed = 405
)
 
// APIService for now is the struct for containing controllerRegistry and registeredPathAndController,
// and it is the core service provider
type APIService struct {
    // controllerRegistry is where all registered controllers exist
    controllerRegistry map[string]interface{}
    //registeredPathAndController is a mapping of paths and controllers
    registeredPathAndController map[string]map[string]map[string]string
    requestForm                 map[string]url.Values
}
 
func (api *APIService) Get(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(GETMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
func (api *APIService) Post(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(POSTMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
func (api *APIService) Put(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(PUTMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
func (api *APIService) Patch(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(PATCHMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
func (api *APIService) Options(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(OPTIONSMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
func (api *APIService) Delete(path, controllerWithActionString string) {
    mapping := api.mappingRequestMethodWithControllerAndActions(DELETEMethod, path, controllerWithActionString)
    api.registeredPathAndController[path] = mapping
}
 
// mappingRequestMethodWithControllerAndActions is a function for mapping request method with controllers
// which containing actions
func (api *APIService) mappingRequestMethodWithControllerAndActions(requestMethod, path, controllerWithActionString string) map[string]map[string]string {
    mappingResult := make(map[string]map[string]string)
    if length := len(api.registeredPathAndController[path]); length > 0 {
        mappingResult = api.registeredPathAndController[path]
    }
    controllerAndActionSlice := strings.Split(controllerWithActionString, "@")
    controller := controllerAndActionSlice[0]
    action := controllerAndActionSlice[1]
    controllerAndActionMap := map[string]string{controller: action}
    mappingResult[requestMethod] = controllerAndActionMap
    return mappingResult
}
 
// HandleRequest is a function to handle http request
func (api *APIService) HandleRequest(controllers map[string]map[string]string) http.HandlerFunc {
    return func(rw http.ResponseWriter, request *http.Request) {
        request.ParseForm()
        method := request.Method
        api.requestForm["query"] = request.Form
        api.requestForm["form"] = request.PostForm
        macthedControllers, ok := controllers[method]
        if !ok {
            rw.WriteHeader(HTTPMethodNotAllowed)
        }
        for k, v := range macthedControllers {
            controllerKey := "*" + k
            controller := api.controllerRegistry[controllerKey]
            in := make([]reflect.Value, 2)
            in[0] = reflect.ValueOf(api.requestForm)
            in[1] = reflect.ValueOf(request.Header)
            returnValues := reflect.ValueOf(controller).MethodByName(v).Call(in)
            statusCode := returnValues[0].Interface()
            intStatusCode := statusCode.(int)
            response := returnValues[1].Interface()
            responseHeaders := http.Header{}
            if len(returnValues) == 3 {
                responseHeaders = returnValues[2].Interface().(http.Header)
            }
            api.JSONResponse(rw, intStatusCode, response, responseHeaders)
        }
    }
}
 
// RegisterHandleFunc is a function registers a handle function to handle request from path
func (api *APIService) RegisterHandleFunc() {
    for k, v := range api.registeredPathAndController {
        path := k
        if !strings.HasPrefix(k, "/") {
            path = fmt.Sprintf("/%v", k)
        }
        http.HandleFunc(path, api.HandleRequest(v))
    }
}
 
// RegisterControllers is a function registers a struct of controllers into controllerRegistry
func (api *APIService) RegisterControllers(controllers []interface{}) {
    for _, v := range controllers {
        api.RegisterController(v)
    }
}
 
// RegisterControllers is a function registers a controller into controllerRegistry
func (api *APIService) RegisterController(controller interface{}) {
    controllerType := getType(controller)
    api.controllerRegistry[controllerType] = controller
}
 
// getType is a function gets the type of value
func getType(value interface{}) string {
    if t := reflect.TypeOf(value); t.Kind() == reflect.Ptr {
        return "*" + t.Elem().Name()
    } else {
        return t.Name()
    }
}
 
// Serve is a function
func (api *APIService) Serve(port int) {
    api.RegisterHandleFunc()
    fullPort := fmt.Sprintf(":%d", port)
    http.ListenAndServe(fullPort, nil)
}
 
// JSONResponse is a function return json response
func (api *APIService) JSONResponse(rw http.ResponseWriter, statusCode int, response interface{}, headers http.Header) {
    for k, v := range headers {
        for _, header := range v {
            rw.Header().Add(k, header)
        }
    }
    rw.Header().Add("Content-Type", "application/json")
    rw.WriteHeader(statusCode)
    rsp, err := json.Marshal(response)
    if err != nil {
        // TODO: logging error
        fmt.Println("JSON err:", err)
    }
    rw.Write(rsp)
}
 
// Prepare is a fucntion prepare the service and return prepared service to the user
func Prepare() *APIService {
    var apiService = new(APIService)
    apiService.controllerRegistry = make(map[string]interface{})
    apiService.registeredPathAndController = make(map[string]map[string]map[string]string)
    apiService.requestForm = make(map[string]url.Values)
    return apiService
}

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • Java從單體架構升級到微服務要注意的一些問題
  • 詳解Java 微服務架構
  • 了解java架構之微服務架構—雪崩效應
  • 通過lms.samples熟悉lms微服務框架的使用詳解
  • SpringCloud搭建netflix-eureka微服務集群的過程詳解
  • SpringCloud讓微服務實現指定程序調用
  • Spring Cloud Stream微服務消息框架原理及實例解析
  • 詳解多云架構下的JAVA微服務技術解析

標簽:銅川 欽州 蘭州 梅河口 吐魯番 雞西 重慶 汕頭

巨人網絡通訊聲明:本文標題《golang 實現一個restful微服務的操作》,本文關鍵詞  golang,實現,一個,restful,微,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《golang 實現一個restful微服務的操作》相關的同類信息!
  • 本頁收集關于golang 實現一個restful微服務的操作的相關信息資訊供網民參考!
  • 推薦文章
    婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av
    日韩中文字幕一区二区三区| 精品三级在线观看| 久88久久88久久久| 中文字幕一区二区三区不卡 | 日本成人中文字幕在线视频| 欧美丰满一区二区免费视频| 成人免费三级在线| 国产综合色视频| 日本vs亚洲vs韩国一区三区| 亚洲丝袜自拍清纯另类| 国产农村妇女精品| 日韩欧美一级精品久久| 91.xcao| 91丨porny丨国产| 国产福利一区二区三区| 亚洲高清久久久| 成人欧美一区二区三区| 2欧美一区二区三区在线观看视频 337p粉嫩大胆噜噜噜噜噜91av | 亚洲啪啪综合av一区二区三区| 欧美成人一区二区三区| 欧美精品久久久久久久久老牛影院 | 欧美电影免费观看高清完整版| 日本高清不卡aⅴ免费网站| 韩国v欧美v亚洲v日本v| 日韩av网站在线观看| 亚洲一区二区精品3399| 一区二区三区日本| 久久亚洲一级片| 欧美大片免费久久精品三p| 欧美一级片免费看| 日韩一二三四区| 久久综合色播五月| 久久精品在这里| 精品裸体舞一区二区三区| 日韩一级大片在线观看| 精品国产网站在线观看| 26uuu久久天堂性欧美| 精品剧情v国产在线观看在线| 精品成人免费观看| 日韩欧美国产系列| 国产日韩精品一区二区三区| 精品久久久三级丝袜| 日本一区二区三区在线观看| 国产精品另类一区| 国产精品美女久久久久久2018 | 亚洲日本va午夜在线电影| 亚洲婷婷国产精品电影人久久| 亚洲精品视频一区二区| 日韩制服丝袜先锋影音| 久久99精品久久只有精品| 粉嫩av一区二区三区粉嫩| 99国产精品国产精品毛片| 欧美日韩一级片在线观看| 日韩美女在线视频| 1区2区3区欧美| 亚洲动漫第一页| 国产乱一区二区| 色菇凉天天综合网| 777午夜精品视频在线播放| 2017欧美狠狠色| 亚洲综合丁香婷婷六月香| 久久不见久久见免费视频7| 粉嫩绯色av一区二区在线观看| 懂色av一区二区在线播放| 欧美日韩黄视频| 国产精品天美传媒沈樵| 亚洲香蕉伊在人在线观| 国产盗摄女厕一区二区三区| 色综合久久综合网| 国产欧美日产一区| 免费三级欧美电影| 91日韩一区二区三区| 国产视频一区二区在线| 日韩电影在线免费看| 国产成人综合亚洲网站| 欧美少妇一区二区| 一区在线观看免费| 国产精品一区二区久激情瑜伽| 欧美午夜片在线看| 亚洲激情自拍视频| 99这里只有精品| 亚洲精品免费在线播放| 欧美怡红院视频| 亚洲图片自拍偷拍| 欧美一级黄色大片| 国产精品中文字幕日韩精品 | 蜜臀av性久久久久蜜臀aⅴ流畅| 欧美日韩国产a| 五月天欧美精品| 日韩视频免费观看高清完整版在线观看| 麻豆精品国产传媒mv男同| 亚洲精品在线三区| 国产·精品毛片| 亚洲精品国产a久久久久久| 欧美体内she精高潮| 老司机精品视频线观看86| 久久日韩粉嫩一区二区三区| 99精品久久久久久| 性感美女久久精品| 久久先锋资源网| 色哟哟一区二区三区| 婷婷六月综合网| 久久综合网色—综合色88| 99re热视频精品| 日韩精品电影一区亚洲| 欧美国产精品中文字幕| 欧美性色欧美a在线播放| 免费av成人在线| 1区2区3区精品视频| 日韩视频在线观看一区二区| 高清不卡一二三区| 首页国产丝袜综合| 国产精品欧美久久久久无广告 | 欧美三片在线视频观看| 久99久精品视频免费观看| 亚洲你懂的在线视频| 日韩午夜激情电影| 91麻豆精品视频| 国产一区欧美日韩| 亚洲福利一区二区三区| 国产精品欧美久久久久无广告| 在线观看91精品国产麻豆| 成人ar影院免费观看视频| 蜜臀av在线播放一区二区三区| 亚洲九九爱视频| 国产午夜精品一区二区三区嫩草| 欧美日韩精品一区视频| 99久久综合狠狠综合久久| 黄页网站大全一区二区| 午夜久久久久久| 亚洲精品一二三四区| 国产精品久久久久久久浪潮网站| 日韩欧美一区中文| 欧美视频一区二区三区在线观看| 91在线精品秘密一区二区| 国产一区欧美二区| 国产在线一区二区| 免费观看在线色综合| 亚洲国产成人精品视频| 亚洲精品国产一区二区精华液| 国产精品毛片大码女人| 久久久国产午夜精品| 日韩精品在线一区| 6080亚洲精品一区二区| 欧美午夜在线观看| 欧美写真视频网站| 欧美色精品天天在线观看视频| 91久久人澡人人添人人爽欧美| 96av麻豆蜜桃一区二区| 成人免费视频一区二区| 成人av免费观看| 99在线精品视频| 在线中文字幕不卡| 欧美日韩一区 二区 三区 久久精品| jlzzjlzz亚洲女人18| 91麻豆国产福利在线观看| 一本一道综合狠狠老| 色久综合一二码| 欧美三级韩国三级日本一级| 欧美日韩在线播| 91精品免费观看| 精品理论电影在线| 国产色91在线| 亚洲精品国产品国语在线app| 亚洲狼人国产精品| 日韩国产精品久久| 国产一区999| jizzjizzjizz欧美| 欧美日韩激情在线| 欧美变态tickle挠乳网站| 国产亚洲女人久久久久毛片| 国产欧美日韩视频一区二区| 亚洲视频在线一区二区| 亚洲第一二三四区| 黄色成人免费在线| 一本久久a久久免费精品不卡| 欧美高清www午色夜在线视频| 久久亚区不卡日本| 亚洲在线免费播放| 国产美女精品人人做人人爽| 99久久精品免费精品国产| 欧美日韩国产经典色站一区二区三区 | 国产另类ts人妖一区二区| 成人免费高清在线| 欧美性大战久久久| 久久久久久免费网| 亚洲一区在线看| 国产成人精品免费| 欧美日韩一本到| 国产亚洲女人久久久久毛片| 亚洲五月六月丁香激情| 高清不卡一二三区| 日韩一区二区三区四区| 最近中文字幕一区二区三区| 捆绑紧缚一区二区三区视频 | 日韩精品一区二区三区在线观看| 日本一区二区不卡视频| 奇米影视在线99精品| 一道本成人在线| 久久久久久久久久久久久女国产乱 |