带有ACE反应器的Zeromq
ZeroMQ with ACE Reactor
我有一个使用ACE反应器处理通信的旧应用程序。为了提高临时网络分区的可靠性,我想将Zeromq而不是TCP插座作为运输。ACE为现有的IPC机制提供C 包装器,但我想提供ACE可以使用的 Custom IPC机制。在我的特殊情况下,我想使用ZMQ,但是我的问题更笼统,我在问,如何使用ACE使用自定义运输?
有两种方法。
- 根据Zeromq为您提供的模型,从
ACE_SOCK
或ACE_IPC_SAP
中得出了一个新的IPC类家庭。不要忘记要匹配的地址课。这是很多工作,但是如果您在许多地方重复使用它,可能是值得的。 - 从
ACE_Event_Handler
中得出用例的处理程序,并包括您的Zeromq传输对象的成员。假设您可以从Zeromq对象获得可选的套接字手柄,则可以从get_handle()
钩访问它并向反应器注册。然后,在您的handle_input()
等人中,回调进行消息传输。这相对较快,容易。
相关文章:
- zeromq 在 I/O 线程中引发异常
- 如何在 Fedora 上为 C++ 包含 zeromq 标头?
- 如何使用ZeroMQ为协议缓冲区编写自己的RPC实现
- 如何在 MFC 应用程序中启动 ZeroMQ 线程?
- ZeroMQ:如何使用 C < C11 使用多个发布服务器和单个客户端
- ZeroMQ 发布-订阅通信:SUB 不接收任何内容
- ZeroMQ 在使用 std::thread 创建工作线程时崩溃
- ZeroMQ:如何使用inproc减少多线程通信延迟
- ZeroMq:打开的文件太多.在同一对象上连续增长的fd使用数
- 将Socket_t指针传递给ZeroMQ发送函数
- ZeroMQ :如何将 Poller 中使用的pollitem_t项投射回 ZeroMQ 套接字?
- 如何监控ZeroMQ服务器是否存在
- 如何在C++中使用ZeroMQ通信多个映像
- ZeroMQ SUB 从不接收消息
- ZeroMQ (cppzmq) 订阅者,过滤器以相同的字符串开头
- ZeroMQ(cppzmq)订阅者跳过第一条消息
- 平行反应器POCO C++
- 实时线程中的 ZeroMQ inproc PubSub send() 调用会导致严重的阻塞吗?
- 与处理 ZeroMQ 的永久线程与 Qt 通信
- 带有ACE反应器的Zeromq