GO-Grpc微服務開發三 服務調用for golang

• 微服務調用
• • rpc

微服務調用

rpc

• golang 版

package main

import (
    consulapi "github.com/hashicorp/consul/api"
    "fmt"
    "os"
    "google.golang.org/grpc"
    pb "micro-srv/service/kibana/proto"
    "golang.org/x/net/context"
)


func main() {
    config := consulapi.Config{
    	//consul作為服務發現
        Address:"http://127.0.0.1:8500",
    }

    client, err := consulapi.NewClient(&config)//非預設情況下需要設定實際的參數
    if err != nil {
        fmt.Println(err.Error())
        os.Exit(0)
    }
	//取到日志服務資訊
    services1, _, err := client.Catalog().Service("kibana", "", nil)

    if err != nil {
        fmt.Println(err.Error())
        os.Exit(1)
    }
	//調用服務
    sendData1(services1)
}


func sendData1(service []*consulapi.CatalogService) {
    if len(service) > 0 {
    	//建立連接配接，TODO GO-Grpc微服務開發五 服務調用優化
        conn, err := grpc.Dial(fmt.Sprintf("%s:%d", service[0].ServiceAddress, service[0].ServicePort), grpc.WithInsecure())
		//初始化用戶端
        c := pb.NewKibanaClient(conn)
		//發送的資料
        request := &pb.WriteRequest{
            Tag: "micro_test",
            Info: "hello 5.45",
            Level: "info",
        }
        //發起請求
        r, err := c.Write(context.Background(), request)
        fmt.Println(r, err)
    }
}
           

源碼：go-grpc-getway