GO-Grpc微服务开发三 服务调用for golang

juelite · · 1044 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

# 微服务调用 ## rpc - golang 版 ```go 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](https://github.com/juelite/micro-srv)

有疑问加站长微信联系(非本文作者))

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1044 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传