publish-subscribe 相关问题

发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。

kafka可以像pubsub一样,按需动态创建consumergroup吗?

如果你有数以万计的消费者,每个消费者都需要自己的最新消息副本,并且消费者数量不断进出而波动,kafka可以支持这个用例吗? 我唯一的办法...

回答 1 投票 0

与消息代理的粘性会话

我正在开发一个项目,我们正在尝试利用消息代理,在类型消息开始发送给给定的消费者之后,它会继续发送给该消费者。这本质上是...

回答 1 投票 0

ActiveMQ - 结合发布订阅和点对点

有没有办法用ActiveMQ实现一个拓扑,其中P是发布者,s_a是服务A的订阅者,s_b1和s_b2是服务B的订阅者。后者设置在集群中用于负载

回答 1 投票 0

使用 ZeroMQ 时如何等待 SUB 套接字的订阅在 PUB 端注册?

我有消息总线,仅将消息从其 PULL 套接字转发到 PUB 套接字。它作为系统其他部分的通信媒介,使用 PUSH 套接字发送消息和 SUB 所以...

回答 1 投票 0

React Context API 无法支持高效的 pub sub 模式

我正在使用 React 的 Context API 来实现一个简单的发布-订阅模式。我有一个包含 100 个项目的列表,其中有一些重复项,每个项目上都有一个“赞”按钮,当我在...

回答 1 投票 0

使用声明方式处理 pub/sub 事件时从应用程序返回不可重试的错误

当我尝试使用 DAPR 发布/订阅使用主题时,出现这样的错误。看起来消息已成功消费,但之前记录了一个错误。无法识别 root-c...

回答 1 投票 0

Pusher 事件被触发两次

每当管理员发送通知时,我都会使用 Pusher (pusher.com) 向所有登录的客户端触发通知。 由于某种原因,该事件拍摄了两次,尽管我只触发了一次。 客户...

回答 2 投票 0

Redis pub/sub架构发布到chanel时返回0

我已经用C#实现了基于redis的应用程序。它是一个多层的发布/订阅架构。 我有 Redis 桌面管理器(RDM)以及在本地运行的 Redis 服务器。 还有一个

回答 2 投票 0

如果我没有使用 pubsub 设置“恰好一次传递”,重复发生的频率是多少?

我注意到使用“仅一次交付”会影响使用拉取和确认时的性能。拉取和确认消息所需的时间最多延长 5 倍(约 0.2 秒)。如果我禁用“

回答 2 投票 0

无法在 pgadmin 中创建 pg-notify 扩展

如果不存在则创建扩展 pg_notify;无法在 pgadmin 中执行此命令。 我收到以下错误: 错误:无法打开扩展控制文件“C:/Program Files/PostgreS...

回答 1 投票 0

使用 Websphere MQ 主题 .NET API

我读了这篇文章 并且仍然不理解主题在 MQ 中如何工作的概念。 在 JMS 中,我知道您可以在某个主题上发布消息,并且为了从该主题接收消息,您首先...

回答 1 投票 0

如何使用 Azure 事件网格监听所有 azure 订阅的事件?

我有一个天蓝色订阅列表,我想在其中使用Azure事件网格监听这些天蓝色订阅中的事件(例如创建的虚拟机)。 可以这样做吗?是...

回答 1 投票 0

如何使用 Azure 事件网格监听所有订阅的事件?

我有一个订阅列表,我想在其中使用 Azure 事件网格监听这些订阅中的事件(例如创建的虚拟机)。 可以这样做吗?有可能吗...

回答 1 投票 0

Node.js PubSub new v1.SubscriberClient() 拉取请求拉取很少的消息

我需要拉取 2500 条消息,因此我将 maxMessages 设置为 2500,但它仍然最多只拉取 500 条消息,而且通常也拉取不到 10 条消息。鉴于我同时拉取消息,我...

回答 1 投票 0

如何顺序处理Google Pub/Sub消息?

我正在尝试他们提供的 Google pub/sub 示例代码。类似于以下内容: 子.js // 导入 Google Cloud 客户端库 const {PubSub} = require('@google-cloud/pubsub'); // C...

回答 2 投票 0

数组中多条消息的架构指南

我们正在使用 Kafka 构建一个简单的发布-订阅系统。发布者是一项从发布到 Kafka 主题的客户端应用程序接收消息数组(称为块)的服务。我们有 4

回答 1 投票 0

在发布-订阅模式中我可以跟踪消息完成情况吗

我有两个微服务,它们使用 pub sub 模式相互通信。 我希望我的 serviceA 发布 100 条特定类型的消息,一旦所有消息都处理成功,那么

回答 2 投票 0

Quarkus,如何发送带有保留标志的Mqtt消息?

我目前正在使用 Smallrye 反应式消息传递与 Quarkus 发送 Mqtt 消息,问题是当我将保留标志添加为 true 时,没有任何变化。 我是这样做的: @播送 @频道(&q...

回答 1 投票 0

gcloud beta pubsub 订阅拉取格式

快速提问: 当我通过命令行工具从 pubsub 订阅中提取消息时 gcloud beta pubsub 订阅拉动 MY_SUB 我得到一个表格,其中包含(所有详细信息和)数据作为字符串(已经

回答 2 投票 0

如何使用Azure Pub Sub发送图像和二进制文档?支持吗?

如何使用Azure Pub Sub发送图像和二进制文档?是否支持或仅支持文本? 尝试将图像和文档发送到 azure pub sub。有什么限制吗?任何我们的例子...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.