grpc的封装

grpc的c++封装方法：
grpc是什么？
要了解grpc之前，先需要了解微服务架构，微服务架构简单来说是一种系统架构方法，本来是用于大型服务器的，作用是什么呢？简单来说：当服务器的某个部分挂掉的时候，其他的部分依然可以运行；这个架构用在软件开发中的时候，就变成了一个系统中，不同的模块，每个模块或者几个模块，分别包装成微服务器；好处是：某个模块需要改动的时候只需要进行内部改动，和与此相关的某些模块的协议需要改动，完全不会影响到其他模块；
一般的系统架构图：

微服务架构图：

grpc是什么？
grpc是微服务架构的系统中，用于rpc的库；
rpc是什么？
rpc的含义是远程程序呼叫；
举例来说：A是服务器，要提供服务；而B是客户端，需要远程请求服务；这时候A和B之间就需要通讯协议，而一般的tcp协议的话，只是进行数据传输的，rpc却可以做到进行接口调用，也就是说B可以直接调用A中的接口；
那么，微服务架构中，如何设计一个模块呢？或者说模块的关注点是什么？
除了模块内部的结构体和处理逻辑之外，还需要关注的就是：client端和server端；一个模块可以被看成一个盲盒：client端是输入资讯，server端是提供调用服务（输出）；
以下一一个订单管理模块的结构图举例：
一般的模块结构图：

grpc封装之后的结构图：

最后是实现的部分：
步骤1：假设原有的模块已经实现完成了；
步骤2：安装grpc：请去官网按照步骤安装；然后用example检查是否安装成功，并可以进行编译和使用；
步骤3：写proto，proto就相当于是一般的server和client之间的通讯协议一样的写法，只是需要按照proto的语法来写；假设这是模块A为模块B提供的service的proto文件；（这里插入一下：service划分的方法：一个模块A为所有模块B,C,D的rpc全部放在一个service中，一个是为B的是一个proto，为C的是一个；选择后者比较好：修改比较简单，不然本来只是修改A为B的service，反而要修改所有模块的相关文件；）；所以一个proto = A’service For B；
步骤4：用proto生成四个proto相关的文件(这里请参照grpc提供的example中的helloworld的cmake文档)：XXX.pb.h,XXX.pb.cc,XXX.grpc.pb.h,XXX.grpc.pb.cc
步骤5：把这四个文件拷贝到A和B中；
步骤6：按照官方的文档写A的server和service，B的client；（建议先用最简单的实现方法，不要使用asyn方法，之后深入理解之后，再用）；
步骤7：把ClassA修改成单例模式：server中需要使用到ClassA的接口的时候，就直接调用；ClassB包含client，在需要rpc的时候，直接使用client进行rpc；
步骤8：在main中测试一下:server的开启需要用多线程：
例子中是模块DBManagement为OrderManagement提供的service；

 DBManagement_OrderManagement_Server* mongodb_server = new DBManagement_OrderManagement_Server();
  std::thread t_mongodb_server(&DBManagement_OrderManagement_Server::Init, mongodb_server);
  t_mongodb_server.detach();

使用rpc：

OrderManagement::GetInstance()->insert_into_DB(data);

这里insert内部是这样的：

dbclient_->Insert_Data(data);

最后，附上两个cmake模板：
1 步骤4中生成四个文件的cmake模板：
分为两个部分：
官方的不可缺的部分：

cmake_minimum_required(VERSION 3.5.1)

project(generate)

if(NOT MSVC)
  set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11")
else()
  add_definitions(-D_WIN32_WINNT=0x600)
endif()

