程序员经验分享-hwhale

检测 ZeroMQ 队列中丢弃的消息

2023-11-26

由于似乎无法查询/检查底层 ZeroMQ 队列/缓冲区套接字以查看它们的利用率，因此是否有某种方法可以检测在发送/排队时由于发布者套接字中的缓冲区已满而导致消息被丢弃的情况？

例如，如果发布者队列已满，则zmq_send操作只会删除该消息。

基本上，我想要实现的是一种检测队列压力和/或满的情况的方法，以便能够（稍后）调整解决方案以更好地工作。一种替代方法是向每条消息添加序列号，并在订阅者中进行简单的计算，但我永远无法确定消息是否由于发布者中的缓冲区已满而丢失。


ZeroMQ 指南中有一个示例（如果你想愉快地使用 0MQ，你应该阅读并消化它）：http://zguide.zeromq.org/page:all#Slow-Subscriber-Detection-Suicidal-Snail-Pattern

该机制正如您自己回答的那样，在消息中添加序列号，并允许订阅者检测间隙并采取适当的操作。对于大多数 pubsub 场景，您可以将默认 HWM（1,000）提高到更高的值；这取决于您的平均邮件大小。

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

zeromq

检测 ZeroMQ 队列中丢弃的消息 的相关文章

  • 无法安装 PyZMP for Python -- 依赖项

    我在安装 iPython 的 PyZMP 依赖项时遇到问题 我尝试了很多方法 例如使用 pip brew 但最终还是使用手动安装包这个答案 Now pip list packages产生以下结果 pyzmq 14 2 0 dev pyzmq

  • NanoMsg (NNG) 和 FlatBuffers 是否适合该项目？

    大声喊出我们是否应该考虑更好的事情 我正在寻找一种非常快速且简单的方法来获取多个程序 例如 5 个 每个程序都在私有 OpenStack 云上的单独节点上运行以相互通信 数据包将是短 C 结构 小于 100 字节 交通流量将会较少 可能低于

  • Ratchet PHP WAMP - React / ZeroMQ - 特定用户广播

    Note 这是not与这个问题 https stackoverflow com questions 17583903 how to get the connection object of a specific user它利用Message

  • pyzmq安装错误

    我在尝试导入时收到错误zmq Traceback most recent call last File BasicPub py line 1 in

  • Linux重启后nodejs消失了

    我刚刚使用 nvm 安装了 nodejs 版本 0 10 14 它安装成功 同样在安装nodejs之前 我安装了zeromq版本2 2 0 出于测试目的 我尝试运行下面的基本酒吧示例 var zmq require zmq var sock

  • ZeroMQ：重新绑定套接字时地址使用错误

    将 ZeroMQ 套接字绑定到端点并关闭套接字后 将另一个套接字绑定到同一端点需要多次尝试 之前的调用zmq bind直到成功失败并出现错误 地址正在使用 EADDRINUSE 下面的代码演示了这个问题 include

  • Apache Thrift 和 ZeroMQ 之间的区别

    据我了解 Apache Thrift 和 ZeroMQ 是属于不同类别的软件 并且很难进行比较 因为这是苹果与橘子的比较 但我不知道为什么它们属于不同的类别 它们不是都用于在不同的服务之间传递数据吗 这些服务可能用不同的语言编写 也可能不是

  • 未找到类 ZMQContext

    我在 Ubuntu 14 04 的虚拟机内的 nginx 1 4 6 和 php 5 5 上运行 Web 服务器 并且需要安装 ZeroMQ 扩展 我已按照以下说明进行操作ZMQ http zeromq org area download

  • jeromq 生产准备好了吗？

    我过去曾通过 JVM 应用程序使用 ZeroMQjzmq图书馆 我计划在一个新项目中使用 Zeromq 其中一些服务是在 JVM 上实现的 我刚刚发现jeromq https github com zeromq jeromq 一个 Zero

  • NODE_MODULE_VERSION 46。此版本的 Node.js 需要 NODE_MODULE_VERSION 64。请尝试重新编译或重新安装

    我正在尝试执行提供给我的节点应用程序 它应该可以正常工作 我已尝试运行它 但无法修复此错误 seba vps92941 services drivetech node awto js home seba services drivetech

  • 了解 Zeromq Java 绑定

    我正在研究 Zeromq 作为 Java 项目中的消息传递解决方案 但我发现有关 Java 绑定的说明有点难以遵循 http www zeromq org bindings java http www zeromq org bindings

  • ZeroMQ性能测试。准确的延迟是多少？

    我正在使用 zmq 跨进程传输消息 并且我想做一些性能测试来获取延迟和吞吐量 官方网站给出了指南讲述如何运行性能测试 http zeromq org results perf howto 例如 我尝试过 local lat tcp 1521

  • Zeromq.node安装错误Ubuntu 12.04：'node-gyp重建'

    我正在尝试安装ZeroMQ节点 https github com JustinTulloss zeromq node using npm install zmq 但是 我不断收到以下错误 任何帮助将非常感激 gyp ERR build er

  • 如何使用 ZeroMQ 处理原始 UDP？

    我有一个客户 我无法更改其代码 但我想使用 重新 编写ZeroMQ插座 客户使用原始TCP和原始的UDP插座 我知道我可以使用ZMQ ROUTER RAW对于生的TCP插座 但是原始的怎么样 UDP数据流 ZeroMQ 中对 UDP 的支持

  • 如果可以使用 JZMQ，为什么还需要 JeroMQ？

    简单的问题 为什么在 Java 上 移植 zmq 并将其称为 JeroMQ 是个好主意 JeroMQ是ZeroMQ社区的官方项目 它是 C libzmq 库的完整移植 支持 3 2 版本 优点 纯Java 因此无需通过JNI链接C C 这对

  • Jupyter 和 Common Lisp

    我正在尝试安装cl jupyter https github com fredokun cl jupyter common lisp 内核Jupyter http jupyter org 我无法让它工作 当我打开一个新的 lisp 笔记本

  • 应用程序在 iOS 6 上崩溃：找不到符号：___sync_fetch_and_add_4

    我有一个与 iOS4 和 iOS5 完美配合的应用程序 它使用针对 ARM 的 Zeromq 库的静态编译版本 Apple 拒绝了我的应用程序 因为他们声称它在 iOS 6 下崩溃 尚未发布 wth 在使用 iOS 6 GM 尝试之后 我可

  • PyZMQ 是否处理为每个新客户端连接创建线程？

    我正在使用 PyZMQ 创建请求 回复服务器 并且我试图弄清楚为每个新客户端连接创建线程的行为是否由 PyZMQ 自动处理 最终 我试图弄清楚来自一个客户端的请求需要很长时间才能回复 是否会阻止来自所有其他客户端的请求 通常 我会在 Pyt

  • ZeroMQ在多线程应用程序中处理中断

    多线程环境下ZeroMQ的优雅退出 规格 带有 c 11 的 ubuntu 16 04 libzmq 4 2 3 示例代码 static int s interrupted 0 static void s signal handler in

  • 如何抑制Windows防火墙的Windows安全警报？

    当我从这里找到的 ZeroMQ 指南中用 C 创建 Hello World 示例时 http zguide zeromq org page all Ask and Ye Shall Receive http zguide zeromq or

