恋恋风辰的官方博客

windows配置和使用grpc
Posted on 2023-05-31 19:59:00 by 恋恋风辰 | In C++ | 原文链接

简介

本文主要讲述如何在Windows环境下使用visual studio配置grpc，并且实现grpc通信的例子。前文windows配置和编译grpc已经介绍了如何在windows环境配置grpc，接下来我们利用之前编译好的库配置到项目中，并实现grpc通信。

项目配置

我们为了方便配置，将之前下载和编译好的项目放在D盘cppsoft文件夹下，路径为D:\cppsoft\grpc。

https://cdn.llfc.club/1685531030735.jpg

接下来我们创建一个项目，名字叫Grpc-Server,在项目的根目录下创建一个proto名字为demo.proto

  1. syntax = "proto3";
  3. package hello;
  5. service Greeter {
  6.   rpc SayHello (HelloRequest) returns (HelloReply) {}
  7. }
  9. message HelloRequest {
  10.   string message = 1;
  11. }
  13. message HelloReply {
  14.   string message = 1;
  15. }

接下来我们利用grpc编译后生成的proc.exe生成proto的头文件和源文件

  1. D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug\protoc.exe  -I="." --grpc_out="." --plugin=protoc-gen-grpc="D:\cppsoft\grpc\visualpro\Debug\grpc_cpp_plugin.exe" "demo.proto"

上述命令会生成demo.grpc.pb.h和demo.grpc.pb.cc文件。

D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug\protoc.exe表示protoc.exe所在的路径，你可以将其放在指定目录并配置环境变量，直接使用protoc.exe就行了。

-I="." 指定 demo.proto所在的路径为当前路径。

--grpc_out="." 表示生成的pb.h和pb.cc文件的输出目录。

--plugin=protoc-gen-grpc="D:\cppsoft\grpc\visualpro\Debug\grpc_cpp_plugin.exe"表示要使用的插件为cpp插件，也就是生成cpp类的头文件和源文件。

接下来我们生成grpc类需要的pb文件，因为要序列化数据。

  1. D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug\protoc.exe --cpp_out=. "demo.proto"

上述命令会生成demo.pb.h和demo.pb.cc文件。

接下来我们在项目中配置grpc库的包含目录和库目录。
为了方便调试，我们配置debug版本

https://cdn.llfc.club/1685532359790.jpg

项目属性中选择C++下的常规选项，在附加包含目录中添加我们grpc生成debug库

https://cdn.llfc.club/1685532525027.jpg

这里列举下要包含的目录

  1. D:\workspace\github\grpc\third_party\re2
  2. D:\workspace\github\grpc\third_party\address_sorting\include
  3. D:\workspace\github\grpc\third_party\abseil-cpp
  4. D:\workspace\github\grpc\third_party\protobuf\src
  5. D:\workspace\github\grpc\include

接下来配置库路径, 在链接器常规选项下，点击附加库目录，添加我们需要的库目录。

https://cdn.llfc.club/1685532681403.jpg

同样，我们配置的是debug版本

https://cdn.llfc.club/1685532839282.jpg

要配置的库目录很多，这里详细列举一下

  1. D:\cppsoft\grpc\visualpro\third_party\re2\Debug
  2. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\types\Debug
  3. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\synchronization\Debug
  4. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\status\Debug
  5. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\random\Debug
  6. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\flags\Debug
  7. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\debugging\Debug
  8. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\container\Debug
  9. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\hash\Debug
  10. D:\cppsoft\grpc\visualpro\third_party\boringssl-with-bazel\Debug
  11. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\numeric\Debug
  12. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\time\Debug
  13. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\base\Debug
  14. D:\cppsoft\grpc\visualpro\third_party\abseil-cpp\absl\strings\Debug
  15. D:\cppsoft\grpc\visualpro\third_party\protobuf\Debug
  16. D:\cppsoft\grpc\visualpro\third_party\zlib\Debug
  17. D:\cppsoft\grpc\visualpro\Debug
  18. D:\cppsoft\grpc\visualpro\third_party\cares\cares\lib\Debug

另外，我们虽然配置了库目录，但还要将要使用的库链接到项目
在链接器输入选项下，点击附加依赖项添加依赖的库名字

https://cdn.llfc.club/1685532997690.jpg

库配置

https://cdn.llfc.club/1685533182327.jpg

