标签：github url consul 调用 kit 实例 go com

package main

import (
    "context"
    "fmt"
    "github.com/go-kit/kit/endpoint"
    "github.com/go-kit/kit/log"
    "github.com/go-kit/kit/sd"
    "github.com/go-kit/kit/sd/consul"
    httptransport "github.com/go-kit/kit/transport/http"
    consulapi "github.com/hashicorp/consul/api"
    "gomicro2/Services"
    "io"
    "net/url"
    "os"
)

func main() {
    //第一步创建client
    {
        config := consulapi.DefaultConfig()
        config.Address = "localhost:8500"
        api_client, _ := consulapi.NewClient(config)
        client:= consul.NewClient(api_client)

        var logger log.Logger
        {
            logger = log.NewLogfmtLogger(os.Stdout)
            var Tag = []string{"primary"}
            //第二部创建一个consul的实例
            instancer := consul.NewInstancer(client, logger, "userservice", Tag, true) //最后的true表示只有通过健康检查的服务才能被得到
            {
                factory := func(service_url string) (endpoint.Endpoint, io.Closer, error) { //factory定义了如何获得服务端的endpoint,这里的service_url是从consul中读取到的service的address我这里是192.168.3.14:8000
                    tart, _ := url.Parse("http://" + service_url) //server ip +8080真实服务的地址
                    return httptransport.NewClient("GET", tart, Services.GetUserInfo_Request, Services.GetUserInfo_Response).Endpoint(), nil, nil //我再GetUserInfo_Request里面定义了访问哪一个api把url拼接成了http://192.168.3.14:8000/v1/user/{uid}的形式
                }
                endpointer := sd.NewEndpointer(instancer, factory, logger)
                endpoints, _ := endpointer.Endpoints()
                fmt.Println("服务有", len(endpoints), "条")
                getUserInfo := endpoints[0] //写死获取第一个
                ctx := context.Background() //第三步：创建一个context上下文对象

                //第四步：执行
                res, err := getUserInfo(ctx, Services.UserRequest{Uid: 101})
                if err != nil {
                    fmt.Println(err)
                    os.Exit(1)
                }
                //第五步：断言，得到响应值
                userinfo := res.(Services.UserResponse)
                fmt.Println(userinfo.Result)
            }
        }
    }

}

标签：github,url,consul,调用,kit,实例,go,com
来源： https://www.cnblogs.com/hualou/p/12081025.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。