Clion上搭建基于grpc的service与client实例

本文主要是介绍Clion上搭建基于grpc的service与client实例，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

这里假设protobuf，grpc，zlib等前置库都已经安装好了。
 

1.新建protobuf文件

syntax = "proto3";
message SearchRequest
{string Request = 1;
}
message SearchResponse
{string Response = 2;
}
service SearchService 
{rpc Search (SearchRequest) returns (SearchResponse);
}

2.生成protobuf和grpc手脚架文件

protoc --cpp_out=./ param.proto
protoc --grpc_out=./ --plugin=protoc-gen-grpc=/usr/local/bin/grpc_cpp_plugin param.proto

查看protobuf生成的文件，可以看到工具为我们生成了一系列的函数。

getter 函数具有与字段名一模一样的名字，并且是小写的，而 setter 函数都是以 set_ 前缀开头。此外，还有 has_ 前缀的函数，对每一个单一的（required 或 optional 的）字段来说，如果字段被置（set）了值，该函数会返回true。最后，每一个字段还有一个 clear_ 前缀的函数，用来将字段重置（un-set）到空状态（empty state）。

然而，数值类型的字段 id 就只有如上所述的基本读写函数，name 和email 字段则有一些额外的函数，因为它们是 string——前缀为 mutable_的函数返回 string 的直接指针（direct pointer）。除此之外，还有一个额外的setter函数。注意：你甚至可以在 email 还没有被置（set）值的时候就调用 mutable_email()，它会被自动初始化为一个空字符串。在此例中，如果有一个单一消息字段，那么它也会有一个 mutable_ 前缀的函数，但是没有一个 set_ 前缀的函数。

重复的字段也有一些特殊的函数——如果你看一下重复字段 phone 的那些函数，就会发现你可以：
（1）得到重复字段的 _size（换句话说，这个 Person 关联了多少个电话号码）。
（2）通过索引（index）来获取一个指定的电话号码。
（3）通过指定的索引（index）来更新一个已经存在的电话号码。
（4）向消息（message）中添加另一个电话号码，然后你可以编辑它（重复的标量类型有一个add_前缀的函数，允许你传新值进去）。

关于枚举和嵌套类（Enums and Nested Classes）。
生成的代码中包含了一个PhoneType 枚举，它对应于.proto文件中的那个枚举。你可以把这个类型当作Student::PhoneType，其值为Student::MOBILE和Student::HOME（实现的细节稍微复杂了点，但是没关系，不理解它也不会影响你使用该枚举）。

编译器还生成了一个名为 Student::PhoneNumber 的嵌套类。如果你看看代码，就会发现“真实的”类实际上是叫做Student_PhoneNumber，只不过Student内部的一个typedef允许你像一个嵌套类一样来对待它。这一点所造成的唯一的一个区别就是：如果你想在另一个文件中对类进行前向声明（forward-declare）的话，你就不能在C++中对嵌套类型进行前向声明了，但是你可以对Student_PhoneNumber进行前向声明。

可以查看官方文档获取更多信息：

https://developers.google.com/protocol-buffers/docs/reference/cpp-generated

3.service端代码

文件目录：
Service
├── CMakeLists.txt
└── src├── main.cpp└── protos├── param.grpc.pb.cc├── param.grpc.pb.h├── param.pb.cc├── param.pb.h└── param.proto

main.cpp内容：

#include <iostream>
#include <memory>
#include <string>#include <grpc++/grpc++.h>
#include <grpc++/server.h>
#include <grpc++/server_builder.h>
#include <grpc++/server_context.h>#include "param.grpc.pb.h"using grpc::Server;
using grpc::ServerBuilder;
using grpc::ServerContext;
using grpc::Status;class SearchRequestImpl final : public SearchService::Service {Status Search(ServerContext* context, const SearchRequest* request,SearchResponse* reply) override {std::string prefix("Hello ");reply->set_response(prefix + request->request());return Status::OK;}
};void RunServer() {std::string server_address("0.0.0.0:50051");SearchRequestImpl service;ServerBuilder builder;builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());builder.RegisterService(&service);std::unique_ptr<Server> server(builder.BuildAndStart());std::cout << "Server listening on " << server_address << std::endl;server->Wait();
}int main(int argc, char** argv) {RunServer();return 0;
}

