gin+go-micro+etcd实战一

这篇主要介绍服务注册和发现的实现

etcd的安装方式:https://etcd.io/

当部署完etcd以后会显示

 etcd的默认客户端端口是2379，接下来就可以使用etcd做服务注册、服务发现

go环境：go-micro gin 

目录结构

 userserver/main.go

package main

import (
    "github.com/micro/go-micro/registry"
    "github.com/micro/go-micro/registry/etcd"
    "github.com/micro/go-micro/web"
    "userserver/routers"
)

var etcdReg registry.Registry


// 注册到etcd
func init(){
    etcdReg = etcd.NewRegistry(
        registry.Addrs("127.0.0.1:2379"),
    )
}

func main(){
    // 初始化路由
    router := routers.InitRouter()
    microService := web.NewService(
        web.Name("api.miku.com.userserver"),
        web.Address(":10001"),
        web.Handler(router),
        web.Registry(etcdReg),
    )
    microService.Run()
}

userserver/router.go

package routers

import (
    "github.com/gin-gonic/gin"
    "net/http"
)

func InitRouter()*gin.Engine{
    ginRouter := gin.Default()
    ginRouter.POST("/users", func(context *gin.Context) {
        context.JSON(http.StatusOK,gin.H{
            "code": 200,
            "m g": "请求成功",
        })
    })
    return ginRouter
}

orderserver/main.go 中实现了服务发现

package main

import (
    "bytes"
    "fmt"
    "github.com/micro/go-micro/client/selector"
    "github.com/micro/go-micro/registry"
    "github.com/micro/go-micro/registry/etcd"
    "github.com/micro/go-micro/web"
    "net/http"
    "orderserver/router"
    "time"
)

var etcdReg registry.Registry

func init(){
    etcdReg = etcd.NewRegistry(
        registry.Addrs("127.0.0.1:2379"),
    )
}

func main(){
    ginRouter := router.InitRouter()
    microServce := web.NewService(
        web.Name("api.miku.com.orderserver"),
        web.Address(":10082"),
        web.Handler(ginRouter),
        web.Registry(etcdReg),
    )
    // 获取服务地址
    hostAddress := GetServiceAddr("api.miku.com.userserver")
    if len(hostAddress) <= 0 {
        fmt.Println("hostAddress is null")
    }else{
        url := "http://" + hostAddress + "/users"
        fmt.Println(url)
        resp, _ := http.Post(url,"application/json;charset=utf-8",bytes.NewBuffer([]byte("")))
        fmt.Println(resp)
    }
    microServce.Run()
}

// 获取服务地址
func GetServiceAddr(serviceName string)(address string){
    var retryCount  int
    for {
        servers,err := etcdReg.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
        }
        // 重试次数
        retryCount  ++
        time.Sleep(time.Second * 3)
        if retryCount  >= 5{
            return
        }
    }
}

package router

import (
    "github.com/gin-gonic/gin"
    "net/http"
)

func InitRouter()*gin.Engine{
    ginRouter := gin.Default()
    ginRouter.POST("/orders/", func(c *gin.Context) {
        c.String(http.StatusOK,"get orderinfo")
    })
    return ginRouter
}

运行micro web会在8082端口打开web UI服务，在网页中会显示micro注册的服务

 

 当运行所有的main.go文件 会看到orderserver成功调用了userserver的服务，这就实现了服务注册、服务发现功能

摘自https://www.jianshu.com/p/1e14a5b0a9db?utm_campaign=studygolang.com&utm_medium=studygolang.com&utm_source=studygolang.com

原作者：

技术修仙