库名字列举如下

  1. libprotobufd.lib
  2. gpr.lib
  3. grpc.lib
  4. grpc++.lib
  5. grpc++_reflection.lib
  6. address_sorting.lib
  7. ws2_32.lib
  8. cares.lib
  9. zlibstaticd.lib
  10. upb.lib
  11. ssl.lib
  12. crypto.lib
  13. absl_bad_any_cast_impl.lib
  14. absl_bad_optional_access.lib
  15. absl_bad_variant_access.lib
  16. absl_base.lib
  17. absl_city.lib
  18. absl_civil_time.lib
  19. absl_cord.lib
  20. absl_debugging_internal.lib
  21. absl_demangle_internal.lib
  22. absl_examine_stack.lib
  23. absl_exponential_biased.lib
  24. absl_failure_signal_handler.lib
  25. absl_flags.lib
  26. absl_flags_config.lib
  27. absl_flags_internal.lib
  28. absl_flags_marshalling.lib
  29. absl_flags_parse.lib
  30. absl_flags_program_name.lib
  31. absl_flags_usage.lib
  32. absl_flags_usage_internal.lib
  33. absl_graphcycles_internal.lib
  34. absl_hash.lib
  35. absl_hashtablez_sampler.lib
  36. absl_int128.lib
  37. absl_leak_check.lib
  38. absl_leak_check_disable.lib
  39. absl_log_severity.lib
  40. absl_malloc_internal.lib
  41. absl_periodic_sampler.lib
  42. absl_random_distributions.lib
  43. absl_random_internal_distribution_test_util.lib
  44. absl_random_internal_pool_urbg.lib
  45. absl_random_internal_randen.lib
  46. absl_random_internal_randen_hwaes.lib
  47. absl_random_internal_randen_hwaes_impl.lib
  48. absl_random_internal_randen_slow.lib
  49. absl_random_internal_seed_material.lib
  50. absl_random_seed_gen_exception.lib
  51. absl_random_seed_sequences.lib
  52. absl_raw_hash_set.lib
  53. absl_raw_logging_internal.lib
  54. absl_scoped_set_env.lib
  55. absl_spinlock_wait.lib
  56. absl_stacktrace.lib
  57. absl_status.lib
  58. absl_strings.lib
  59. absl_strings_internal.lib
  60. absl_str_format_internal.lib
  61. absl_symbolize.lib
  62. absl_synchronization.lib
  63. absl_throw_delegate.lib
  64. absl_time.lib
  65. absl_time_zone.lib
  66. absl_statusor.lib
  67. re2.lib

grpc服务器

接下来我们写代码，实现grpc服务器

  1. #include <iostream>
  2. #include <memory>
  3. #include <string>
  4. #include <grpcpp/grpcpp.h>
  6. #include "demo.grpc.pb.h"
  8. using grpc::Server;
  9. using grpc::ServerBuilder;
  10. using grpc::ServerContext;
  11. using grpc::Status;
  12. using hello::HelloRequest;
  13. using hello::HelloReply;
  14. using hello::Greeter;
  16. // Logic and data behind the server's behavior.
  17. class GreeterServiceImpl final : public Greeter::Service {
  18.     Status SayHello(ServerContext* context, const HelloRequest* request,
  19.         HelloReply* reply) override {
  20.         std::string prefix("llfc grpc server has received :  ");
  21.         reply->set_message(prefix + request->message());
  22.         return Status::OK;
  23.     }
  24. };
  26. void RunServer() {
  27.     std::string server_address("127.0.0.1:50051");
  28.     GreeterServiceImpl service;
  30.     ServerBuilder builder;
  31.     // Listen on the given address without any authentication mechanism.
  32.     // 监听给定的地址
  33.     builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  34.     // Register "service" as the instance through which we'll communicate with
  35.     // clients. In this case it corresponds to an *synchronous* service.
  36.     builder.RegisterService(&service);
  37.     // Finally assemble the server.
  38.     std::unique_ptr<Server> server(builder.BuildAndStart());
  39.     std::cout << "Server listening on " << server_address << std::endl;
  41.     // Wait for the server to shutdown. Note that some other thread must be
  42.     // responsible for shutting down the server for this call to ever return.
  43.     server->Wait();
  44. }
  46. int main(int argc, char** argv) {
  47.     RunServer();
  49.     return 0;
  50. }