find_package(Threads REQUIRED)

  # This branch assumes that gRPC and all its dependencies are already installed
  # on this system, so they can be located by find_package().

  # Find Protobuf installation
  # Looks for protobuf-config.cmake file installed by Protobuf's cmake installation.
  set(protobuf_MODULE_COMPATIBLE TRUE)
  find_package(Protobuf CONFIG REQUIRED)
  message(STATUS "Using protobuf ${Protobuf_VERSION}")

  set(_PROTOBUF_LIBPROTOBUF protobuf::libprotobuf)
  set(_REFLECTION gRPC::grpc++_reflection)
  if(CMAKE_CROSSCOMPILING)
    find_program(_PROTOBUF_PROTOC protoc)
  else()
    set(_PROTOBUF_PROTOC $<TARGET_FILE:protobuf::protoc>)
  endif()

  # Find gRPC installation
  # Looks for gRPCConfig.cmake file installed by gRPC's cmake installation.
  find_package(gRPC CONFIG REQUIRED)
  message(STATUS "Using gRPC ${gRPC_VERSION}")

  set(_GRPC_GRPCPP gRPC::grpc++)
  if(CMAKE_CROSSCOMPILING)
    find_program(_GRPC_CPP_PLUGIN_EXECUTABLE grpc_cpp_plugin)
  else() 
    set(_GRPC_CPP_PLUGIN_EXECUTABLE $<TARGET_FILE:gRPC::grpc_cpp_plugin>)
  endif()

通过自己写的proto生成文件的部分：请按照自己的proto名字和想要的service名字进行修改

#dbmanagement service for ordermanagement
# Proto file
get_filename_component(db_order_proto "${CMAKE_CURRENT_BINARY_DIR}/dbmanagement_ordermanagement.proto" ABSOLUTE)
get_filename_component(db_order_proto_path "${db_order_proto}" PATH)

# Generated sources
set(db_order_proto_srcs "${CMAKE_CURRENT_BINARY_DIR}/dbmanagement_ordermanagement.pb.cc")
set(db_order_proto_hdrs "${CMAKE_CURRENT_BINARY_DIR}/dbmanagement_ordermanagement.pb.h")
set(db_order_grpc_srcs "${CMAKE_CURRENT_BINARY_DIR}/dbmanagement_ordermanagement.grpc.pb.cc")
set(db_order_grpc_hdrs "${CMAKE_CURRENT_BINARY_DIR}/dbmanagement_ordermanagement.grpc.pb.h")
add_custom_command(
      OUTPUT "${db_order_proto_srcs}" "${db_order_proto_hdrs}" "${db_order_grpc_srcs}" "${db_order_grpc_hdrs}"
      COMMAND ${_PROTOBUF_PROTOC}
      ARGS --grpc_out "${CMAKE_CURRENT_BINARY_DIR}"
        --cpp_out "${CMAKE_CURRENT_BINARY_DIR}"
        -I "${db_order_proto_path}"
        --plugin=protoc-gen-grpc="${_GRPC_CPP_PLUGIN_EXECUTABLE}"
        "${db_order_proto}"
      DEPENDS "${db_order_proto}")

# Include generated *.pb.h files
include_directories("${CMAKE_CURRENT_BINARY_DIR}")

# db_grpc_proto
add_library(db_order_proto
  ${db_order_proto_srcs}
  ${db_order_proto_hdrs}
  ${db_order_grpc_srcs}
  ${db_order_grpc_hdrs})
target_link_libraries(db_order_proto
  ${_REFLECTION}
  ${_GRPC_GRPCPP}
  ${_PROTOBUF_LIBPROTOBUF})

  # Targets 
foreach(_target )
  add_executable(${_target} "${_target}.cc")
  target_link_libraries(${_target}
    db_order_proto
    ${_REFLECTION}
    ${_GRPC_GRPCPP}
    ${_PROTOBUF_LIBPROTOBUF})
endforeach()

2步骤5中，拷贝四个文件到相应模块，该模块的cmake需要新增的内容：

find_package(Protobuf CONFIG REQUIRED)
find_package(gRPC REQUIRED)
include_directories("/usr/local/include/grpc")
include_directories("/usr/local/include/grpc++")
include_directories("/usr/local/include/grpcpp")
target_link_libraries(mongodbmanager protobuf::libprotobuf gRPC::grpc++ gRPC::grpc++_reflection)