Ignite 中类似 JavaSpaces 的模式

JavaSpaces-like patterns in Ignite

我过去使用过 GigaSpaces,我想知道我是否可以以类似的方式使用 Ignite。具体来说,我需要实施主从模式,其中一组进程将对象写入内存数据网格,另一组进程读取这些对象,进行一些处理,并可能将结果写回网格。我需要的一项重要 GigaSpaces/JavaSpaces 功能是租赁。如果我向 space 写入一个对象,但在特定时间段内未被拾取,它应该会自动过期,我应该会收到某种通知。

Apache Ignite 是否适合此用例?

我以前曾在 GigaSpaces 工作过。您正在寻找的可能是 Ignite 中的 "continuous queries"。这将允许为特定谓词创建过滤器,即检查正在写入网格的新对象的字段。评估过滤器后,它将触发一个侦听器,该侦听器可以执行您需要的逻辑并将结果或更改写回网格。您可以根据需要创建任意数量的此类查询并创建链。类似于 gigaspaces 中的 "notification container"。正如您所期望的那样,您可以为此单独控制线程池。

至于master worker模式,你可以配置客户端Ignite节点写入数据,服务器节点存储和处理数据。您甚至可以使用其他客户端节点作为您提到的数据更改的远程侦听器。

我以前曾在 GigaSpaces 工作过。您正在寻找的可能是 Ignite 中的 "continuous queries"。这将允许为特定谓词创建过滤器,即检查正在写入网格的新对象的字段。评估过滤器后,它将触发一个侦听器,该侦听器可以执行您需要的逻辑并将结果或更改写回网格。您可以根据需要创建任意数量的此类查询并创建链。类似于 gigaspaces 中的 "notification container"。正如您所期望的那样,您可以单独控制线程池。

至于master worker模式,你可以配置客户端Ignite节点写入数据,服务器节点存储和处理数据。您甚至可以使用其他客户端节点作为您提到的数据更改的远程侦听器。

检查这些链接: https://apacheignite.readme.io/docs/continuous-queries https://apacheignite.readme.io/docs/clients-vs-servers