java - Ignite:仅使用核心来传递消息？

Question

我想制作一个仅使用 ignite-core-2.0.0 并执行 Ignite 消息传递的小型(est)应用程序。我想与之交换消息的某个集群。

我已将 IGNITE_HOME 设置为 ./apache-ignite-2.0.0-src，其中我已编译源代码。文件 IGNITE_HOME/config/default-config.xml 存在且未更改。

这是异常发生之前运行的代码

Ignition.setClientMode(true);
Ignite ignite = Ignition.start();
...

我懂了

Exception in thread "main" class org.apache.ignite.IgniteException:
    Failed to create Ignite component (consider adding ignite-spring
    module to classpath)...

Caused by: java.lang.ClassNotFoundException:
    org.apache.ignite.internal.util.spring.IgniteSpringHelperImp‌​l

我在 ignite-core JAR 中没有看到 IgniteSpringHelperImp‌​l 类，并且想知道为什么需要它。

如何仅使用 ignite-core JAR 来实现消息传递？

Answer 1

到目前为止，这看起来可行。

IgniteConfiguration cfg = new IgniteConfiguration();
TcpDiscoverySpi spi = new TcpDiscoverySpi();
cfg.setDiscoverySpi(spi);
TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
ipFinder.setAddresses(Arrays.asList("127.0.0.1"));
spi.setIpFinder(ipFinder);
Ignite ignite = Ignition.start(cfg);
IgniteMessaging igMsg = ignite.message(ignite.cluster().forLocal());
igMsg.localListen("unorderedTopic", (nodeId, msg) -> {
    System.out.println("msg: " + msg + ", from: " + nodeId);
    return true; // to continue listening
});
for (int i = 0; i < 10; i++)
    igMsg.send("unorderedTopic", Integer.toString(i));

在我的机器上发送和接收消息。