GolanggRPCUnary调用详解教程

大家好，今天本人给大家带来文章《Golang gRPC Unary调用实战教程》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

首先定义Protobuf接口并生成Go代码，然后实现gRPC服务端和客户端，最后启动服务并调用SayHello方法，输出“Response: Hello, Alice”，完成Unary调用流程。

在Go语言中使用gRPC进行服务间通信，Unary模式是最基础、最常用的调用方式。它对应“一元调用”，即客户端发送一个请求，服务器返回一个响应。本文将带你从零开始实践Golang中gRPC Unary调用的完整开发流程。

定义Protobuf接口

要使用gRPC，首先需要定义服务接口和消息结构。创建service.proto文件：

syntax = "proto3";
package example;

// 定义请求消息
message HelloRequest {
    string name = 1;
}

// 定义响应消息
message HelloResponse {
    string message = 1;
}

// 定义服务
service Greeter {
    rpc SayHello(HelloRequest) returns (HelloResponse);
}

使用protoc工具生成Go代码：

protoc --go_out=. --go_opt=paths=source_relative \
    --go-grpc_out=. --go-grpc_opt=paths=source_relative \
    service.proto

实现gRPC服务端

编写服务端逻辑，注册并启动gRPC服务器：

package main

import (
    "context"
    "log"
    "net"

    "google.golang.org/grpc"
    pb "your-module-path/proto"
)

type server struct {
    pb.UnimplementedGreeterServer
}

func (s *server) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {
    return &pb.HelloResponse{
        Message: "Hello, " + req.GetName(),
    }, nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }

    s := grpc.NewServer()
    pb.RegisterGreeterServer(s, &server{})

    log.Println("gRPC server listening on :50051")
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

编写gRPC客户端

客户端通过连接服务端，调用Unary方法SayHello：

package main

import (
    "context"
    "log"

    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
    pb "your-module-path/proto"
)

func main() {
    // 建立与服务端的连接
    conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()

    // 创建客户端实例
    client := pb.NewGreeterClient(conn)

    // 构造请求
    req := &pb.HelloRequest{Name: "Alice"}

    // 发起Unary调用
    resp, err := client.SayHello(context.Background(), req)
    if err != nil {
        log.Fatalf("could not greet: %v", err)
    }

    log.Printf("Response: %s", resp.GetMessage())
}

运行与验证

启动服务端：

go run server.go

另开终端运行客户端：

go run client.go

预期输出：

Response: Hello, Alice

说明gRPC Unary调用成功完成。

基本上就这些。只要定义好Proto、生成代码、实现服务和调用，就能快速搭建gRPC通信。注意错误处理和连接管理，在生产环境中建议启用TLS并设置超时。

到这里，我们也就讲完了《GolanggRPCUnary调用详解教程》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！