4.CMakeList.txt文件

cmake_minimum_required(VERSION 3.13)
project(Service)set(CMAKE_CXX_STANDARD 14)
set(CMAKE_CXX_FLAGS -std=c++11)
set(CMAKE_CXX_FLAGS "${CAMKE_CXX_FLAGS} -std=c++11 -pthread")
set(CMAKE_CXX_FLAGS_DEBUG "-g -Wall ${CMAKE_CXX_FLAGS}")
set(CMAKE_EXE_LINKER_FLAGS "-static-libgcc -static-libstdc++ -Wl,-allow-multiple-definition -Wl,--eh-frame-hdr")
set(CMAKE_MODULE_PATH /home/CLionProjects/Service/cmake)   //这里是指明查找grpc库的位置，会自动去这个目录下找Find_grpc.cmake文件aux_source_directory(src/ LIST_SRC)
aux_source_directory(src/protos LIST_SRC)add_executable(Service ${LIST_SRC})include_directories(Service src/protos)find_package(grpc REQUIRED)
include_directories(Service ${grpc_INCLUDE_DIRS})
target_link_libraries(Service ${grpc_LIBRARIES})find_package(ZLIB)
include_directories(Service ${ZLIB_INCLUDE_DIRS})
target_link_libraries(Service ${ZLIB_LIBRARIES})
target_link_libraries(Service pthread)

5.配置Find_grpc.cmake

set(SHEEP_PROJECT_SOURCE_DIR /root)
set(PACKAGE_PATH ${SHEEP_PROJECT_SOURCE_DIR}/grpc)
set(grpc_INCLUDE_DIRS ${SHEEP_PROJECT_SOURCE_DIR}/grpc/include)
set(grpc_INCLUDE_DIRS ${grpc_INCLUDE_DIRS} ${SHEEP_PROJECT_SOURCE_DIR}/grpc/third_party/protobuf/src)
SET(GRPCC++_LIBRARIES ${PACKAGE_PATH}/build/libgrpc++.a)
SET(GRPC_LIBRARIES ${PACKAGE_PATH}/build/libgrpc.a)
SET(PROTOBUF_LIBRARIES ${PACKAGE_PATH}/build/libprotobuf.a)
FIND_LIBRARY(RT_LIBRARIES librt.a PATH ${PACKAGE_PATH}/build)
SET(grpc_LIBRARIES ${GRPCC++_LIBRARIES} ${GRPC_LIBRARIES} ${PROTOBUF_LIBRARIES} ${RT_LIBRARIES})

6.Client

与Service相比只有main.cpp不同

#include <iostream>
#include <memory>
#include <string>#include <grpc++/grpc++.h>
#include <grpc/support/log.h>#include "param.grpc.pb.h"using grpc::Channel;
using grpc::ClientAsyncResponseReader;
using grpc::ClientContext;
using grpc::CompletionQueue;
using grpc::Status;class ExampleClient {
public:explicit ExampleClient(std::shared_ptr<Channel> channel): stub_(SearchService::NewStub(channel)) {}std::string Search(const std::string& user) {SearchRequest request;request.set_request(user);SearchResponse reply;ClientContext context;CompletionQueue cq;Status status;std::unique_ptr<ClientAsyncResponseReader<SearchResponse> > rpc(stub_->AsyncSearch(&context, request, &cq));rpc->Finish(&reply, &status, (void*)1);void* got_tag;bool ok = false;GPR_ASSERT(cq.Next(&got_tag, &ok));GPR_ASSERT(got_tag == (void*)1);GPR_ASSERT(ok);if (status.ok()) {return reply.response();} else {return "RPC failed";}}private:std::unique_ptr<SearchService::Stub> stub_;
};int main(int argc, char** argv) {ExampleClient client(grpc::CreateChannel("127.0.0.1:50051", grpc::InsecureChannelCredentials()));std::string user("world");std::string reply = client.Search(user);  // The actual RPC call!std::cout << "client received: " << reply << std::endl;return 0;
}

 

这篇关于Clion上搭建基于grpc的service与client实例的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---