跨微服务的CompletableFuture)

Question

第1步：我想有一个CompletableFuture

步骤2：然后通过手动调用asyncFuture手动完成相同的future对象。从不同的微服务B完成（T值），该微服务B将由某个异步事件触发。

显然，微服务 A 和微服务 B 具有不同的 JVM。实际上，微服务 A 和微服务 B 是在 kubernetes 中不同 Pod 上运行的同一微服务的不同实例。

在步骤1和步骤2之间，未来的对象将存储在Redis中，微服务B可以安全地检索。

经过一些快速谷歌搜索，我想我会尝试以下几个解决方案：

1个

static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor)

编号： http://docs.hazelcast.org/docs/2.3/manual/html/ch09.html

2

编号： https://apacheignite.readme.io/v1.2/docs/executor-service

不确定这两种方法是否可行？还有，我想知道以前有没有人处理过类似的事情？如果是这样，如果您能与我分享您的解决方案，我将不胜感激。




Answer 1

关于Apache Ignite，有很多关于如何合作节点（微服务）的选项。其中之一是连续查询[1]，它允许侦听缓存上发生的数据修改。

例如，在服务A上，您可以创建ContinuousQuery并等待缓存中的值更改：

private String waitForValueChanged(IgniteCache<Integer, String> cache, Integer key) throws InterruptedException {
    ContinuousQuery<Integer, String> qry = new ContinuousQuery<>();

    qry.setInitialQuery(new ScanQuery<>((k, v) -> k == key));

    final CountDownLatch waitForValueChanged = new CountDownLatch(1);
    final AtomicReference<String> result = new AtomicReference<>();

    CacheEntryUpdatedListener<Integer, String> listener = new CacheEntryUpdatedListener<Integer, String>() {
        @Override public void onUpdated(Iterable<CacheEntryEvent<? extends Integer, ? extends String>> iterable) throws CacheEntryListenerException {
            for (CacheEntryEvent<? extends Integer, ? extends String> entry: iterable) {
                result.set(entry.getValue());
            }

            waitForValueChanged.countDown();
        }
    };

    qry.setLocalListener(listener);

    try (QueryCursor<Cache.Entry<Integer, String>> cur = cache.query(qry);) {
        waitForValueChanged.await(60000, TimeUnit.MILLISECONDS);
    }

    return result.get();
}

在服务B上，您只需要将值放入缓存中以“完成未来”:

private void completeFuture(IgniteCache<Integer, String> cache, Integer key, String value) {
    cache.put(key, value);
}

这是一个示例项目，展示了连续查询的工作原理[2]。

[1] https://apacheignite.readme.io/docs#section-连续查询

[2] https://github.com/gromtech/ignite-continuous-query-example