//定義一個(gè)常量指定proto文件路徑
var PROTO_FILE_PATH = 'E:\\01.study\\36.nodejs\\workspace\\grpc-demo\\proto\\Student.proto';
//引入GRPC庫
var grpc = require('grpc');
//找到我們在IDL文件中定義的service：StudentService
var grpcService = grpc.load(PROTO_FILE_PATH).com.mzj.netty.ssy._08_grpc;
//定義服務(wù)端
var server = new grpc.Server();
server.addService(grpcService.StudentService.service,{
    //添加測試的rpc方法，服務(wù)名：服務(wù)對(duì)應(yīng)調(diào)用方法
    getRealNameByUsername: getRealNameByUsername1,
    // 添加其他rpc方法
    getStudentsByAge: getStudentsByAge1,
    getStudentsWrapperByAges: getStudentsWrapperByAges1,
    biTalk: biTalk1,
})
//綁定端口，并設(shè)置不是用ssl安全加密
server.bind('localhost:8899',grpc.ServerCredentials.createInsecure());
//啟動(dòng)服務(wù)器
server.start();
//實(shí)現(xiàn)rpc服務(wù)調(diào)用處理函數(shù)：參數(shù)1call：請(qǐng)求對(duì)象，參數(shù)2callback：回調(diào)函數(shù)
function getRealNameByUsername1(call,callback) {
    console.log("username : " + call.request.username);//打印請(qǐng)求對(duì)象
    /**
     * 定義回調(diào)函數(shù)
     */
    callback(null,{realname: 'mazhongjia'});//參數(shù)1：錯(cuò)誤對(duì)象，這里不進(jìn)行設(shè)置，參數(shù)2：返回給客戶端的結(jié)果對(duì)象，這里的屬性名對(duì)應(yīng)IDL中聲明的屬性名
}
function getStudentsByAge1(){
}
function getStudentsWrapperByAges1(){
}
function biTalk1(){
}
 

//--------------動(dòng)態(tài)代碼生成的方式：--------------
//1、定義grpc的IDL文件位置
var PROTO_FILE_PATH = 'E:\\01.study\\36.nodejs\\workspace\\grpc-demo\\proto\\Student.proto';
//2、引入grpc庫，nodejs中，引入庫用require方法
var grpc = require('grpc');
//3、定義grpc服務(wù)
//找到我們在IDL文件中定義的service：StudentService
var grpcService = grpc.load(PROTO_FILE_PATH).com.mzj.netty.ssy._08_grpc;
//4、定義nodejs客戶端
var client = new grpcService.StudentService('localhost:8899',grpc.credentials.createInsecure());
//grpc.credentials.createInsecure()：創(chuàng)建的是一個(gè)不安全的、不是用ssl證書加密的通道，與java如下代碼等價(jià)：
//.usePlaintext(true).
//調(diào)用rpc方法，其中方法首字母轉(zhuǎn)小寫
client.getRealNameByUsername({username:'lisi'},function (error,respData) {
    console.log(respData);
})
 

syntax = "proto3";
package com.mzj.netty.ssy._08_grpc;
option java_package = "com.mzj.netty.ssy._08_grpc";
option java_outer_classname = "StudentProto";
option java_multiple_files = true;
service StudentService{
    //gRpc支持的四種調(diào)用形式示例：
    rpc GetRealNameByUsername(MyRequest) returns (MyResponse){}//種類1：普通輸入?yún)?shù)與返回值
    rpc GetStudentsByAge(StudentRequest) returns (stream StudentResponse){}//種類2：服務(wù)端rpc方法返回值是stream形式，參數(shù)是普通對(duì)象
    rpc GetStudentsWrapperByAges(stream StudentRequest) returns (StudentResponseList){}//種類3：客戶端輸入?yún)?shù)是stream形式，返回是一個(gè)普通對(duì)象
    rpc BiTalk(stream StreamRequest) returns (stream StreamResponse){}//種類4：雙向的流式的數(shù)據(jù)傳遞（客戶端發(fā)送請(qǐng)求/服務(wù)端返回結(jié)果都是流式）
    //從IDL的定義上，四種調(diào)用形式區(qū)別體現(xiàn)在rpc定義時(shí)方法參數(shù)、返回值的message前面是否有stream關(guān)鍵字
    //rpc方法的參數(shù)與返回值類型都是IDL中定義的message類型，而不能是string、int32等變量類型，這一點(diǎn)跟thrift不同，即使只有一個(gè)屬性，也得定義成message
}
message MyRequest{
    string username = 1;
}
message MyResponse{
    string realname = 2;
}
message StudentRequest{
    int32 age = 1;
}
message StudentResponse{
    string name = 1;
    int32 age = 2;
    string city = 3;
}
message StudentResponseList{
    //protobuf中集合用repeated表示
    repeated StudentResponse studentResponse = 1;//repeated表示集合類型，這里表示服務(wù)器端向客戶端返回的是一個(gè)集合類型，集合中元素是StudentResponse
}
message StreamRequest{
    string request_info = 1;
}
message StreamResponse{
    string response_info = 1;
}

npm install -g grpc-tools

grpc_tools_node_protoc --js_out=import_style=commonjs,binary:../node/static_codegen/ --grpc_out=../node/static_codegen --plugin=protoc-gen-grpc=`which grpc_tools_node_protoc_plugin` helloworld.proto

grpc_tools_node_protoc --js_out=import_style=commonjs,binary:static_codegen/ --grpc_out=static_codegen --plugin=protoc-gen-grpc=/c/Users/mzj/AppData/Roaming/npm/grpc_tools_node_protoc_plugin.cmd proto/Student.proto

//1、定義service，service位于Student_grpc_pb.js中
var service = require('../static_codegen/proto/Student_grpc_pb.js');
//2、定義消息
var message = require('../static_codegen/proto/Student_pb.js');
//3、引入grpc庫
var grpc = require('grpc');
//4、定義客戶端
var client = new service.StudentServiceClient('localhost:8899',grpc.credentials.createInsecure());
//5、定義請(qǐng)求message（與動(dòng)態(tài)生成方式不同）
var request = new message.MyRequest();
request.setUsername('huna');
//6、調(diào)用rpc方法
client.getRealNameByUsername(request,function (error,respData) {
    //靜態(tài)調(diào)用方式是以方法調(diào)用的方式獲取返回結(jié)果，因?yàn)閞pc的返回值在編譯期可見，而動(dòng)態(tài)方式rpc返回值編輯期不可見、是通過屬性的方式獲取結(jié)果
    console.log(respData.getRealname());//打印返回結(jié)果
})