publish-subscribe 相关问题

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

无法发布到 symfony 中的 rabbitmq 默认交换

当我尝试向 rabbitmq 默认交换发布消息时,我收到错误:“ACCESS_REFUSED - 默认交换不允许操作” 我用 交响乐 4.2 php-amqplib/rabbitmq-bu...

回答 0 投票 0

如何使用 Azure 服务近乎实时地收听 GCP 发布/订阅

我无法找到以下信息或示例: 使用 Azure 服务,无论是 Durable Functions 还是 EventGrid 或其他……我想订阅我的 GCP Pub/Sub 服务……

回答 1 投票 0

在 go 服务中基于每个用户使用 Redis pubsub 的内存高效方式?

我们使用 GraphQL 订阅将数据推送到客户端。在用 golang 编写的 GraphQl 服务器上,我们为每个用户订阅连接到一个 pubsub 频道(每个用户的频道都是唯一的)。虽然

回答 0 投票 0

在 zeromq pub sub 上丢失消息

我正在尝试使用 zeromq 框架实现 pub sub 设计模式。 这个想法是先启动订阅者,然后再启动发布者。 订阅者将收听 100 条消息,并且 ...

回答 4 投票 0

ZeroMQ Python Pub/Sub 1-to-许多

我已经阅读了所有 zeromq 文档,简单模式和高级模式。 我尝试使用转发器作为中介,因此发布者发布到转发器。转发器发布给订阅者。 尝试使用 TCP,并且对于

回答 0 投票 0

什么是最好的 PUB/SUB 模型? [关闭]

我一直在学习 ActiveMq、HiveMQ、ZeroMQ 和 Kafka,以便为我的物联网应用程序实施 PUB/SUB 模型。 我们在后端有 nodeJs,我们正在使用多种类型的机器人来处理数据。 的...

回答 0 投票 0

如何在 GCP 发布/订阅应用程序中处理 nack 按摩?

我正在编写一个 gcp pub/sub 应用程序,但我无法正确地 nack() 一条消息。您能否查看以下代码并提供帮助 - @成分 公开课 PubSubEventConsu...

回答 0 投票 0

无法从 Gmail Pub/Sub API 中消除重复项

我已经设置了带有推送通知的 Pub/Sub 订阅,以使用这些参数观看 Gmail 收件箱: watch_request = { 'labelIds': ['收件箱'], '主题名称':'...' } 我...

回答 0 投票 0

为什么 rabbitmq 队列中的发布和消费者确认意外下降?

这里是排队消息和消息速率图的屏幕截图 队列详情 我试过增加队列的消费者,消息发布率是 150,但仍然有下降。

回答 1 投票 0

如何使用 arduino pubsubclient 库发送两个字符串 - 获取无效操作数错误

可能是一件足够简单的事情-如此之多以至于我认为值得一问。 我熟悉来自用于 Spark/Particle 设备的 hirotasker 端口的 pubsub mqtt 客户端库。我正在努力...

回答 0 投票 0

创建 Pub/Sub 主题后如何订阅它们

我有一个包含各种发布/订阅主题的 GCP 项目,我想订阅所有这些主题并在创建它们时自动附加它们(我的用例是我...

回答 1 投票 0

在 Apache Camel 中从 Google Pubsub 轮询数据时如何处理错误

我为来自 Google Pubsub 主题的投票数据开发了一个 Camel 项目。这是我的 Pubsub 路线。 from("google-pubsub:xProjectx:xTopicx?maxMessagesPerPoll=20&concurrentConsumers=10&ackMode=...

回答 0 投票 0

发布到 pubsub pubsub 中的主题 topic_name 时出现 RabbitMQ dapr 错误:通道未初始化

我正在使用 dapr rabbitmq pubsub 发布和订阅事件。 云端点工作正常,但在本地设置中出现错误 在

回答 0 投票 0

如果 1 个消费者组中有 1 个主题和 1 个消费者,但 1 个消费者在多台机器上运行,Kafka 将如何管理事件顺序

最近遇到一个情况: 事件正在发布到 1 个主题 鉴于我们在 1 个消费者组中有 1 个消费者。 为了跟上生产消息和消费消息的步伐,我们有...

回答 1 投票 0

使用了哪些工具和技术来构建QStash? [关闭]

使用了哪些工具和技术来构建QStash? 背景:我 6 个月前开始了我的第一份 Web 开发人员工作,最近我将 QStash 集成到我们的解决方案中。我喜欢它,但和其他许多人一样

回答 0 投票 0

如何在 NodeJS 游戏服务器中使用 Pub/Sub 防止在用户修改和广播期间覆盖 Redis GameStatus

我正在尝试使用 NodeJS 和 Redis 创建游戏服务器。我在 Redis 中使用一个 GameStatus 来使用 Pub/Sub 向相应的客户端执行广播。 问题是我不能保证...

回答 0 投票 0

无法在dapr中使用python的grpc订阅一个主题。

我很难找到适用于python的gRPC pub -sub订阅模板 我正在尝试的是这样的,但似乎没有成功。 class DaprClientServicer(daprclient_services......)

回答 1 投票 0

如何在Google Cloud PubSub上实现请求-响应模式?

我有多个客户端A(主应用)和多个客户端B(支付服务)。如果我从客户端A发布一条消息,将在客户端B上处理和回复(在客户端A发布回复 ...

回答 1 投票 1

PubSub主题的ActiveMQ消费者群体

我对ActiveMQ很陌生,我想知道是否可以在下面的场景中进行设置。服务A和B订阅一个PubSub主题。这个主题我用来发送事件,所以...

回答 1 投票 0

创建股票报价的实时警报

我想创建一个实时股票警报应用程序,用户可以订阅特定的股票工具与目标价格。一旦目标价格达到,订阅的用户将被通知在应用程序。A ...

回答 1 投票 -1

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