GreeterServiceImpl 继承自 Greeter::Service，重写了SayHello函数，当收到客户端发送的SayHello请求后执行重写函数功能的逻辑。

grpc客户端

grpc客户端比较简单，直接调用发送接口发送数据即可

  1. #include <string>
  2. #include <iostream>
  3. #include <memory>
  4. #include <grpcpp/grpcpp.h>
  5. #include "demo.grpc.pb.h"
  6. using grpc::ClientContext;
  7. using grpc::Channel;
  8. using grpc::Status;
  9. using hello::HelloReply;
  10. using hello::HelloRequest;
  11. using hello::Greeter;
  13. // static method : Greeter::NewStub
  14. class FCClient {
  15. public:
  16.     FCClient(std::shared_ptr<Channel> channel)
  17.         :stub_(Greeter::NewStub(channel)) {
  18.     }
  20.     std::string SayHello(std::string name) {
  21.         ClientContext context;
  22.         HelloReply reply;
  23.         HelloRequest request;
  24.         request.set_message(name);
  26.         Status status = stub_->SayHello(&context, request, &reply);
  28.         if (status.ok()) {
  29.             return reply.message();
  30.         }
  31.         else {
  32.             return "failure " + status.error_message();
  33.         }
  34.     }
  36. private:
  37.     std::unique_ptr<Greeter::Stub> stub_;
  38. };
  40. int main(int argc, char* argv[]) {
  41.     auto channel = grpc::CreateChannel("127.0.0.1:50051", grpc::InsecureChannelCredentials());
  42.     FCClient client(channel);
  43.     // block until get result from RPC server
  44.     std::string result = client.SayHello("hello , llfc.club !");
  45.     printf("get result [%s]\n", result.c_str());
  46.     return 0;
  47. }

客户端创建了一个channel，然后调用NewStub生成stub，接下来就可以发送数据了，下面是运行的效果

https://cdn.llfc.club/1685534091844.jpg

总结

本文介绍了grpc在windows环境下的配置和使用

源码链接https://gitee.com/secondtonone1/boostasio-learn

热门评论
点击查看更多评论 没有更多评论了,点击收起 展开评论

热门文章

  1. MarkDown在线编辑器
    喜欢(514) 浏览(15995)

  2. 聊天项目(28) 分布式服务通知好友申请
    喜欢(507) 浏览(7238)

  3. vscode搭建windows C++开发环境
    喜欢(596) 浏览(99108)

  4. 使用hexo搭建个人博客
    喜欢(533) 浏览(14081)

  5. Linux环境搭建和编码
    喜欢(594) 浏览(15714)

最新评论

  1. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理，无论工作也好生活也罢，最重要的是开心，即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃，所以我还是想去做喜欢的方向。
  2. 处理网络粘包问题 zyouth: //消息的长度小于头部规定的长度，说明数据未收全，则先将部分消息放到接收节点里 if (bytes_transferred < data_len) { memcpy(_recv_msg_node->_data + _recv_msg_node->_cur_len, _data + copy_len, bytes_transferred); _recv_msg_node->_cur_len += bytes_transferred; ::memset(_data, 0, MAX_LENGTH); _socket.async_read_some(boost::asio::buffer(_data, MAX_LENGTH), std::bind(&CSession::HandleRead, this, std::placeholders::_1, std::placeholders::_2, shared_self)); //头部处理完成 _b_head_parse = true; return; } 把_b_head_parse = true;放在_socket.async_read_some前面是不是更好
  3. C++ 线程池原理和实现 mzx2023:两种方法解决，一种是改排序算法，就是当线程耗尽的时候，使用普通递归，另一种是当在线程池commit的时候，判断线程是否耗尽，耗尽的话就直接当前线程执行task
  4. 利用指针和容器实现文本查询 越今朝:应该添加一个过滤功能以解决部分单词无法被查询的问题: eg: "I am a teacher."中的teacher无法被查询，因为在示例代码中teacher.被解释为一个单词从而忽略了teacher本身。
  5. 无锁并发队列 TenThousandOne:_head  和 _tail  替换为原子变量。那里pop的逻辑，val = _data[h] 可以移到循环外面吗

其他链接

  1. GitHub
  2. 个人博客
  3. 博客园
  4. CSDN

个人公众号

个人微信