后台线程c++中的grpc服务器

2024-03-28

我正在尝试在 MFC 应用程序的线程中运行 grpc 服务器。

我有(直接来自 GRPC 示例的 grpc 部分):

MyAppDlg.h:

#include <thread>
#include <grpcpp\grpcpp.h>

class MyAppDlg : public CDialog
{
public:
    MyAppDlg( CString aFileName, CWnd *pParent = NULL );
    virtual ~MyAppDlg();

    std::unique_ptr<grpc::Server> grpcServer;

    std::thread grpcThread;

    void RunServer();

MyAppDlg.cpp:

class GreeterServiceImpl final : public Greeter::Service {
    Status SayHello(ServerContext* context, const HelloRequest* request,
        HelloReply* reply) override {
        std::string prefix("Hello ");
        reply->set_message(prefix + request->name());
        return Status::OK;
    }
};

void MyAppDlg::RunServer() {
    std::string server_address("0.0.0.0:50051");
    GreeterServiceImpl service;
    grpc::EnableDefaultHealthCheckService(true);
    grpc::reflection::InitProtoReflectionServerBuilderPlugin();
    ServerBuilder builder;
    builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
    builder.RegisterService(&service);
    std::unique_ptr<Server> grpcServer(builder.BuildAndStart());
    std::cout << "Server listening on " << server_address << std::endl;

    // Wait for the server to shutdown. Note that some other thread must be
    // responsible for shutting down the server for this call to ever return.
    grpcServer->Wait(); <-- Leaving this out causes the server to close immediately again.
}

MyAppDlg::MyAppDlg( CString aFileName, CWnd* pParent /* =NULL */ )
{
    ... stuff ...
    // RunServer(); <-- using this works but blocks the thread
    grpcThread(RunServer); <-- does not work

}

MyAppDlg::~MyAppDlg()
{
    grpcServer->Shutdown();
    grpcThread.join();
}

没有线程,它运行良好(客户端可以连接并调用SayHello),但会阻塞构造函数RunServer()因为grpcServer->Wait()称呼。尝试使用线程,我收到编译器错误:call of an object of a class type without appropriate operator() or conversion functions to pointer-to-function type

不打电话grpcServer->Wait()导致服务器立即关闭RunServer()退出,尽管变量grpcServer只要类实例正在运行,它就仍然在范围内。

我该如何正确开始grpcServer并将其放在后台?


我认为问题出在这一行MyAppDlg::RunServer():

std::unique_ptr<Server> grpcServer(builder.BuildAndStart());

您正在定义一个名为的局部变量grpcServer而不是分配给同名的类数据成员,因此一旦RunServer()返回。我认为应该只是:

grpcServer.reset(builder.BuildAndStart());
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

后台线程c++中的grpc服务器 的相关文章

  • 临时表是线程安全的吗?

    我正在使用 SQL Server 2000 它的许多存储过程广泛使用临时表 数据库的流量很大 我担心创建和删除临时表的线程安全性 假设我有一个存储过程 它创建了一些临时表 它甚至可以将临时表连接到其他临时表等 并且还可以说两个用户同时执行存
  • 为什么两个不同的 Base64 字符串的转换会返回相等的字节数组?

    我想知道为什么从 base64 字符串转换会为不同的字符串返回相同的字节数组 const string s1 dg const string s2 dq byte a1 Convert FromBase64String s1 byte a2
  • 类模板参数推导 - clang 和 gcc 不同

    下面的代码使用 gcc 编译 但不使用 clang 编译 https godbolt org z ttqGuL template
  • C#中如何移动PictureBox?

    我已经使用此代码来移动图片框pictureBox MouseMove event pictureBox Location new System Drawing Point e Location 但是当我尝试执行时 图片框闪烁并且无法识别确切
  • 创建链表而不将节点声明为指针

    我已经在谷歌和一些教科书上搜索了很长一段时间 我似乎无法理解为什么在构建链表时 节点需要是指针 例如 如果我有一个节点定义为 typedef struct Node int value struct Node next Node 为什么为了
  • 重载<<的返回值

    include
  • WCF 中 SOAP 消息的数字签名

    我在 4 0 中有一个 WCF 服务 我需要向 SOAP 响应添加数字签名 我不太确定实际上应该如何完成 我相信响应应该类似于下面的链接中显示的内容 https spaces internet2 edu display ISWG Signe
  • 显示UnityWebRequest的进度

    我正在尝试使用下载 assetbundle统一网络请求 https docs unity3d com ScriptReference Networking UnityWebRequest GetAssetBundle html并显示进度 根
  • 如何设计以 char* 指针作为类成员变量的类?

