publish-subscribe 相关问题

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

发布到 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

为什么 react Apollo 在更新订阅时,会将已经更新的值返回为 prev?

我在一个反应项目中使用apollo,并在创建,更新和删除对象时使用订阅功能。我使用 subscribeToMore 功能来启动订阅。前值的...

回答 1 投票 1

如何将死信消息路由回原主题?

我有一个谷歌云PubSub订阅,正在使用一个死字主题。我最近发生了一次故障,阻止了一些消息的处理&他们最终在死字中。

回答 1 投票 0

zeromq.js - 等待连接。

connect方法的文档中说,连接到给定远程地址的socket并立即返回。连接将在后台异步进行。但是, await确实...

回答 1 投票 0

可以查询pubsub系统中已经消耗的旧消息吗?

我正在建立一个打牌的系统,我决定使用SSE的pubsub系统来保持客户端的更新。我面临的一个问题是把消息保留下来,以便以后查询。一个用例是...

回答 2 投票 0

需要帮助验证建议扑克游戏的设计。

我正在开发完全去中心化的扑克游戏。目前我的设计是使用pubsub,push-pull套接字使用nano套接字来建立通信。玩家推送数据...

回答 1 投票 0

javascript中的pubsub模式与websocket的比较

我经常把pubsub设计模式和websocket这样的协议搞混。当新的专业术语出现时,比如反应式编程,我变得更加困惑。对我来说,这就像WebSocket是一种pubsub, ...

回答 1 投票 0

在无状态的Node.js应用中调度函数调用。

我试图找出一种设计模式,用于在一个无状态的Node后端中调度多个实例同时运行的事件。用例举例。创建一个消息对象的发布...

回答 1 投票 0

RxJs - 创建一个Observable数组的正确模式是什么?

我是一个相当新的RxJs,并试图了解什么是正确的模式是简单地创建一个Observable数组。我想检索一个用户的帖子列表。帖子...

回答 1 投票 0

对传入的MQTT信息没有反应

我有一个简单的设置,一个wemos d1 mini,有一个按钮和一些LED灯,它可以发送和接收MQTT消息,并且应该对它们采取行动。它可以发送和接收MQTT消息,并且应该对它们采取行动。我想让它在按下按钮时发送 "11",并点亮LED灯。

回答 1 投票 -1

我创建了一个PubSub主题的云函数,如果函数失败,是否要重试一次从pubsub发送消息?

我有一个带有简单测试代码的函数,如: exports.helloPubSub = (event, context) => { const message = event.data ? Buffer.from(event.data, 'base64').toString() : '...

回答 1 投票 0

是否所有内置主题的数据字段都是按照DDSRTPS规范发送的?

我试图更好地理解RTPS和DDS规范。RTPS规范谈到了 "数据变化 "和它们如何被传播,但没有确切地指定 "什么 "被传播(...

回答 2 投票 1

如何让go-ipfs使用ws-star来做punsub?

当我在go-ipfs中使用wss时,它抛出不支持wss,所以我不能使用dns4ws-star.discovery.libp2p.iotcp443wssp2p-websocket-star我想让js-ipfs和go-ipfs可以加入同一个pubsub主题。

回答 1 投票 1

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