发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。
我正在开发一个项目,我们正在尝试利用消息代理,在类型消息开始发送给给定的消费者之后,它会继续发送给该消费者。这本质上是...
有没有办法用ActiveMQ实现一个拓扑,其中P是发布者,s_a是服务A的订阅者,s_b1和s_b2是服务B的订阅者。后者设置在集群中用于负载
使用 ZeroMQ 时如何等待 SUB 套接字的订阅在 PUB 端注册?
我有消息总线,仅将消息从其 PULL 套接字转发到 PUB 套接字。它作为系统其他部分的通信媒介,使用 PUSH 套接字发送消息和 SUB 所以...
React Context API 无法支持高效的 pub sub 模式
我正在使用 React 的 Context API 来实现一个简单的发布-订阅模式。我有一个包含 100 个项目的列表,其中有一些重复项,每个项目上都有一个“赞”按钮,当我在...
使用声明方式处理 pub/sub 事件时从应用程序返回不可重试的错误
当我尝试使用 DAPR 发布/订阅使用主题时,出现这样的错误。看起来消息已成功消费,但之前记录了一个错误。无法识别 root-c...
每当管理员发送通知时,我都会使用 Pusher (pusher.com) 向所有登录的客户端触发通知。 由于某种原因,该事件拍摄了两次,尽管我只触发了一次。 客户...
我已经用C#实现了基于redis的应用程序。它是一个多层的发布/订阅架构。 我有 Redis 桌面管理器(RDM)以及在本地运行的 Redis 服务器。 还有一个
如果我没有使用 pubsub 设置“恰好一次传递”,重复发生的频率是多少?
我注意到使用“仅一次交付”会影响使用拉取和确认时的性能。拉取和确认消息所需的时间最多延长 5 倍(约 0.2 秒)。如果我禁用“
如果不存在则创建扩展 pg_notify;无法在 pgadmin 中执行此命令。 我收到以下错误: 错误:无法打开扩展控制文件“C:/Program Files/PostgreS...
我读了这篇文章 并且仍然不理解主题在 MQ 中如何工作的概念。 在 JMS 中,我知道您可以在某个主题上发布消息,并且为了从该主题接收消息,您首先...
如何使用 Azure 事件网格监听所有 azure 订阅的事件?
我有一个天蓝色订阅列表,我想在其中使用Azure事件网格监听这些天蓝色订阅中的事件(例如创建的虚拟机)。 可以这样做吗?是...
我有一个订阅列表,我想在其中使用 Azure 事件网格监听这些订阅中的事件(例如创建的虚拟机)。 可以这样做吗?有可能吗...
Node.js PubSub new v1.SubscriberClient() 拉取请求拉取很少的消息
我需要拉取 2500 条消息,因此我将 maxMessages 设置为 2500,但它仍然最多只拉取 500 条消息,而且通常也拉取不到 10 条消息。鉴于我同时拉取消息,我...
我正在尝试他们提供的 Google pub/sub 示例代码。类似于以下内容: 子.js // 导入 Google Cloud 客户端库 const {PubSub} = require('@google-cloud/pubsub'); // C...
我们正在使用 Kafka 构建一个简单的发布-订阅系统。发布者是一项从发布到 Kafka 主题的客户端应用程序接收消息数组(称为块)的服务。我们有 4
我有两个微服务,它们使用 pub sub 模式相互通信。 我希望我的 serviceA 发布 100 条特定类型的消息,一旦所有消息都处理成功,那么
我目前正在使用 Smallrye 反应式消息传递与 Quarkus 发送 Mqtt 消息,问题是当我将保留标志添加为 true 时,没有任何变化。 我是这样做的: @播送 @频道(&q...
快速提问: 当我通过命令行工具从 pubsub 订阅中提取消息时 gcloud beta pubsub 订阅拉动 MY_SUB 我得到一个表格,其中包含(所有详细信息和)数据作为字符串(已经
如何使用Azure Pub Sub发送图像和二进制文档?支持吗?
如何使用Azure Pub Sub发送图像和二进制文档?是否支持或仅支持文本? 尝试将图像和文档发送到 azure pub sub。有什么限制吗?任何我们的例子...
我有2个不同的云功能。当前设置如下: 云调度器触发功能A 函数 A 使用 pub/sub 在脚本末尾触发函数 B 两种云功能...