publish-subscribe 相关问题

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

使用 Spring Reactive Redis pub/sub 时如何取消订阅(断开与频道的连接)?

我目前正在春季使用 Reactive Redis pub/sub,我想取消订阅 如果我在使用时遇到某些情况(例如套接字断开),您知道如何取消我的订阅吗

回答 1 投票 0

使用单一通道与数千个消费者时,Redis pub sub 性能影响和限制

在我们的 Spring boot 应用程序中,我们希望使用 Redis 发布-订阅将消息发布到正常情况下拥有大约 500 个侦听器的通道。 但在某些罕见的时间/日子里,听众可能会...

回答 1 投票 0

在 Redis ConnectionMultiplexer 上调用 UnsubscribeAll() 会影响其他 Redis 订阅

我有一个 Redis Connection Multiplexer 类,我将其注入到构造函数中的两个类中。 公开课 CLASS_1 { IConnectionMultiplexer _redis; 公共 CLASS_1(IConnectionMultip...

回答 1 投票 0

Redis/Valkey Pub/Sub 和 Streams 之间的主要区别是什么?

各自的优缺点是什么? 请建议何时使用其中一种而不是另一种。

回答 1 投票 0

确保 Node.js 应用程序中的顺序消息处理

我有一个 Node.js 应用程序,它充当连接器,促进 WhatsApp 和另一个应用程序之间的消息交换,我们称之为 CCM。它的工作原理如下: 连接器弄乱了...

回答 1 投票 0

回复Redis流中已消费的消息

我正在使用 Java 和 Redis。 我有服务 A 和服务 B。服务 A 生成消息,服务 B 消费这些消息并进行一些处理。我想回复同样的消息...

回答 1 投票 0

saga设计模式与微服务架构中的pub-sub模型有何不同?

在 saga 中,一个组件使用中间的主题调用另一个组件,同样的事情也发生在 pub shub 模型中。那么两者有何不同?

回答 1 投票 0

多次订阅同一个Redis频道时如何避免重复通知?

我遇到一个问题,如果我多次订阅同一个 Redis 频道,我的订阅者就会开始收到重复的消息。 这是我的订阅方法: 公共无效 SubscribeToUserNotific...

回答 1 投票 0

laravel api 中使用 redis 发布时收不到消息

我使用 laravel api 作为后端,vue 作为前端。这些是独立的项目。当我点击 redis 连接后发布的 api 时,例如 $redis = Redis::connection(); $重新...

回答 3 投票 0

创建哈希图以将引用存储为 Pub-Sub 的值

我需要创建一个哈希图,将对其他对象的引用存储为值,并将这些对象的名称作为键(HashMap)。 整个系统就像一个迷你车...

回答 1 投票 0

在事件驱动架构(websockets、pub sub 等)中,客户端和服务器是否不断检查新消息?它是如何运作的?

我读过很多文章,描述了 websockets 和 pub sub 架构如何在高层次上工作。 我知道使用 websockets 可以在客户端和服务器之间保持连接以发送...

回答 1 投票 0

ZeroMQ PUB/SUB 内部行为是什么?

我正在尝试了解 zmq 与 PUB/SUB 的行为。 Q1:我找不到使用 PUSH/PULL 套接字组合可以创建一个实际在内存消息中排队的队列的真正原因

回答 1 投票 0

中介者模式与发布/订阅

有人能指出两者之间的主要区别吗? 看来,至少在概念上,两者是非常密切相关的。如果我大胆猜测,我会说发布/订阅...

回答 6 投票 0

我可以让我的 SwiftUI 视图了解导致 @Binding 属性更新的情况吗?

总结 我正在使用 SwiftUI 将视图上的属性与可观察对象同步,但我丢失了有关从可观察对象发送到...的更新来源的关键详细信息

回答 1 投票 0

如何在 MassTransit 中配置多个消息使用者?

我正在考虑使用 MassTransit 将事件从一个进程发布到所有其他关心该事件的进程。在我的环境中,订阅该事件的多个进程可能是

回答 1 投票 0

Google Pub/Sub 上未收到嵌套字段

自从我学习 Google Pub/Sub 库以来,我已经设置了 Pub/Sub 的本地实例并创建了 2 个应用程序:1 个用于发送消息,另一个用于接收消息。到目前为止一切顺利,我已经成功设置了

回答 1 投票 0

用于发布和订阅自定义主题的 Azure 服务与 AWS IoT 中提供的相同

我正在开发一个软件,我需要向各种客户端发送 JSON 有效负载。这里的客户端是一台Windows PC,我的软件正在其中运行。在某些事件中,我需要触发一些动作...

回答 3 投票 0

Mosquitto MQTT 客户端在连接调用后在loop_start函数调用中返回错误10

我正在编写一个 MQTT 客户端,它只需连接到代理并发布或订阅主题。 在程序中,我尝试连接到 Broker,然后调用 Loop_forever() 函数,然后...

回答 1 投票 0

ZeroMQ可以订阅,但如何排除特定过滤器?

在ZeroMQ中我们可以通过一些过滤器订阅一个主题 socket.setsockopt(zmq.SUBSCRIBE, "/someRoot/") 有没有办法排除发送特定过滤器? 例如,我们如何排除...

回答 2 投票 0

Redis PubSub 中多个频道发布的内容很少,或者频道很少但发布的内容很多?

我在应用程序中使用 Redis PubSub 作为通知系统。我通常有大约 1000 个并发用户。对于每个用户,我都有一个包含用户 ID 的个人频道,通过该频道,多个人...

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.