小编Ján*_*res的帖子

Hazelcast 分布式执行器服务 KeyOwner

我无法理解 Hazelcast 分布式执行的概念。据说能够对特定密钥的所有者实例执行执行。
来自文档:

   <T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
   Submits task to owner of the specified key and returns a Future representing that task.
       Parameters:
            task - task
            key - key
       Returns:
            a Future representing pending completion of the task
Run Code Online (Sandbox Code Playgroud)

我相信我并不是唯一拥有一个由多个映射构建的集群的人,这些映射实际上可能使用相同的密钥用于不同的目的,持有不同的对象(例如,以下设置中的某些内容):

IMap<String, ObjectTypeA> firstMap = HazelcastInstance.getMap("firstMap");
IMap<String, ObjectTypeA_AppendixClass> secondMap = HazelcastInstance.getMap("secondMap");
Run Code Online (Sandbox Code Playgroud)

对我来说,文档中关于密钥所有者的描述似乎很令人困惑。我真正的沮丧是我不知道它指的是哪个 - 在哪个地图 - 键?
该文档还给出了这种方法的“演示”:

import com.hazelcast.core.Member;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.IExecutorService;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;   
import java.util.Set;
import com.hazelcast.config.Config;

public void echoOnTheMemberOwningTheKey(String input, Object key) throws Exception …
Run Code Online (Sandbox Code Playgroud)

java key owner execution hazelcast

4
推荐指数
1
解决办法
4023
查看次数

标签 统计

execution ×1

hazelcast ×1

java ×1

key ×1

owner ×1