gRPC vs REST API: когда использовать gRPC в 2025

syntax = "proto3";

package user;

// Сервис для работы с пользователями
service UserService {
  // Получить пользователя по ID
  rpc GetUser (GetUserRequest) returns (User);
  
  // Получить список пользователей (streaming)
  rpc ListUsers (ListUsersRequest) returns (stream User);
  
  // Создать пользователя
  rpc CreateUser (CreateUserRequest) returns (User);
}

// Запрос на получение пользователя
message GetUserRequest {
  int32 id = 1;
}

// Запрос на создание пользователя
message CreateUserRequest {
  string name = 1;
  string email = 2;
  int32 age = 3;
}

// Запрос на список пользователей
message ListUsersRequest {
  int32 page = 1;
  int32 limit = 2;
}

// Модель пользователя
message User {
  int32 id = 1;
  string name = 2;
  string email = 3;
  int32 age = 4;
  string created_at = 5;
}

// server.js
const grpc = require('@grpc/grpc-js');
const protoLoader = require('@grpc/proto-loader');

// Загрузка .proto файла
const packageDefinition = protoLoader.loadSync('user.proto', {
  keepCase: true,
  longs: String,
  enums: String,
  defaults: true,
  oneofs: true
});

const userProto = grpc.loadPackageDefinition(packageDefinition).user;

// Реализация сервиса
const server = new grpc.Server();

server.addService(userProto.UserService.service, {
  GetUser: (call, callback) => {
    const userId = call.request.id;
    // Получение пользователя из БД
    const user = {
      id: userId,
      name: 'John Doe',
      email: 'john@example.com',
      age: 30,
      created_at: new Date().toISOString()
    };
    callback(null, user);
  },

  ListUsers: (call) => {
    // Server streaming
    const users = [
      { id: 1, name: 'John', email: 'john@example.com', age: 30 },
      { id: 2, name: 'Jane', email: 'jane@example.com', age: 25 }
    ];
    
    users.forEach(user => {
      call.write(user);
    });
    call.end();
  },

  CreateUser: (call, callback) => {
    const { name, email, age } = call.request;
    // Создание пользователя
    const newUser = {
      id: Date.now(),
      name,
      email,
      age,
      created_at: new Date().toISOString()
    };
    callback(null, newUser);
  }
});

// Запуск сервера
server.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => {
  server.start();
  console.log('gRPC server running on port 50051');
});

// client.js
const grpc = require('@grpc/grpc-js');
const protoLoader = require('@grpc/proto-loader');

const packageDefinition = protoLoader.loadSync('user.proto', {
  keepCase: true,
  longs: String,
  enums: String,
  defaults: true,
  oneofs: true
});

const userProto = grpc.loadPackageDefinition(packageDefinition).user;

// Создание клиента
const client = new userProto.UserService(
  'localhost:50051',
  grpc.credentials.createInsecure()
);

// Unary call
client.GetUser({ id: 1 }, (error, user) => {
  if (error) {
    console.error('Error:', error);
    return;
  }
  console.log('User:', user);
});

// Server streaming
const stream = client.ListUsers({ page: 1, limit: 10 });
stream.on('data', (user) => {
  console.log('User:', user);
});
stream.on('end', () => {
  console.log('Stream ended');
});
stream.on('error', (error) => {
  console.error('Error:', error);
});

# server.py
import grpc
from concurrent import futures
import user_pb2
import user_pb2_grpc

class UserService(user_pb2_grpc.UserServiceServicer):
    def GetUser(self, request, context):
        # Получение пользователя
        return user_pb2.User(
            id=request.id,
            name='John Doe',
            email='john@example.com',
            age=30,
            created_at='2025-11-13T10:00:00Z'
        )
    
    def ListUsers(self, request, context):
        # Server streaming
        users = [
            user_pb2.User(id=1, name='John', email='john@example.com', age=30),
            user_pb2.User(id=2, name='Jane', email='jane@example.com', age=25)
        ]
        for user in users:
            yield user
    
    def CreateUser(self, request, context):
        # Создание пользователя
        return user_pb2.User(
            id=123,
            name=request.name,
            email=request.email,
            age=request.age,
            created_at='2025-11-13T10:00:00Z'
        )

def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    user_pb2_grpc.add_UserServiceServicer_to_server(UserService(), server)
    server.add_insecure_port('[::]:50051')
    server.start()
    print('gRPC server running on port 50051')
    server.wait_for_termination()

if __name__ == '__main__':
    serve()