设为首页 收藏本站
查看: 1585|回复: 0

[经验分享] linux下golang gRPC配置详解

[复制链接]

尚未签到

发表于 2018-9-20 11:41:16 | 显示全部楼层 |阅读模式
1.安装gRPC运行环境
  

go get google.golang.org/grpc  

  这里的grpc通俗来说就说用在代码里的一个类库,后面的例子可以看到。比较坑的是这里可能需要FQ.....

2.安装protoc
  这里需要安装proto buffer的编译器。首先在官网下载,如c++版本的protobuf-cpp-3.4.1.tar.gz,解压后进行编译:
  

./configure  
make && make install
  

3.安装protoc-gen-go
  

go get -a github.com/golang/protobuf/protoc-gen-go  

4.编写proto文件
  基于protobuf的跨语言的特性,不难想到它自己实现了一套数据类型。这里有一个简单的例子
  

//testHello.proto  
syntax = "proto3";
  

  
package protos;
  

  
// The service definition.
  
service Devops {
  // 定义服务
  rpc SayHello (HelloRequest) returns (Response) {}
  
}
  

  
// The request message containing the user's name.
  
message HelloRequest {
  string name = 1;
  
}
  

  
// The response message
  
message HelloReply {
  string message = 1;
  
}
  

  
message Response {
  enum StatusCode {
  UNDEFINED = 0;
  SUCCESS = 200;
  FAILURE = 500;
  }
  StatusCode status = 1;
  HelloReply msg = 2;
  
}
  

  然后在终端自动生成pb.go:
  

protoc --go_out=plugins=grpc:. testHello.proto  

5.编写服务端
  

package main  

  
const (
  port = ":50051"
  
)
  

  
type myserver struct{}
  

  
//这里myserver实现了SayHello
  
func (s *myserver) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.Response, error) {
  fmt.Print("receive " + in.Name)
  return &pb.Response{
  Status:pb.Response_SUCCESS,
  Msg:&pb.HelloReply{Message:"receive " + in.Name},
  }, nil
  
}
  

  
func main() {
  //绑定端口
  lis, err := net.Listen("tcp", port)
  if err != nil{
  log.Fatal("fail to listen")
  }
  

  s := grpc.NewServer()
  pb.RegisterDevopsServer(s, &myserver{})
  s.Serve(lis)
  
}
  

6.编写客户端
  

package main  

  
const (
  address = "localhost:50051"
  
)
  

  
func main()  {
  //grpc.WithInsecure()指定后才不会报错
  conn, err := grpc.Dial(address, grpc.WithInsecure())
  

  if err != nil{
  log.Fatal("error....", err)
  }
  c := pb.NewDevopsClient(conn)
  res, _ := c.SayHello(context.Background(), &pb.HelloRequest{"eeee"})
  

  fmt.Print(res)
  
}
  

  WithInsecure returns a DialOption which disables transport security for this ClientConn.
  
Note that transport security is required unless WithInsecure is set.

  WithInsecure返回一个DialOption,它在传输过程中不保证安全。除非设置WithInsecure,否则grpc.Dial必须指定安全选项。
  参考:

  1.https://github.com/google/protobuf/releases
  
2.http://www.cnblogs.com/YaoDD/p/5504881.html




运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-598826-1-1.html 上篇帖子: Golang中使用lua进行扩展 下篇帖子: 【golang-GUI开发】项目的编译
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表