publish-subscribe 相关问题

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

akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?

我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka

回答 1 投票 0

为什么 nacked 消息没有出现在我的死信主题中?

所以,场景很简单:我想配置谷歌的pubsub模拟器有一个死信队列主题,如果消息导致处理程序中出现异常,则应该转发该消息...

回答 1 投票 0

基于上海证券交易所的 Pub/Sub 经纪商

我想要一个基于 Http 的发布/订阅服务器,将消息发布到带有 HTTP POST 请求的通道,并通过 EventSource (SSE) 订阅。除此之外,我想添加通配符

回答 2 投票 0

为什么我订阅某个频道没有错误后,redis 却报告没有订阅者?

我正在尝试通过 websockets 发送实时反馈,并且我通过 redis 从 Rest-api 服务器发送数据到 websocker 服务器(均用 python/django 编写)来实现这一点。在 websocket 中...

回答 1 投票 0

使用 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

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