以下是一个简单的Golang RPC（使用gRPC）服务定义和客户端调用的例子。
首先，我们需要定义一个服务接口：
// proto/greeter.proto
syntax = "proto3";
package greeter;
service Greeter {
rpc Greet(GreetRequest) returns (GreetResponse) {}
}
message GreetRequest {
string name = 1;
}
message GreetResponse {
string message = 1;
}
然后使用protobuf编译器生成Golang代码：
protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/greeter.proto
服务端代码：
package main
import (
"context"
"fmt"
"google.golang.org/grpc"
"net"
)
// 实现Greeter服务接口
type GreeterServer struct{}
// Greet实现Greeter服务的RPC调用
func (s *GreeterServer) Greet(ctx context.Context, req *greeter.GreetRequest) (*greeter.GreetResponse, error) {
return &greeter.GreetResponse{Message: "Hello, " + req.Name}, nil
}
func main() {
listener, err := net.Listen("tcp", ":50051")
if err != nil {
fmt.Println("failed to listen:", err)
return
}
s := grpc.NewServer()
greeter.RegisterGreeterServer(s, &GreeterServer{})
if err := s.Serve(listener); err != nil {
fmt.Println("failed to serve:", err)
return
}
}
客户端代码：
package main
import (
"context"
"fmt"
"google.golang.org/grpc"
)
func main() {
conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(), grpc.WithBlock(), grpc.WithTimeout(context.Background(), 5*time.Second))
if err != nil {
fmt.Println("failed to dial:", err)
return
}
defer conn.Close()
client := greeter.NewGreeterClient(conn)
response, err := client.Greet(context.Background(), &greeter.GreetRequest{Name: "World"})
if err != nil {
fmt.Println("failed to greet:", err)
return
}
fmt.Println("Greeting:", response.Message)
}
在这个例子中，我们定义了一个名为Greeter的服务，并在服务端实现了Greet方法。然后在客户端，我们连接到服务器，并调用Greet方法。这个过程展示了如何使用gRPC在Golang中创建和使用RPC服务。