随机推荐

  • WiX RemoveFolderEx 不起作用？

    我希望 WiX 在卸载时删除 AppData 文件夹 因此我查看了 RemoveFolderEx 并遵循了一些有关如何使其工作的帖子 指南 据我所知 我的实现应该有效 但事实并非如此 我正在使用以下内容

  • 如何一次构建多个包二进制文件

    我在不同的地方看到过这个讨论 答案包括 使用 cmd foo cmd bar 类型的文件夹结构 这对我不起作用 这有效 du a 8 src cmd bin1 main go 8 src cmd bin1 8 src cmd bin2 ma

  • ESLint 与 React 给出 `no-unused-vars` 错误

    我已经设置了eslint eslint plugin react 当我运行 ESLint 时 linter 返回no unused vars每个 React 组件的错误 我假设它没有识别出我正在使用 JSX 或 React 语法 有任何想法

  • android 显示软键盘时如何向上移动布局

    我的登录屏幕有两个EditTexts和我的布局中的登录按钮 问题是 当我开始打字时 会显示软键盘并覆盖登录按钮 当布局出现时 如何将布局向上或键盘上方推 我不想使用ScrollView 只想实现它而不向下滚动 那怎么办呢 Set windo

  • 防止服务器中出现多个实例相同的用户名

    我开发了一个托管在一台服务器上的应用程序 许多用户通过远程桌面连接访问它 但有时我在任务管理器中看到同一用户打开了 2 个实例 我需要防止同一用户无法打开多个实例 但请注意 该程序可以由不同的用户多次打开 请原谅我的英语 谢谢 PS 我使用

  • 在 Java Lambda 中，为什么对捕获的变量调用 getClass()

    如果你看一下字节码 Consumer

  • 使用VBA查找Windows中安装的MySQL ODBC驱动程序的版本

    使用 Visual Basic 进行应用程序 如何查明用户计算机上的 Windows 中安装了哪个版本的 MySQL ODBC 驱动程序 我有一个 Microsoft Access 应用程序 它使用 MySQL ODBC 驱动程序进行连接

  • 如何在mysql json表中使用where子句进行查询

    我使用的是mysql 5 7 x 我可以创建一个 mysql json 表 CREATE TABLE t1 jdoc JSON 我可以插入行 INSERT INTO t1 VALUES key1 value1 key2 value2 INS

  • 为什么Soap支持异步调用而Rest不支持？

    我在网上浏览了 Soap 与 Rest 发现大多数人都说 Soap 支持异步调用 而 Rest 不支持 但没有得到任何具体的例子 有人可以帮我吗 这是我提到的资源之一 http web archive org web 20120421084

  • 在 C++11 中实现 boost::Optional

    我正在尝试使用 c 11 功能实现 boost Optional 之类的数据结构 这是我到目前为止所拥有的 template

  • Android 可以进行点对点自组织网络吗？

    是否可以将 Android 设置为 ad hoc 对等 wifi 模式 例如 我想让一部电话广播一条消息 并让网络中的所有对等方接收广播 而无需服务器 我想使用 wifi 因为蓝牙范围更有限 这是有关您请求的功能的错误报告 它的状态是 已审

  • Angular 6 材质嵌套树不适用于动态数据

    我在用mat tree with mat nested tree node在角度 6 中 我想要的是当用户切换展开图标时动态加载数据 使用动态数据示例Flat Tree给出材料示例我尝试使用相同的概念Nested Tree 这是我到目前为止

  • 如何定义自己的asciidoc宏

    如何在 asciidoc asciidoctor 中定义宏 我将在文档的许多部分使用重复模式 因此我想进行参数化替换以避免多次输入相同的内容 特别是 我有以下 asciidoc 片段 set cellbgcolor grey grid no

  • 在网络浏览器中，窗口对象是本机 ECMAScript 对象吗？

    ECMAScript 规范定义了一个 在控制进入任何执行上下文之前创建的唯一全局对象 该全局对象是 ECMAScript 的标准内置对象 因此是本机对象 该规范还指出 除了本规范中定义的属性之外 全局 对象可能具有其他主机定义的属性 这可能

  • PHP - DOMDocument - 需要用新标签更改/替换现有 HTML 标签

    我正在努力改变一切 p 文档中的标签 p div 这是我想出来的 但它似乎不起作用 dom new DOMDocument dom gt loadHTML htmlfile data foreach dom gt getElementsBy

  • 在 super.init 中引用 self

    我有以下代码 编辑 更新了代码 以便每个人都可以编译并查看 import UIKit struct Action let text String let handler gt Void class AlertView UIView init

  • 获取 LinkedIn 用户个人资料图片

    喜欢脸书http graph facebook com userid picture 有没有一种简单的方法可以在 LinkedIn 中获取多张个人资料图片 您需要对 linkedin 使用 oAuth 并使用如下 url http api

  • 一次迭代多个列表的最佳方法是什么？ [复制]

    这个问题在这里已经有答案了 假设我有两个或多个相同长度的列表 迭代它们的好方法是什么 a b是列表 for i ele in enumerate a print ele b i or for i in range len a print a

  • 无法解析方法 readAllBytes()

    我正在尝试做什么 我正在尝试构建一个 java net 应用程序 其中客户端和服务器必须通过序列化集合类型相互发送数据 如下所示byte 问题 由于未知原因 我的 DataInputStream 无法解析该方法readAllBytes 一个

  • 检测 ZeroMQ 队列中丢弃的消息

    由于似乎无法查询 检查底层 ZeroMQ 队列 缓冲区套接字以查看它们的利用率 因此是否有某种方法可以检测在发送 排队时由于发布者套接字中的缓冲区已满而导致消息被丢弃的情况 例如 如果发布者队列已满 则zmq send操作只会删除该消息 基

热门标签