publish-subscribe 相关问题

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

为什么 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

这是一个基于消息总线的pub-sub模式吗?

根据这个答案,消息总线是一个消息基础设施,允许不同的系统通过一组共享的接口(消息总线)进行通信。下面是createHub()函数&...。

回答 1 投票 -1

节点 Redis XREAD 屏蔽订阅

我正在将redis pubsub系统转换为redis流,这样我就可以为我的服务器发送的事件添加一些容错功能。用传统的方式订阅很简单:从'...导入{ createClient }。

回答 1 投票 0

为什么spring集成中默认的 "errorChannel "是 "PublishSubscribeChannel"?

我发现 "默认的 "errorChannel "是一个PublishSubscribeChannel",但我不明白为什么。可以用直接通道代替吗?使用直接通道作为入站通道的缺点是什么?

回答 1 投票 0

gcloud pubsub发布消息问题

我正在尝试发布有关主题的消息,但是我无法发布该消息。我正在使用laravelframework。我的订阅是推送类型。我已经用过$ composer require google / cloud-pubsub ...

回答 2 投票 0

Pub-Sub模式和消息代理,如何确保所有订阅者完成对事件的处理

首先,我知道可以使用像NATS这样的优质(轻量级)消息代理。如果这是一项工作,我当然会采用行之有效的解决方案,这更多是关于好奇心和意志……

回答 1 投票 1

MongoDB ChangeStream功能是否可以替换发布/订阅技术

我正在经历MongoDB ChangeStream,我知道它减少了拖尾oplog的风险-我们目前正在拖尾oplog以将数据发布到Kafka。请帮助我掌握,以便如何...

回答 1 投票 1

WebSocket是否有标准的PubSub协议?

我正在寻找一种方法,以不同语言编写的应用程序之间实现基本的发布/订阅,以与JSON负载交换事件。 WebSocket似乎是...

回答 1 投票 1

Redis发布/订阅-发行人也是订户吗?

我是Redis的新手,我一直在和Pub / Sub玩弄。由于相关因素的影响,我希望发布者也成为频道的订阅者,这样,当发布者发送...

回答 1 投票 1

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