程序员经验分享-hwhale

RabbitMQ / AMQP 中的消息组

2023-11-26

ActiveMQ / JMS 有一个内置机制，可确保在使用竞争消费者模式时，共享公共标头（即 JMSXGroupID 标头）的消息始终由队列的同一使用者使用。队列的消费者完全不知道实际的标头值，因为具有公共标头的消息的保证是在服务器端而不是消费者端执行的。有关其工作原理的更多详细信息，请参阅http://activemq.apache.org/message-groups.html .

使用 AMQP 或 RabbitMQ 特定的东西可以做这样的事情吗？


截至撰写此答案时，仅使用 AMQP 是不可能做到这一点的，并且需要在应用程序方面进行工作。 RabbitMQ 计划在未来实现类似的功能，但不会很快发布或开发。

参考：https://github.com/rabbitmq/rabbitmq-server/issues/262 and https://twitter.com/old_sound/status/410898209788411904

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

rabbitmq

Messaging

AMQP

RabbitMQ / AMQP 中的消息组 的相关文章

  • 使用 RabbitMq 锁定和批量获取消息

    我正在尝试以一种更非常规的方式使用 RabbitMq 尽管此时我可以根据需要选择任何其他消息队列实现 消费者不会将 Rabbit 推送消息留给我的消费者 而是连接到一个队列并获取一批 N 条消息 在此期间它会消费一些消息 并可能拒绝一些消息

  • RabbitMQ Java 客户端自动重新连接

    当我的应用程序失去与 RabbitMQ 的连接时 我将其连接工厂设置为自动尝试并重新连接 ConnectionFactory factory new ConnectionFactory factory setUsername usernam

  • AMQP如何克服直接使用TCP的困难？

    AMQP如何克服直接使用TCP发送消息时的困难 或者更具体地说 在发布 订阅场景中 在 AMQP 中 有一个代理 该代理接收消息 然后完成将消息路由到交换器和队列的困难部分 您还可以设置持久队列 即使客户端断开连接 也可以为客户端保存消息

  • RabbitMQ - 如何死信/处理过期队列中的消息？

    我有一个队列x expires放 我遇到的问题是我需要对队列中的消息进行进一步处理IF队列过期 我最初的想法是设置x dead letter exchange在队列中 但是 当队列过期时 消息就会消失而不会进入死信交换 如何处理死信或以其他

  • 面向服务的架构 - AMQP 或 HTTP

    一点背景 非常大的整体 Django 应用程序 所有组件都使用相同的数据库 我们需要分离服务 以便我们可以独立升级系统的某些部分而不影响其余部分 我们使用 RabbitMQ 作为 Celery 的代理 现在我们有两个选择 使用 REST 接

  • 如何使用 AMQP 以“PeekLock”模式从 Azure 服务总线队列获取消息？

    我们正在尝试在 Node 应用程序中使用 Azure 服务总线 我们的要求是从队列中获取多条消息 由于Azure SDK for Node不支持批量检索 我们决定使用AMQP 虽然我们能够使用 Peek Messages 获取消息 如此处所

  • 服务器在 pika.exceptions.StreamLostError: Stream 连接丢失后关闭

    我的队列中有一些图像 我将每个图像传递到我的 Flask 服务器 在其中完成图像处理 并在我的rabbitmq 服务器中收到响应 收到响应后 我收到此错误 pika exceptions StreamLostError 流连接丢失 104

  • 无法使用 abortBroadcast() 阻止短信？

    我正在开发一个短信拦截器应用程序 其中我使用广播接收器和 abortBroadcast 方法 正如许多人在这里建议的那样 防止消息到达收件箱并提醒用户 但就我而言 当我使用模拟器发送短信时 短信不会被阻止 并到达收件箱 我也会收到错误 06

  • JMS 中的 MessageListener 和 Consumer 有什么区别？

    我是新来的JMS 据我了解Consumers能够从队列 主题中挑选消息 那么为什么你需要一个MessageListener因为Consumers会知道他们什么时候收到消息吗 这样的实际用途是什么MessageListener 编辑 来自Me

  • RabbitMQ 等待消息超时

    我想向 RabbitMQ 服务器发送一条消息 然后等待回复消息 在 回复 队列上 当然 我不想永远等待 以防处理这些消息的应用程序出现故障 需要有一个超时 这听起来像是一项非常基本的任务 但我找不到方法来做到这一点 我现在在使用 Java

  • 使用 Spring 与 RabbitMQ 集成

    我正在为我们的一个应用程序开发消息传递界面 该应用程序是一种服务 旨在接受 作业 进行一些处理并返回结果 实际上以文件的形式 这个想法是使用 RabbitMQ 作为消息传递基础设施 并使用 Spring AMQP 来处理协议特定的细节 我不

  • RabbitMQ 中 Pub/Sub 与工作队列的混合

    我正在评估使用 RabbitMQ 作为消息队列 消息总线 并一直在查看示例教程 https www rabbitmq com getstarted html在 RabbitMQ 页面上 我正在寻找教程中未涵盖的特定场景 并且我不确定是否以及

  • 启动时加载 RabbitMQ 配置

    如何在启动时加载 RabbitMQ 配置以确认已创建代理对象 队列 交换 绑定 用户 虚拟主机 权限和参数 根据 RabbitMQ 文档 可以通过以下方式完成load definitions http www rabbitmq com ma

  • 如何停止本地主机上的 RabbitMQ 服务器

    我在 OS X 上安装了 RabbitMQ 服务器 并在命令行上启动它 现在 我应该如何阻止它运行还不清楚 我这样做之后 sudo rabbitmq server detached I get Activating RabbitMQ plu

  • 具有重新排队功能的 BasicReject 实际上去了哪里？

    这似乎是一个简单的问题 但我很难找到明确的答案 如果在 RabbitMQ 3 6 1 中我有一个如下所示的队列 5 4 3 2 1 lt head 我使用消息 1 然后执行以下操作 channel BasicReject ea Delive

  • RabbitMQ + Windows + LDAP 无需发送密码

    我正在尝试在 Windows 7 上使用 RabbitMQ 3 6 2 进行 LDAP 身份验证 授权 我已经在应用程序发送用户名 密码的情况下进行了基本身份验证 但密码位于我需要弄清楚如何进行的代码中避免 有没有人在不提供密码的情况下成功

  • 如何停止rabbitmq服务器

    我正在尝试启动一个节点应用程序 但我认为rabbitmq 妨碍了我 与此线程类似 名为 rabbit 的节点已经在运行 但也 无法连接到节点 rabbit https stackoverflow com questions 8737754

  • 使用 Celery 时出现错误消息“无法找到记录器“多处理”的处理程序”

    RabbitMQ http en wikipedia org wiki RabbitMQ现在似乎工作正常 然而 当我尝试 python m celery bin celeryd loglevel INFO 常规的celeryd不起作用 我收

  • PHPUnit RabbitMQ：为创建连接函数编写测试

    我面临以下问题 我编写了一个函数 根据所需参数创建连接对象 AMQPConnection 现在我想编写相应的单元测试 我只是不知道在没有运行 RabbitMQ 代理的情况下如何做到这一点 这是有问题的函数 public function g

  • Celery 设计帮助：如何防止并发执行任务

    我对 Celery AMQP 相当陌生 正在尝试提出一个任务 队列 工作人员设计来满足以下要求 我有多种类型的 每用户 任务 例如 TaskA TaskB TaskC 这些 每用户 任务中的每一个都为系统中的一个特定用户读取 写入数据 因此