    首先我想介绍一下我的情况 我写了一些类 将 char 指针作为私有类成员 而且这个项目有 GUI 所以当单击按钮时 某些函数可能会执行多次 这些类是设计的单班在项目中 但是其中的某些函数可以执行多次 然后我发现我的项目存在内存泄漏 所以我想
  • SolrNet连接说明

    为什么 SolrNet 连接的容器保持静态 这是一个非常大的错误 因为当我们在应用程序中向应用程序发送异步请求时 SolrNet 会表现异常 在 SolrNet 中如何避免这个问题 class P static void M string
  • 无锁算法真的比全锁算法性能更好吗?

    陈雷蒙德 http blogs msdn com b oldnewthing 一直在做一个huge http blogs msdn com b oldnewthing archive 2011 04 15 10154245 aspx ser
  • 转发声明和包含

    在使用库时 无论是我自己的还是外部的 都有很多带有前向声明的类 根据情况 相同的类也包含在内 当我使用某个类时 我需要知道该类使用的某些对象是前向声明的还是 include d 原因是我想知道是否应该包含两个标题还是只包含一个标题 现在我知
  • Java执行器服务线程池[关闭]

    很难说出这里问的是什么 这个问题是含糊的 模糊的 不完整的 过于宽泛的或修辞性的 无法以目前的形式得到合理的回答 如需帮助澄清此问题以便重新打开 访问帮助中心 help reopen questions 如果我使用 Executor 框架在
  • 垃圾收集器是否在单独的进程中运行?

    垃圾收集器是否在单独的进程中启动 例如 如果我们尝试测量某段代码所花费的进程时间 并且在此期间垃圾收集器开始收集 它会在新进程上启动还是在同一进程中启动 它的工作原理如下吗 Code Process 1 gt Garbage Collect
  • 覆盖子类中的字段或属性

    我有一个抽象基类 我想声明一个字段或属性 该字段或属性在从该父类继承的每个类中具有不同的值 我想在基类中定义它 以便我可以在基类方法中引用它 例如覆盖 ToString 来表示 此对象的类型为 property field 我有三种方法可以
  • 如何将带有 IP 地址的连接字符串放入 web.config 文件中?

    我们当前在 web config 文件中使用以下连接字符串 add name DBConnectionString connectionString Data Source ourServer Initial Catalog ourDB P
  • 如何在Xamarin中删除ViewTreeObserver?

    假设我需要获取并设置视图的高度 在 Android 中 众所周知 只有在绘制视图之后才能获取视图高度 如果您使用 Java 有很多答案 最著名的方法之一如下 取自这个答案 https stackoverflow com a 24035591
  • 是否可以在 .NET Core 中将 gRPC 与 HTTP/1.1 结合使用?

    我有两个网络服务 gRPC 客户端和 gRPC 服务器 服务器是用 NET Core编写的 然而 客户端是托管在 IIS 8 5 上的 NET Framework 4 7 2 Web 应用程序 所以它只支持HTTP 1 1 https le
  • C# - OutOfMemoryException 在 JSON 文件上保存列表

    我正在尝试保存压力图的流数据 基本上我有一个压力矩阵定义为 double pressureMatrix new double e Data GetLength 0 e Data GetLength 1 基本上 我得到了其中之一pressur
  • Windows 和 Linux 上的线程

    我在互联网上看到过在 Windows 上使用 C 制作多线程应用程序的教程 以及在 Linux 上执行相同操作的其他教程 但不能同时用于两者 是否存在即使在 Linux 或 Windows 上编译也能工作的函数 您需要使用一个包含两者的实现

随机推荐

  • SwiftUI:无法将“Bool”类型的值转换为预期的参数类型“Binding

    为 SwiftUI 创建基于文本的游戏 想知道为什么我无法在字符 ForEach 循环中访问 isSelected 它给出了错误 无法将类型 Bool 的值转换为预期参数类型 Binding 在线上Toggle isOn character
  • 为什么 const_cast 会删除指针的常量性,但不会删除指向 const 的指针?

    我明白那个const cast使用指针和引用 我假设输入const cast应该是一个指针或引用 我想知道为什么如果输入是指针 引用 它不会消除常量性const int 以下代码按预期工作 const cast具有多级指针 int main
  • 如何删除自动完成上的清除按钮并仅显示文本

    我是反应虚拟化和自动完成的新手 我目前已经构建了一个列表 当选中该复选框时 该列表会显示多个文本 这是我的代码 https codesandbox io s material demo forked 1qzd3 file demo tsx
  • Django:限制模型数据

    我正在以一种限制可以通过模型获得的查询集的方式进行搜索 假设我有以下模型 具有依赖项 Company Section Employee Task more models Customer Contract Accounts other gr
  • 使用 dict.values() 或 dict.itervalues() 迭代时修改字典值

