從大型微服務(wù)圖看API網(wǎng)關(guān)

圖來(lái)源

image.png

圖來(lái)源

image.png

充上面看我們的Api網(wǎng)關(guān)要做的事情還是挺多：

image.png

Mciro 提供的插件形式示例

1:新建一個(gè)網(wǎng)關(guān)的項(xiàng)目結(jié)構(gòu)

image.png

新增一個(gè)用戶多個(gè)插件的注冊(cè)順序的演示

image.png

2:定義一個(gè)插件auth.go

package auth

import (
    "github.com/micro/cli/v2"
    "github.com/micro/micro/v2/plugin"
    "log"
    "net/http"
)

func NewPlugin() plugin.Plugin {

    return plugin.NewPlugin(
        // 插件名
        plugin.WithName("example"),
        //查詢命令喊的一些參數(shù)說(shuō)明
        plugin.WithFlag(&cli.StringFlag{
            Name:   "example_flag",
            Usage:  "This is an example plugin flag",
            EnvVars: []string{"EXAMPLE_FLAG"},
            Value: "avalue",
        }),
        // 配置插件初始化操作，cli.Context中包含了項(xiàng)目啟動(dòng)參數(shù)
        plugin.WithInit(func(ctx *cli.Context) error {
            println("我是自定義的認(rèn)證中間件處理器-----------------------")
            log.Println("Got value for example_flag", ctx.String("example_flag"))
            return nil
        }),
        // 配置處理函數(shù)，注意與wrapper不同，他的參數(shù)是http包的ResponseWriter和Request
        plugin.WithHandler(cAuthWrapper()),
    )
}

//查詢需要處理的事情
func cAuthWrapper() plugin.Handler {
    return func(h http.Handler) http.Handler {
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            println("進(jìn)去進(jìn)來(lái)到了認(rèn)證中間件來(lái)了！")

            //這個(gè)地方很關(guān)鍵----必須執(zhí)行下面這一步，保證其他插件和業(yè)務(wù)代碼的執(zhí)行，否則沒(méi)有響應(yīng)體返回
            h.ServeHTTP(w, r)
        })
    }
}

2:定義一個(gè)插件auth2.go

package auth

import (
    "github.com/micro/cli/v2"
    "github.com/micro/micro/v2/plugin"
    "log"
    "net/http"
)

func NewPlugin2() plugin.Plugin {

    return plugin.NewPlugin(
        // 插件名
        plugin.WithName("example"),
        //查詢命令喊的一些參數(shù)說(shuō)明
        plugin.WithFlag(&cli.StringFlag{
            Name:   "example_flag",
            Usage:  "This is an example plugin flag",
            EnvVars: []string{"EXAMPLE_FLAG"},
            Value: "avalue",
        }),
        // 配置插件初始化操作，cli.Context中包含了項(xiàng)目啟動(dòng)參數(shù)
        plugin.WithInit(func(ctx *cli.Context) error {
            println("我是自定義的認(rèn)證中間件處理器222222-----------------------")
            log.Println("Got value for example_flag", ctx.String("example_flag"))
            return nil
        }),
        // 配置處理函數(shù)，注意與wrapper不同，他的參數(shù)是http包的ResponseWriter和Request
        plugin.WithHandler(cAuthWrapper2()),
    )
}

//查詢需要處理的事情
func cAuthWrapper2() plugin.Handler {
    return func(h http.Handler) http.Handler {
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            println("進(jìn)去進(jìn)來(lái)到了認(rèn)證中間件來(lái)了222222222！")

            //這個(gè)地方很關(guān)鍵----必須執(zhí)行下面這一步，保證其他插件和業(yè)務(wù)代碼的執(zhí)行，否則沒(méi)有響應(yīng)體返回
            h.ServeHTTP(w, r)
        })
    }
}

3:注冊(cè)插件，在我們的main.go里面注冊(cè)我們的插件

package main

