Ignite clustergroup.forAttribute适用于客户端节点？

Question

<property name="userAttributes">
    <map>
        <entry key="Role" value="FOR_COMPUTE" />
    </map>
</property>

然后我使用：

ignite.cluster().forClients().forAttribute("Role", "FOR_COMPUTE");

这似乎无法为那些设置了该属性的客户机提供一个clusergroup。这对客户端节点不起作用吗？

Answer 1

用户属性确实起作用。再次检查你的设置。确保使用正确的配置启动客户端。

运行以下测试：

        IgniteConfiguration serverConfig = new IgniteConfiguration();
        serverConfig.setIgniteInstanceName("server");
        Ignition.start(serverConfig);


        IgniteConfiguration clientConfig = new IgniteConfiguration();
        clientConfig.setClientMode(true);
        clientConfig.setIgniteInstanceName("client");

        Map<String, String> userAttributes = new HashMap<>();
        userAttributes.put("Role", "FOR_COMPUTE");
        clientConfig.setUserAttributes(userAttributes);


        Ignite ignite = Ignition.start(clientConfig);
        System.out.println("Role user attribute value: " + ignite.cluster().localNode().attribute("Role"));
        ClusterGroup filteredNodes = ignite.cluster().forClients().forAttribute("Role", "FOR_COMPUTE");
        for (ClusterNode node:  filteredNodes.nodes()) {
            System.out.println("filtered id: "+ node.id());
        }

你应该看到正确的结果。