随机推荐

  • throw 0 是什么意思？是“坏”吗？

    Context 我遇到了一些代码 如下所示 if Some Condition throw 0 我用谷歌搜索了一下 发现了一些其他代码片段 使用了那个看起来很奇怪的代码throw 0 form 我想人们会这样理解 catch const i

  • 如何从sklearn的CCA模块获得第一个规范相关性？

    在 Python 的 scikit learn 中 有一个名为 cross decomposition 的模块 其中包含规范相关分析 CCA 类 我一直在试图弄清楚如何给出形状 n m 的 2 类多维向量并获得第一个规范相关系数 查看文档

  • Angular 2 Animate - 更改路线/组件时“* => void”过渡没有可见效果

    使用 Angular 2 Animate RC2 在官方文档的帮助下 以及 Matias 在 YT 频道上一个月前的 ng conf 动画视频中使用的代码 除了最关键的部分之外 我一切正常 更改路由器链接 组件时 我似乎无法让离开过渡 动画

  • tidyverse 未加载，它显示“命名空间‘vctrs’0.2.0 已加载，但需要 >= 0.2.1”

    强文本我在安装时不断遇到问题tidyverse包 这使我无法实现许多文本处理任务 这个问题与 2017 年以来许多以前的线程中提到的问题相同 因为当我输入library tidyverse 或者尝试打开其他相关包 他们总是说需要0 2 1版

  • 为什么二元 + 运算符不能与两个 &mut int 一起使用？

    fn increment number mut int this fails with binary operation cannot be applied to type mut int let foo number number let

  • Eclipse - java.lang.ClassNotFoundException

    当尝试从 Eclipse 中启动 JUnit Test 时 我收到 ClassNotFoundException 从控制台运行 mvn test 时 一切正常 另外 Eclipse 中也没有报告任何问题 我的项目结构如下 parent pr

  • 非静态回调如何在本机代码中工作？

    问这个问题有点奇怪 因为我的代码看起来不应该工作 但它确实工作 虽然我没有抱怨 但我想确认为什么 哈哈 简而言之 我有一个 C 本机 DLL 根本没有 CLR 托管支持 它接受来自 C 代码的回调 Native端存储了一个stdcall回调

  • 将 mySQL 查询作为 cron 作业运行？

    我想清除 SQL 数据库中超过 1 周的所有数据 并且我想每晚执行此操作 所以 我要设置一个 cron 作业 如何查询mySQL而无需每次都手动输入密码 PHP中的查询如下 mysql query DELETE FROM tbl messa

  • 将字符“00:00:00”转换为日期时间“00:00:00”

    我的问题来自这个问题 问题有以下字符串 x lt 2007 02 01 00 00 00 y lt 02 01 2007 00 06 10 如果您尝试将此字符串转换为日期类对象 则会发生一些有趣的事情 这是 nrusell 答案的示例 as

  • 如何将 na.rm 作为参数传递给 tapply？

    我想从数据框中计算平均值和标准差 其中一列用于参数 一列用于组标识符 使用时如何计算它们tapply 我可以用sd v1 group na rm TRUE 但无法适应na rm TRUE使用时进入语句tapply omit na是没有选择

  • Android 多重通知在点击时发送相同的数据

    Android 中的通知在点击时具有相同的意图 我在安装主题后发送通知 考虑我安装了 4 个主题 通知窗口中出现了 4 个通知 但是当我单击每个通知时 它将启动特定的活动 但意图是每个意图具有相同的数据 我的代码是这样的 SuppressW

  • 无法从“const wchar_t *”转换为“_TCHAR *”

    TCHAR strGroupName NULL const TCHAR strTempName NULL Assign some value to strTempName strGroupName tcschr strTempName 92

  • 管理 TPL 队列

    我有一项运行各种服务器扫描的服务 所涉及的网络可能非常庞大 数十万个网络节点 该软件的当前版本使用的是我们设计的队列 线程架构 该架构可以工作 但效率不高 尤其是因为作业可能会产生处理不好的子项 V2 即将推出 我正在考虑使用 TPL 看起

  • Java 标签不规则（可能是错误？）

    如果我们看一下Java标准 14 7 我们看到语句可能有标签前缀 例如 标签声明 标识符 声明 理论上 标签应该能够标记任何后续语句 因此 例如 以下内容将相应编译 public class Test public static void

  • OpenCV unproject 2D 指向具有已知深度“Z”的 3D

    问题陈述 我正在尝试将 2D 点重新投影到其原始 3D 坐标 假设我知道每个点的距离 继OpenCV 文档 我设法让它以零失真的方式工作 然而 当存在扭曲时 结果就不正确 目前的方法 因此 我们的想法是反转以下内容 分为以下内容 By 使用

  • 使用 jQuery 的“是”或“否”确认框

    我想要使 用 jQuery 发出 是 否 警报 而不是 确定 取消 按钮 jQuery alerts okButton Yes jQuery alerts cancelButton No jConfirm Are you sure func

  • Qt XML 中属性的顺序不正确

    我有以下代码 element clear element setTagName accountpoint element setAttribute code QString ID CONST serial element setAttrib

  • 自动构建 NuGet 包，包括引用的依赖项

    我想要运行本地 内部 NuGet 存储库 我想我已经弄清楚如何 重用 现有的 NuGet 包 方法是将它们包含在使用 NuGet 的虚拟项目中并扫描包文件以获取我的本地缓存 nupkg files but 如何创建 nuget 包 nupk

  • 将 2D 数组转换为 3D numpy 数组

    我创建了一个 numpy 数组 数组的每个元素都包含相同形状的数组 9 5 我想要的是一个 3D 数组 我尝试过使用 np stack data list map lambda x getKmers x 9 data getKmers cr

  • RabbitMQ / AMQP 中的消息组

    ActiveMQ JMS 有一个内置机制 可确保在使用竞争消费者模式时 共享公共标头 即 JMSXGroupID 标头 的消息始终由队列的同一使用者使用 队列的消费者完全不知道实际的标头值 因为具有公共标头的消息的保证是在服务器端而不是消费

热门标签