发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。
Apollo 服务器 PubSub 实现中的 TypeScript 泛型问题
我正在使用 TypeScript 和用于事件处理的 PubSub 类在 Apollo Server 中实现订阅。但是,我在尝试使用 PubSub 通用命名接口时遇到了问题...
Apollo 服务器订阅和 PubSub 中 asyncIterator 的 Typescript 问题
我正在使用 TypeScript 进行 Apollo Server 订阅,并在实现基于 PubSub 的订阅系统时遇到了一些问题。我遵循了 Apollo 官方文档,但运行了...
Apache Kafka 元数据获取需要 40 秒以上的时间来读取和获取为什么?
我有三个集群,每个集群有 7 个主题和 2 个代理。每个主题都配置有一个分区。每个集群有 1 个生产者和 2 个消费者,消费者连接到其他集群...
我已经在本地实现了带有事件中心的 Dapr PubSub。 我已将 Dapr 配置添加到这两个项目中。 从发布者 daprclient.PublishEventAsync 被调用,并使用
如何实现通用的发布-订阅模式,其中接收调用的订阅者的方法可以在发布者处注册?
更通用的发布-订阅模式 我一直在寻找一种更通用的发布-订阅模式。 据我所知,通常的发布-订阅模式具有虚拟功能...
nestjs-rabbitmq Node.js 包不处理消息
也许我在开始使用 Nestjs 时遗漏了一些基本的东西,但不知何故我无法使用 https://github.com/golevelup/nestjs 让 Nest.js 以 Pub/Sub 模式接收消息。我创建了
akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?
我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka
所以,场景很简单:我想配置谷歌的pubsub模拟器有一个死信队列主题,如果消息导致处理程序中出现异常,则应该转发该消息...
我想要一个基于 Http 的发布/订阅服务器,将消息发布到带有 HTTP POST 请求的通道,并通过 EventSource (SSE) 订阅。除此之外,我想添加通配符
为什么我订阅某个频道没有错误后,redis 却报告没有订阅者?
我正在尝试通过 websockets 发送实时反馈,并且我通过 redis 从 Rest-api 服务器发送数据到 websocker 服务器(均用 python/django 编写)来实现这一点。在 websocket 中...
使用 Spring Reactive Redis pub/sub 时如何取消订阅(断开与频道的连接)?
我目前正在春季使用 Reactive Redis pub/sub,我想取消订阅 如果我在使用时遇到某些情况(例如套接字断开),您知道如何取消我的订阅吗
使用单一通道与数千个消费者时,Redis pub sub 性能影响和限制
在我们的 Spring boot 应用程序中,我们希望使用 Redis 发布-订阅将消息发布到正常情况下拥有大约 500 个侦听器的通道。 但在某些罕见的时间/日子里,听众可能会...
在 Redis ConnectionMultiplexer 上调用 UnsubscribeAll() 会影响其他 Redis 订阅
我有一个 Redis Connection Multiplexer 类,我将其注入到构造函数中的两个类中。 公开课 CLASS_1 { IConnectionMultiplexer _redis; 公共 CLASS_1(IConnectionMultip...
Redis/Valkey Pub/Sub 和 Streams 之间的主要区别是什么?
各自的优缺点是什么? 请建议何时使用其中一种而不是另一种。
我有一个 Node.js 应用程序,它充当连接器,促进 WhatsApp 和另一个应用程序之间的消息交换,我们称之为 CCM。它的工作原理如下: 连接器弄乱了...
我正在使用 Java 和 Redis。 我有服务 A 和服务 B。服务 A 生成消息,服务 B 消费这些消息并进行一些处理。我想回复同样的消息...
saga设计模式与微服务架构中的pub-sub模型有何不同?
在 saga 中,一个组件使用中间的主题调用另一个组件,同样的事情也发生在 pub shub 模型中。那么两者有何不同?
我遇到一个问题,如果我多次订阅同一个 Redis 频道,我的订阅者就会开始收到重复的消息。 这是我的订阅方法: 公共无效 SubscribeToUserNotific...
laravel api 中使用 redis 发布时收不到消息
我使用 laravel api 作为后端,vue 作为前端。这些是独立的项目。当我点击 redis 连接后发布的 api 时,例如 $redis = Redis::connection(); $重新...
我需要创建一个哈希图,将对其他对象的引用存储为值,并将这些对象的名称作为键(HashMap)。 整个系统就像一个迷你车...