rpc SayHello(HelloRequest) returns (HelloResponse) {}

rpc SayHello(HelloRequest) returns (stream HelloResponse) {}

rpc SayHello(stream HelloRequest) returns (HelloResponse) {}

rpc SayHello(stream HelloRequest) returns (stream HelloResponse) {}

// 使用 proto3 語法，不指定的話默認(rèn) proto2
syntax = "proto3";
// 是否需要生成的類拆分為多個
option java_multiple_files = true;
// 生成的類所屬的層級
option java_package = "io.grpc.examples.helloworld";
option java_outer_classname = "HelloWorldProto";
option objc_class_prefix = "HLW";
// 定義報名，并于避免命名沖突
package helloworld;
// 定義服務(wù)
service Greeter {
  // 定義：
  //   1. 參數(shù)
  //   2. 返回類型
  rpc SayHello (HelloRequest) returns (HelloReply) {}
  rpc SayHelloStreamReply (HelloRequest) returns (stream HelloReply) {}
}
// 結(jié)構(gòu)化數(shù)據(jù)：使用 message 定義。
message HelloRequest {
  string name = 1; // 字段類型 字段名 = 字段編號;
}
message HelloReply {
  string message = 1;
}

// Protocol Buffers 文件
let PROTO_PATH = __dirname + './helloworld.proto';
// 用戶實(shí)現(xiàn) gRPC 服務(wù)和客戶端的核心庫
let grpc = require('@grpc/grpc-js');
// 加載 .proto 文件
let protoLoader = require('@grpc/proto-loader');
/**
 * protoLoader.loadSync(PROTO_PATH, { ... }) 方法
 * 從指定的 .proto 文件加載定義，并根據(jù)選項(xiàng)配置進(jìn)行解析。
 * 使用到 protoLoader 一個 Node.js 模塊
 */
let packageDefinition = protoLoader.loadSync(
  PROTO_PATH,
  {
    keepCase: true, // 保持字段名稱的大小寫
    longs: String, // 將 Protocol Buffers 中的 long 類型字段解析為 JavaScript 字符串
    enums: String, // 將枚舉類型轉(zhuǎn)換為字符串
    defaults: true, // 為所有字段設(shè)置默認(rèn)值
    oneofs: true // 支持 oneof 字段，這是一種在 Protocol Buffers 中定義的互斥字段
  });
/**
 * grpc.loadPackageDefinition(packageDefinition) 方法
 * 將 @grpc/proto-loader 生成的描述加載到 gRPC 庫中，
 * 將加載的 Protocol Buffers 描述轉(zhuǎn)換為 gRPC 服務(wù)端可以使用的 JavaScript 對象。
 * 以創(chuàng)建客戶端和服務(wù)端。
 */
let hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld;
/**
 * 定義 RPC 的方法
 */
function sayHello(call, callback) {
  callback(null, { message: 'Hello ' + call.request.name });
}
function main() {
  // 1. 創(chuàng)建 gRPC 服務(wù)器實(shí)例
  let server = new grpc.Server();
  // 2. 將 Greeter 服務(wù)和實(shí)現(xiàn)方法添加到 gRPC 服務(wù)器中
  server.addService(hello_proto.Greeter.service, { sayHello: sayHello });
  /**
   * 3. 綁定服務(wù)器到指定的地址和端口，并使用不安全的憑據(jù)（沒有 SSL/TLS）
   *    grpc.ServerCredentials.createInsecure(): 創(chuàng)建不安全的服務(wù)器憑據(jù)
   */
  server.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), (err, port) => {
    if (err != null) {
      return console.error(err);
    }
    console.log(`gRPC listening on ${port}`)
  });
}
main();

let PROTO_PATH = __dirname + './helloworld.proto';
// 用戶實(shí)現(xiàn) gRPC 服務(wù)和客戶端的核心庫
let grpc = require('@grpc/grpc-js');
// 加載 .proto 文件
let protoLoader = require('@grpc/proto-loader');
// 加載 .proto 文件，并且根據(jù)配置項(xiàng)進(jìn)行解析
let packageDefinition = protoLoader.loadSync(
  PROTO_PATH,
  {
    keepCase: true, // 保持字段名稱的大小寫
    longs: String, // 將 Protocol Buffers 中的 long 類型字段解析為 JS 字符串
    enums: String, // 將枚舉類型轉(zhuǎn)換為字符串
    defaults: true, // 為所有字段設(shè)置默認(rèn)值
    oneofs: true // 支持 oneof 字段
  });
// 將生成的描述添加到 gRPC 庫中，并輸入可以使用的 JS 對象，來創(chuàng)建服務(wù)端和客戶端
let hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld;
function main() {
  // 定義 gRPC 服務(wù)器的地址和端口
  let target = 'localhost:50051';
  // 創(chuàng)建一個客戶端存根，存根(抽象層)：hello_proto.Greeter，來調(diào)用遠(yuǎn)程服務(wù)
  let client = new hello_proto.Greeter(target,
    grpc.credentials.createInsecure());
  let user = 'world';
  // 調(diào)用遠(yuǎn)程服務(wù)方法
  client.sayHello({ name: user }, function (err, response) {
    console.log('Greeting:', response.message);
  });
}
main();