    我有一个像这样初始化的字典 tab Mike 0 Chad 15 Taylor 2 我希望能够将整数添加到字典中的每个值 例如 添加 5 后 字典应如下所示 Mike 5 Chad 20 Taylor 7 似乎这可以通过几行代码来完成 但我
  • mvc视图中模型空引用异常

    问题是从控制器传递数据到视图时出现空引用异常 我将模型从控制器传递到视图 如下所示 ViewBag PartId id var viewmodel new Orderviewmodelnew var order new OrderMnage
  • 扩展 APDU 和 T=0/1 通信协议

    我有一个 JCOP V2 4 2 R3 java 卡 它的数据表中提到 该卡支持T 1 and T 0通信协议 我还有一个 ACR38 智能卡读卡器 它支持 T 0 和 T 1 协议 我与一张卡成功进行了 T 0 通信 并且与该卡成功进行了
  • C# 中的 StreamReader 和缓冲区

    我对 StreamReader 的缓冲区使用有疑问 这里 http msdn microsoft com en us library system io streamreader aspx http msdn microsoft com e
  • 如何让 Polymer 2.0 ES5 元素与 v1 规范一起工作?

    我已经成功构建了许多 Polymer 2 0 元素 它们在支持 ES6 的浏览器中运行良好 当我尝试将它们转换为 ES5 时 浏览器会抛出一堆错误 如下所示 Failed to construct HTMLElement Please us
  • 哪些 Web 浏览器支持通过 HTML5 进行地理定位?

    哪些网络浏览器 和版本 支持通过 HTML5 进行地理定位 在桌面上仅支持 Firefox 不确定 Opera 是否已将其包含在官方版本中 在移动设备上 mobile safari 3 和 android 2 x 浏览器 有关支持的更多信息
  • 使用 python 以字节块的形式读取文件

    我正在尝试将包含超过 10 亿字节的文件转换为整数 显然 我的机器无法立即执行此操作 因此我需要对代码进行分块 我能够解码前 50 000 000 个字节 但我想知道如何读取文件中介于 50 000 001 和 100 000 000 15
  • 如何获取SQL组查询的第一行?

    我在编写查询时遇到问题 我想选择分组的每组行的第一行 我的桌子是Transactions userID Date StoreID 1 8 9 2013 10 1 9 9 2013 10 1 10 9 2013 20 2 7 9 2013 3
  • 使用 pyvips 连接多个巨大图像

    我试图弄清楚如何通过 python 将多个图像与 vip 结合起来 我在一个文件夹中有 30 个 但可以超过 600 个 条纹 png 文件 它们的分辨率为 854x289920 所有分辨率都相同 如果我尝试使用 MemmoryError
  • Apache POI autoSizeColumn() 无法正常工作[重复]

    这个问题在这里已经有答案了 我正在创建一个程序 使用 apache poi 将信息写入 Excel 文件 将所有数据输入文件后 我对文件的每一列调用 autoSizeColumn 方法 但它会将列的大小调整为最后输入的单元格的宽度 该宽度有
  • LNK1106 具有大量二进制资源

    我的项目中有一个相当大的 dat 文件 896MB 作为 BIN 资源 现在我收到 LNK1106 链接错误 致命错误 LNK1106 无效文件或磁盘已满 无法查找 0x382A3920 我在 Windows XP 下使用 Visual S
  • 用于非图像矩阵的 Keras CNN

    我最近开始学习深度学习和强化学习 我试图弄清楚如何使用 Keras 为 10 行 3 列的 0 和 1 矩阵编写卷积神经网络 例如 输入矩阵看起来像这样 1 0 0 0 1 0 0 0 0 输出应该是另一个由 0 和 1 组成的矩阵 与前面
  • React Native 导航 v5 选项卡按下不起作用

    从代码中可以看出 tabPress 没有被调用 是我做错了还是我遗漏了一些东西 不幸的是我没有找到任何 React 导航版本 5 的代码示例
  • Angular 材质创建类似于引导警报的警报

    我是有角材料的新手 我正在尝试实现警报以使用角度材料显示消息 这与引导警报即类似 div class alert alert success strong Well done strong You successfully read thi
  • 如何在nodejs中验证rabbitmq?

    错误 握手被服务器终止 403 ACCESS REFUSED 消息 ACCESS REFUSED 使用身份验证拒绝登录 旋转机制平原 有关详细信息 请参阅代理日志文件 我单独尝试了 authMechanism PLAIN AMQPLAIN
  • 后台线程c++中的grpc服务器

    我正在尝试在 MFC 应用程序的线程中运行 grpc 服务器 我有 直接来自 GRPC 示例的 grpc 部分 MyAppDlg h include