Golang如何使用gRPC Unary模式调用服务_Golang gRPC Unary调用开发实践

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Golang如何使用gRPC Unary模式调用服务_Golang gRPC Unary调用开发实践

2025-11-28

浏览次数：次

返回列表

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

golang如何使用grpc unary模式调用服务_golang grpc 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())
}