16得票2回答
在事件驱动架构中处理多个事件依赖

如果您拥有一个事件驱动的架构,并且订阅事件的服务在继续创建链中的下一个事件之前必须等待多个相同类型的事件,那么什么是最佳实践? 例如,一个书订单处理服务必须等待仓库处理完订单中的每本书,然后创建订单已被拣选的事件,以便发货服务(或类似服务)接收订单并开始准备发货。

30得票7回答
基于事件驱动架构的jQuery插件?

是否有任何事件驱动架构的jQuery插件? 步骤1:订阅 订阅者订阅位于中间的事件处理程序,并传递回调方法以及他们要监听的事件名称...... 例如,这两个绿色的订阅者将会监听p0事件。而蓝色的订阅者将会监听p1事件。 步骤2:p0事件由另一个组件触发到事件处理程序 p0事件被触发到事...

7得票1回答
当主服务器恢复时,Haproxy会关闭与备份服务器的连接。

问题 如果主机在宕机后恢复正常,我能否让haproxy关闭所有与备用主机的连接? 背景 我正在使用HAproxy进行发布/订阅的故障转移。 haproxy后端配置大致如下: listen pubsub 0.0.0.0:1234 mode tcp server pri...

7得票1回答
令人惊讶的是,向MongoDB的固定集合中插入数据速度缓慢。

我正在使用mongodb的固定集合+capped游标作为发布订阅引擎,使用pymongo实现。(这种方法在这里中有描述)。我的环境包括多个主题、多个发布者和几十个订阅者。 这很好用,但是偶尔会遇到需要异常长的时间才能完成插入操作的情况。 我的理解是mongodb可以支持每秒>10K文...

10得票2回答
如何设置最简化的CKSubscription?

我想设置一个简单的CKSubscription,以通知我创建了一个recordType,怎么做?

21得票2回答
Redis的发布订阅功能是否会保存频道中的历史消息?

我在文档中没有找到有关频道消息在Redis发布/订阅中如何存储的信息。 当您发布到Redis频道时,该消息是否存储或持久化? 如果是这样,它会被存储多长时间,并且如何获取历史消息? 否则,我认为它只是广播该消息,然后在广播后删除/丢弃该消息?

15得票5回答
Redis发布/订阅:查看当前订阅的频道

我目前有一个Redis pub/sub应用程序,我想知道订阅了哪些频道。当客户端连接到我们的服务器时,我们会将他们注册到一个看起来像这样的频道: user:user_id 之所以这样做是因为我想知道谁“在线”。目前,我不知道客户端是否在线就盲目地向频道发送消息,因为他们接收这些类型的消息并...

7得票1回答
供应方式的差异:活动式与点动式

在Raku文档中关于Supply方法的act(与tap相比)https://docs.raku.org/type/Supply#method_act,它声明了: 保证给定的代码仅由一个线程执行。 我的理解是,在另一个线程运行该特定代码对象之前,一个线程必须完成该代码对象。 如果是这种...

7得票2回答
在 Django 项目中订阅 Redis 频道

我有多个使用nodejs或python/django编写的应用程序,这些服务运行良好。但需要彼此进行发布/订阅异步通信。 在nodejs中没有问题,可以轻松地向任何redis频道发布/订阅。 问题: 我的问题是如何持续订阅一个redis频道并接收其他服务发布的数据? 注意: 许多链接建议...

18得票4回答
zeromq发布订阅模式中消息丢失问题

我正在尝试使用 zeromq 框架实现发布-订阅设计模式。我的想法是首先启动一个订阅者,然后再启动一个发布者。订阅者将监听100个消息,而发布者将发布100个消息。到目前为止一切都很好... 然而,实际发生的情况是,即使在启动发布者之前订阅者已经启动并运行,订阅者也无法接收到所有的消息(只有...