本文是基于上一篇【go-micro+gin+consul微服務(wù)實戰(zhàn)之服務(wù)注冊與發(fā)現(xiàn)】的藤韵，沒看過的同學(xué)，請移步：http://www.reibang.com/p/757dc1bb3930
我們在使用微服務(wù)構(gòu)建系統(tǒng)時躲查，必然會用到http api它浅，下面介紹下，在如何使用go-micro自帶的http庫構(gòu)建http api 請求
我們還使用上一篇【go-micro+gin+consul微服務(wù)實戰(zhàn)之服務(wù)注冊與發(fā)現(xiàn)】中的orderserver和userserver作為示例镣煮。
看過上一篇的姐霍，就會注意到我們有一段代碼使用了http請求，如下：
//獲取服務(wù)地址
hostAddress := GetServiceAddr("userserver")
if len(hostAddress) <= 0{
fmt.Println("hostAddress is null")
}else{
url := "http://"+ hostAddress + "/users"
response, _ := http.Post(url, "application/json;charset=utf-8",bytes.NewBuffer([]byte("")))
fmt.Println(response)
}
這里我們使用的是 golang的【net/http】包典唇，來實現(xiàn)的镊折，過程相對復(fù)雜，因為需要使用GetServiceAddr("userserver")現(xiàn)獲取到userserver的地址介衔。
在GetServiceAddr中我們使用for的方式來獲取恨胚，代碼復(fù)雜，如下：
func GetServiceAddr(serviceName string)(address string){
var retryCount int
for{
servers,err :=consulReg.GetService(serviceName)
if err !=nil {
fmt.Println(err.Error())
}
var services []*registry.Service
for _,value := range servers{
fmt.Println(value.Name, ":", value.Version)
services = append(services, value)
}
next := selector.RoundRobin(services)
if node , err := next();err == nil{
address = node.Address
}
if len(address) > 0{
return
}
//重試次數(shù)++
retryCount++
time.Sleep(time.Second * 1)
//重試5次為獲取返回空
if retryCount >= 5{
return
}
}
}
下面我們使用go-micro中自帶的http包來實現(xiàn)http api請求
設(shè)計的包有
"github.com/micro/go-micro/client"
"github.com/micro/go-micro/client/selector"
"github.com/micro/go-plugins/client/http"
實現(xiàn)代碼如下：
func main() {
//初始化路由
ginRouter := routers.InitRouters()
//新建一個consul注冊的地址炎咖，也就是我們consul服務(wù)啟動的機器ip+端口
consulReg = consul.NewRegistry(
registry.Addrs("192.168.109.131:8500"),
)
//注冊服務(wù)
microService:= web.NewService(
web.Name("orderserver"),
//web.RegisterTTL(time.Second*30),//設(shè)置注冊服務(wù)的過期時間
//web.RegisterInterval(time.Second*20),//設(shè)置間隔多久再次注冊服務(wù)
web.Address(":18002"),
web.Handler(ginRouter),
web.Registry(consulReg),
)
microselector := selector.NewSelector(
selector.Registry(consulReg),//傳入consul注冊
selector.SetStrategy(selector.RoundRobin),//指定查詢機制
)
microClient := microhttp.NewClient(
client.Selector(microselector),
client.ContentType("application/json"))
req:=microClient.NewRequest("userserver", "/users",map[string]string{})
var resp map[string]interface{}
err := microClient.Call(context.Background(), req, &resp)
if err == nil{
fmt.Println(resp)
}
microService.Run()
}
核心代碼是這段
microselector := selector.NewSelector(
selector.Registry(consulReg),//傳入consul注冊
selector.SetStrategy(selector.RoundRobin),//指定查詢機制
)
microClient := microhttp.NewClient(
client.Selector(microselector),
client.ContentType("application/json"))
req:=microClient.NewRequest("userserver", "/users",map[string]string{})
var resp map[string]interface{}
err := microClient.Call(context.Background(), req, &resp)
if err == nil{
fmt.Println(resp)
}
這里需要注意赃泡，這種方式是依賴consul的，consulReg = consul.NewRegistry( registry.Addrs("192.168.109.131:8500"), )
這種實現(xiàn)共分為3步
第一步乘盼，構(gòu)建selectort升熊，通過指定selector.Registry(consulReg)就會去consul服務(wù)請求服務(wù)的地址；selector.SetStrategy(selector.RoundRobin)是指定獲取服務(wù)的策略緯輪詢的方式
第二步绸栅，構(gòu)建request請求级野，這里指定selector和ContentType，請求的服務(wù)名和接口名粹胯，map[string]string{}為請求參數(shù)蓖柔，這里我們傳空
第三步，請求接口风纠，調(diào)用Call函數(shù)况鸣，傳入請求，第一個參數(shù)默認傳空竹观，第三個參數(shù)是響應(yīng)的返回數(shù)據(jù)懒闷，這個是根據(jù)我們返回的數(shù)據(jù)格式定義的，我們在userserver的/users接口中返回的數(shù)據(jù)如下：
"status": "1",
"data": "get userinfos",
所以這里我們把resp定義為map[string]interface{}栈幸，你也可以根據(jù)自己的返回定義
到這里就完成請求http api 的實現(xiàn)，運行一下就可以看到效果
map[data:get userinfos status:1]
orderserver的完整代碼如下帮辟，userserver的可以在【go-micro+gin+consul微服務(wù)實戰(zhàn)之服務(wù)注冊與發(fā)現(xiàn)】中查看
orderserver代碼結(jié)構(gòu)如下：
image
main.go代碼如下
package main
import (
"context"
"fmt"
"github.com/micro/go-micro/client"
"github.com/micro/go-micro/client/selector"
"github.com/micro/go-micro/registry"
"github.com/micro/go-micro/web"
microhttp "github.com/micro/go-plugins/client/http"
"github.com/micro/go-plugins/registry/consul"
"orderserver/routers"
"time"
)
var consulReg registry.Registry
func init(){
}
func main() {
//初始化路由
ginRouter := routers.InitRouters()
//新建一個consul注冊的地址速址，也就是我們consul服務(wù)啟動的機器ip+端口
consulReg = consul.NewRegistry(
registry.Addrs("192.168.109.131:8500"),
)
//注冊服務(wù)
microService:= web.NewService(
web.Name("orderserver"),
//web.RegisterTTL(time.Second*30),//設(shè)置注冊服務(wù)的過期時間
//web.RegisterInterval(time.Second*20),//設(shè)置間隔多久再次注冊服務(wù)
web.Address(":18002"),
web.Handler(ginRouter),
web.Registry(consulReg),
)
microselector := selector.NewSelector(
selector.Registry(consulReg),//傳入consul注冊
selector.SetStrategy(selector.RoundRobin),//指定查詢機制
)
microClient := microhttp.NewClient(
client.Selector(microselector),
client.ContentType("application/json"))
req:=microClient.NewRequest("userserver", "/users",map[string]string{})
var resp map[string]interface{}
err := microClient.Call(context.Background(), req, &resp)
if err == nil{
fmt.Println(resp)
}
microService.Run()
}
router.go代碼如下
package routers
import "github.com/gin-gonic/gin"
func InitRouters() *gin.Engine {
ginRouter := gin.Default()
ginRouter.POST("/orders/", func(context *gin.Context) {
context.String(200, "get orderinfos")
})
return ginRouter
}