import (
    "github.com/micro/micro/v2/client/api"
    "github.com/micro/micro/v2/cmd"
    "github.com/micro/micro/v2/plugin"
    "micro/plugins/auth"
)

func main()  {

    //第一種方式
    err := api.Register(auth.NewPlugin())
    if err != nil {
        //log.Fatal("auth register")
    }

    // 第二種方式：
    err =plugin.Register(auth.NewPlugin2())
    if err != nil {
        //log.Fatal("auth register")
    }
    cmd.Init()
}

4:啟動(dòng)我們的網(wǎng)關(guān)，主要相關(guān)的啟動(dòng)命令參數(shù)使用（后面參數(shù)不可缺）：

PS: 后面的參數(shù)不可缺不然會(huì)提示相關(guān)的錯(cuò)誤命令

D:\code\go\micro-greeter\api-gateway>go run main.go
我是自定義的認(rèn)證中間件處理器222222-----------------------
2021-01-28 17:08:58.552198 I | Got value for example_flag avalue
No command provided to micro. Please refer to 'micro --help'
exit status 1

正確的啟動(dòng)網(wǎng)關(guān)命令：

go run main.go --registry=etcd --registry_address=192.168.219.130:2379 api --address=0.0.0.0:9000 --namespace=go.micro --type=service

查看我們的啟動(dòng)日志：

D:\code\go\micro-greeter\api-gateway>go run main.go --registry=etcd --registry_address=192.168.219.130:2379  api --address=0.0.0.0:9000 --namespace=go.micro --type=service
我是自定義的認(rèn)證中間件處理器222222-----------------------
2021-01-28 17:10:19.689117 I | Got value for example_flag avalue
我是自定義的認(rèn)證中間件處理器-----------------------
2021-01-28 17:10:19.731005 I | Got value for example_flag avalue
2021-01-28 17:10:19  file=api/api.go:285 level=info service=api Registering API Default Handler at /
2021-01-28 17:10:19  file=http/http.go:90 level=info service=api HTTP API Listening on [::]:9000
2021-01-28 17:10:19  file=v2@v2.9.1/service.go:200 level=info service=api Starting [service] go.micro.api
2021-01-28 17:10:19  file=grpc/grpc.go:864 level=info service=api Server [grpc] Listening on [::]:62154
2021-01-28 17:10:19  file=grpc/grpc.go:697 level=info service=api Registry [etcd] Registering node: go.micro.api-b10fb08b-5834-4316-9690-2109eaca1899

最后注冊(cè)的，先執(zhí)行的安裝！

此時(shí)我們?cè)L問(wèn)我們的API接口：http://localhost:9000/greeter/call

2021-01-28 17:10:19.731005 I | Got value for example_flag avalue
2021-01-28 17:10:19  file=api/api.go:285 level=info service=api Registering API Default Handler at /
2021-01-28 17:10:19  file=http/http.go:90 level=info service=api HTTP API Listening on [::]:9000
2021-01-28 17:10:19  file=v2@v2.9.1/service.go:200 level=info service=api Starting [service] go.micro.api
2021-01-28 17:10:19  file=grpc/grpc.go:864 level=info service=api Server [grpc] Listening on [::]:62154
2021-01-28 17:10:19  file=grpc/grpc.go:697 level=info service=api Registry [etcd] Registering node: go.micro.api-b10fb08b-5834-4316-9690-2109eaca1899
進(jìn)去進(jìn)來(lái)到了認(rèn)證中間件來(lái)了！
進(jìn)去進(jìn)來(lái)到了認(rèn)證中間件來(lái)了222222222！
::1 - - [28/Jan/2021:17:10:47 +0800] "GET /greeter/call HTTP/1.1" 200 16 "" "PostmanRuntime/7.26.8"

發(fā)現(xiàn)先注冊(cè)的，先進(jìn)入?。。?！應(yīng)該也是遵循中間件洋蔥模型形式！??！

這樣我們的就可以隨心所欲定制或加入我們的自己插件或第三方寫(xiě)好的插件了?。。。?！