前言:适用于刚入手的小白,本人学习过程也是来源于git项目的说明文档(就是github项目下面那些介绍,有介绍怎么用的),建议可以先去看看,先了解个大概,知道怎么回事,我说的就是简单直白一点,用大白话叫你明白是怎么回事。
一。获取package
学习groc,首先得先获取对应包
go get -u google.golang.org/grpc
如果下载不了,就去这个地址(https://github.com/grpc/grpc-go.git),自己手动下载,或者用官方的方法
git clone https://github.com/grpc/grpc-go.git $GOPATH/src/google.golang.org/grpc
他的这个git语句的意思是,克隆这个地址的项目,到你的gopath/src下面这个地方。其实和你自己下载(git clone或者download)一个道理(当然他这个比较高大上,比较符合程序员应该的操作)。
二。例子使用
这个项目本身就自带了一个例子。目录在项目下的examples/helloworld文件夹下.
该目录下有四个文件夹
1.helloworld
这个是使用protoc编译生成的一个go文件,你可以先删除他原来的go文件,然后执行protoc --go_out=. helloworld.proto去生成一下(不知道protoc的同学,可以看一下对应的git框架,或者看一下我的笔记https://www.jianshu.com/p/a7c03b8048eb),内容是一样的,只不过他为了例子的完整,提前给你生成好了。这里面写的是服务的数据结构等,是为了其他服务调用而是用的。为什么用这个,是因为golang本身的rpc是不支持其他语言调用的,grpc解决了这个问题,想详细了解的,请移步官方大佬的资料(https://github.com/astaxie/build-web-application-with-golang/blob/master/zh/08.4.md)。
2.greeter_server
package main
import (
"context"
"log"
"net"
"google.golang.org/grpc"
pb "google.golang.org/grpc/examples/helloworld/helloworld"
)
const (
port = ":50051" //监听的端口号
)
// server is used to implement helloworld.GreeterServer.
type server struct { //服务的结构类型
pb.UnimplementedGreeterServer
}
// SayHello implements helloworld.GreeterServer
//这个方法就是你实际的逻辑方法,里面的参数是调用了helloworld下面,使用protoc生成的那个go文件的机构
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {
log.Printf("Received: %v", in.GetName())
return &pb.HelloReply{Message: "Hello " + in.GetName()}, nil
}
func main() {
lis, err := net.Listen("tcp", port) //开启监听
if err != nil {
log.Fatalf("failed to listen: %v", err)
}
s := grpc.NewServer() //新建一个grpc服务
pb.RegisterGreeterServer(s, &server{}) //这个服务和上述的服务结构联系起来,这样你新建的这个服务里面就有那些类型的方法
if err := s.Serve(lis); err != nil { //这个服务和你的监听联系起来,这样外界才能访问到啊
log.Fatalf("failed to serve: %v", err)
}
}
这是服务文件,编译里面的main.go,并执行,就开始了监听服务
3.greeter_client
package main
import (
"context"
"log"
"os"
"time"
"google.golang.org/grpc"
pb "google.golang.org/grpc/examples/helloworld/helloworld"
)
const (
address = "localhost:50051"//服务地址
defaultName = "world"
)
func main() {
// Set up a connection to the server.
conn, err := grpc.Dial(address, grpc.WithInsecure())//连接到你的服务地址
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
c := pb.NewGreeterClient(conn)//返回一个client连接,通过这个连接就可以访问到对应的服务资源,就像一个对象
// Contact the server and print out its response.
name := defaultName
if len(os.Args) > 1 {//这两步不重要,就是执行的时候可以加个参数
name = os.Args[1]
}
ctx, cancel := context.WithTimeout(context.Background(), time.Second)//返回一个client,并设置超时时间
defer cancel()
r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})//访问对应的服务器上面的服务方法
if err != nil {
log.Fatalf("could not greet: %v", err)
}
log.Printf("Greeting: %s", r.GetMessage())
}
这是客户端文件,编译执行,就访问了一次上述的服务。
有疑问加站长微信联系(非本文作者)