发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。
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)。 整个系统就像一个迷你车...
在事件驱动架构(websockets、pub sub 等)中,客户端和服务器是否不断检查新消息?它是如何运作的?
我读过很多文章,描述了 websockets 和 pub sub 架构如何在高层次上工作。 我知道使用 websockets 可以在客户端和服务器之间保持连接以发送...
我正在尝试了解 zmq 与 PUB/SUB 的行为。 Q1:我找不到使用 PUSH/PULL 套接字组合可以创建一个实际在内存消息中排队的队列的真正原因
有人能指出两者之间的主要区别吗? 看来,至少在概念上,两者是非常密切相关的。如果我大胆猜测,我会说发布/订阅...
我可以让我的 SwiftUI 视图了解导致 @Binding 属性更新的情况吗?
总结 我正在使用 SwiftUI 将视图上的属性与可观察对象同步,但我丢失了有关从可观察对象发送到...的更新来源的关键详细信息
我正在考虑使用 MassTransit 将事件从一个进程发布到所有其他关心该事件的进程。在我的环境中,订阅该事件的多个进程可能是
自从我学习 Google Pub/Sub 库以来,我已经设置了 Pub/Sub 的本地实例并创建了 2 个应用程序:1 个用于发送消息,另一个用于接收消息。到目前为止一切顺利,我已经成功设置了