IgniteConfiguration cfg = new IgniteConfiguration(); // 设置CPU数目 cfg.setPublicThreadPoolSize(6); // 设置内存大小 DataStorageConfiguration dsCfg = new DataStorageConfiguration(); dsCfg.getDefaultDataRegionConfiguration().setMaxSize(1024L * 1024 * 1024); cfg.setDataStorageConfiguration(dsCfg);
TcpDiscoverySpi discoSpi = new TcpDiscoverySpi(); // 配置节点数量 discoSpi.setIpFinder(new TcpDiscoveryMulticastIpFinder().setAddresses(Arrays.asList("localhost"))); discoSpi.setJoinTimeout(5000); discoSpi.setMaxMissedHeartbeats(5); // 分配资源 TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder(); ipFinder.setAddresses(Arrays.asList("127.0.0.1..10")); discoSpi.setIpFinder(ipFinder); // 启用DiscoverySpi cfg.setDiscoverySpi(discoSpi);