Golang如何使用gRPC实现服务间通信_Golang gRPC服务调用与通信实践_技术教程

使用Golang与gRPC可构建高效微服务通信。1. 定义hello.proto文件声明HelloService接口和消息结构；2. 用protoc生成hello.pb.go和hello_grpc.pb.go代码；3. 在server.go中实现SayHello方法并启动gRPC服务；4. 在client.go中创建客户端连接并调用远程SayHello方法；5. 运行后输出“Response: Hello, Alice”，验证通信成功。该方式基于HTTP/2和protobuf，具备强类型、高性能特点，适用于高频内部服务交互。

在微服务架构中，服务间高效、可靠的通信至关重要。Golang 与 gRPC 的结合提供了一种高性能、强类型的服务调用方式。gRPC 基于 HTTP/2 协议，使用 Protocol Buffers（protobuf）作为接口定义语言和数据序列化格式，天然适合 Go 语言构建的分布式系统。

定义服务接口与消息结构

要使用 gRPC，第一步是定义服务接口和通信消息。这通过 .proto 文件完成。

创建一个 hello.proto 文件：

syntax = "proto3";

package service;

service HelloService {
    rpc SayHello (HelloRequest) returns (HelloResponse);
}

message HelloRequest {
    string name = 1;
}

message HelloResponse {
    string message = 1;
}

该文件定义了一个名为 HelloService 的服务，包含一个 SayHello 方法，接收 HelloRequest 并返回 HelloResponse。

使用 protoc 工具生成 Go 代码：

protoc --go_out=. --go-grpc_out=. hello.proto

会生成 hello.pb.go 和 hello_grpc.pb.go 两个文件，包含结构体和客户端/服务端接口。

实现 gRPC 服务端

编写服务端代码，实现上一步定义的接口。

创建 server.go：

package main

import (
    "context"
    "log"
    "net"

    pb "your-module/service" // 替换为你的模块路径
    "google.golang.org/grpc"
)

type server struct {
    pb.UnimplementedHelloServiceServer
}

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

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

    grpcServer := grpc.NewServer()
    pb.RegisterHelloServiceServer(grpcServer, &server{})

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

这段代码启动了一个监听 50051 端口的 gRPC 服务，并注册了 HelloService 的具体实现。

实现 gRPC 客户端调用

接下来编写客户端，调用远程服务。

创建 client.go：

package main

import (
    "context"
    "log"
    "time"

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

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.NewHelloServiceClient(conn)

    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()

    resp, err := client.SayHello(ctx, &pb.HelloRequest{Name: "Alice"})
    if err != nil {
        log.Fatalf("could not greet: %v", err)
    }

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

客户端通过 grpc.Dial 连接到服务端，创建 stub 后即可像调用本地方法一样发起远程调用。