gRPC 与服务通信

1syntax = "proto3";
2 
3package user;
4 
5service UserService {
6  rpc GetUser(GetUserRequest) returns (User);
7  rpc ListUsers(ListUsersRequest) returns (stream User);
8}
9 
10message User {
11  int64 id = 1;
12  string name = 2;
13  string email = 3;
14}
15 
16message GetUserRequest {
17  int64 id = 1;
18}

1type userServer struct {
2    pb.UnimplementedUserServiceServer
3    repo UserRepository
4}
5 
6func (s *userServer) GetUser(ctx context.Context, req *pb.GetUserRequest) (*pb.User, error) {
7    user, err := s.repo.FindByID(ctx, req.Id)
8    if err != nil {
9        return nil, status.Error(codes.NotFound, "user not found")
10    }
11    
12    return &pb.User{
13        Id:    user.ID,
14        Name:  user.Name,
15        Email: user.Email,
16    }, nil
17}