导航：首页 > 开发技术 >

golang下grpc框架怎么使用

发表于：2024-11-29 作者：千家信息网编辑

千家信息网最后更新 2024年11月29日，今天小编给大家分享一下golang下grpc框架怎么使用的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们

千家信息网最后更新 2024年11月29日golang下grpc框架怎么使用

今天小编给大家分享一下golang下grpc框架怎么使用的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。

1. 什么是grpc和protobuf

1.1 grpc

gRPC是一个高性能、开源和通用的RPC框架，面向移动和HTTP/2设计。

目前提供C、Java和Go语言版本，分别是：

grpc,grpc-java,grpc-go.其中C版本支持C,
C++,Node.js,Python,Ruby,Objective-C,PHP和C#支持.

grpc遵循HTTP/2协议，是一个二进制协议

grpc与http一样，底层都是tcp连接，遵循socket套接字

RPC是指远程过程调用，两台服务器A,B。A(客户端)调用B(服务端)上的方法，由于不在同一个内存空间，不能直接调用，需要通过网络调用。

1.2 protobuf

Protocol Buffer是一种协议。
Protocol Buffer 其实是 Google出品的一种轻量 & 高效的结构化数据存储格式，性能比Json、XML真的强2-100倍！

protobuf经历了protobuf2和protobuf3，pb3比pb2简化了很多，目前主流的版本是pb3

protobuf优点：

1.性能好：
压缩性能；
序列化和发序列化快，比Json、XML强2-100倍；
传输速度快。

2.便捷性好：
使用简单，自动生成序列化和反序列化代码；
维护成本低，只维护proto文件
向后兼容，不必破坏旧格式
加密性好

3.跨语言，跨平台，支持各种语言

protobuf缺点：

1.通用性差，json可以任何语言都支持，但是protobuf需要专门的解析库

2.自解释性差，只有通过proto文件才能了解数据结构

2.go下grpc

2.1官网下载protobuf工具

官网：https://github.com/protocolbuffers/protobuf/releases

2.2 下载go的依赖包

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

2.3 编写proto文件

option go_package = "./;proto";

解释：

./;:生成文件的路径

proto:生成文件的包名

hello.proto

syntax = "proto3";package services;option go_package = "./;proto";service Greeter {    rpc SayHello (HelloRequest) returns (HelloReply);}message HelloRequest {    string name = 1;}message HelloReply {    string message = 1;}

2.4 生成hello.pb.proto文件

cd到proto目录下命令：protoc -I . hello.proto   --go_out=plugins=grpc:.命令解释：protoc -I .：在当前路径下寻找hello.proto文件--go_out=plugins=grpc:.  ：生成go语言的proto文件放在当前路径下

2.5 编写server端代码

package mainimport (        "context"        "file_test/grpc_go/proto"        "net"        "google.golang.org/grpc")type Server struct {}// 业务逻辑func (s *Server) SayHello(ctx context.Context, request *proto.HelloRequest) (*proto.HelloReply, error) {        res := &proto.HelloReply{                Message: "hello " + request.Name,        }        return res, nil}// 启动rpc的server服务func start() {        // 1.实例化server        g := grpc.NewServer()        // 2.注册逻辑到server中        proto.RegisterGreeterServer(g,&Server{})        // 3.启动server        lis,err:=net.Listen("tcp","127.0.0.1:8081")        if err !=nil{                panic("监听错误:"+err.Error())        }        err = g.Serve(lis)        if err !=nil{                panic("启动错误:"+err.Error())        }}func main() {        start()}

2.6 编写client端代码

package mainimport (        "context"        "file_test/grpc_go/proto"        "fmt"        "google.golang.org/grpc")// rpc调用func clientRpc(body map[string]string) (res *proto.HelloReply, err error) {        name := body["name"]        conn, err := grpc.Dial("127.0.0.1:8081", grpc.WithInsecure())        if err != nil {                return nil,err        }        defer conn.Close()        rpc := proto.NewGreeterClient(conn)        response, err := rpc.SayHello(context.Background(), &proto.HelloRequest{Name: name})        if err != nil {                return nil,err        }        return response,nil}// 业务代码func start() {        body := make(map[string]string)        body["name"] = "jeff"        response,err := clientRpc(body)        if err!=nil{                fmt.Println("rpc调用失败:",err)                return        }        fmt.Println(response.Message)}func main() {        start()}//结果：hello jeff