8.服务调用: 使用插件、调用http api的正规姿势(初步)

我们先启动一个server然后再去调用server api

package main

import (
    "github.com/gin-gonic/gin"
    "github.com/micro/go-micro/registry"
    "github.com/micro/go-micro/web"
    "github.com/micro/go-plugins/registry/consul"
    "go-micro/ProdService"
)

func main() {
    consulReg := consul.NewRegistry( //新建一个consul注册的地址，也就是我们consul服务启动的机器ip+端口
        registry.Addrs("localhost:8500"),
    )
    ginRouter := gin.Default()
    ginRouter.Handle("GET", "/user", func(context *gin.Context) {
        context.String(200, "user api")
    })
    ginRouter.Handle("GET", "/news", func(context *gin.Context) {
        context.String(200, "news api")
    })

    v1Group := ginRouter.Group("/v1")
    {
        v1Group.Handle("POST", "/prods", func(context *gin.Context) {
            context.JSON(
                200,
                gin.H{
                    "data": ProdService.NewProdList(2),
                },
            )
        })
    }

    //其实下面这段代码的意义就是启动服务的同时把服务注册进consul中，做的是服务发现
    server := web.NewService( //go-micro很灵性的实现了注册和反注册，我们启动后直接ctrl+c退出这个server，它会自动帮我们实现反注册
        web.Name("prodservice"), //注册进consul服务中的service名字
        web.Address(":8088"), //注册进consul服务中的端口,也是这里我们gin的server地址
        web.Handler(ginRouter),  //web.Handler()返回一个Option，我们直接把ginRouter穿进去，就可以和gin完美的结合
        web.Registry(consulReg), //注册到哪个服务器伤的consul中
    )
    server.Init() //加了这句就可以使用命令行的形式去设置我们一些启动的配置
    server.Run()
}

首先先看我们在浏览器中请求server获取到的response长什么样

可以看到返回的是一个json，那么我们在客户端通过go-micro调用的时候也有一些细节，请仔细看下面代码注释

接下来是调用服务的代码

package main

import (
    "context"
    "fmt"
    "github.com/micro/go-micro/client"
    "github.com/micro/go-micro/client/selector"
    "github.com/micro/go-micro/registry"
    myhttp "github.com/micro/go-plugins/client/http"
    "github.com/micro/go-plugins/registry/consul"
    "log"
)
//重点在这里
func callAPI(s selector.Selector) {
    myCli := myhttp.NewClient(
        client.Selector(s),
        client.ContentType("application/json"), //因为我们要调用的/v1/prods这个api返回的是json，所以这里要先规定好数据格式json(很重要,如果是其他的会报错)
    )
    //下面这句代码封装了一个请求(未发送)
    req := myCli.NewRequest("prodservice", "/v1/prods", map[string]string{})//这里最后一个参数是body，一般用于post请求的参数，因为我们这个api没有参数，所以我随便写了map[string]string{}
    //从之前的图可以看到我们的返回值是一个json，key-val为"data":[],所以我们的response要构建一个相同结构的，方便go-micro帮我们返回响应结构体
    var resp map[string]interface{}
    err := myCli.Call(context.Background(), req, &resp) //发起请求调用，并返回结果
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(resp)
}

func main() {
    consulReg := consul.NewRegistry(
        registry.Addrs("localhost:8500"),
    )
    mySelector := selector.NewSelector(
        selector.Registry(consulReg),
        selector.SetStrategy(selector.RoundRobin), //设置查询策略，这里是轮询
    )
    callAPI(mySelector)
}

来自为知笔记(Wiz)