如何获取Apache ignite缓存的数据

Question

我是阿帕奇点燃新来的。我正在尝试填充缓存并从缓存读取。我创建了两个java项目，一个填充Apache ignite缓存，另一个打印缓存数据，但是打印缓存项目会出错。

public void run(String... arg0) throws Exception
{
    try (Ignite ignite = Ignition.start("ignite.xml"))
    {
        int iteration=0;

        while(true)
        {
            iteration++;
            IgniteCache<Object, Object> cache = ignite.getOrCreateCache("test cache " + iteration);
            System.out.println(""+100);
            System.out.println("Caching started for iteration " + iteration);
            printMemory();

            for (int i = 0; i < 100; i++)
            {
                cache.put(i, new CacheObject(i, "Cached integer " + i));
                System.out.println(i);
                Thread.sleep(100);

            }
            //cache.destroy();
            System.out.println("**************************************"+cache.size());
        }

    }


}

Ignition.setClientMode(true);
    IgniteConfiguration cfg = new IgniteConfiguration();        
    cfg.setPeerClassLoadingEnabled(true);
    TcpDiscoveryMulticastIpFinder discoveryMulticastIpFinder = new TcpDiscoveryMulticastIpFinder();
    Set<String> set = new HashSet<>();

    set.add("serverhost:47500..47509");
    discoveryMulticastIpFinder.setAddresses(set);

    TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi();
    discoverySpi.setIpFinder(discoveryMulticastIpFinder);

    cfg.setDiscoverySpi(discoverySpi);

    cfg.setPeerClassLoadingEnabled(true);
    cfg.setIncludeEventTypes(EVTS_CACHE);
    Ignite ignite = Ignition.start(cfg);

    System.out.println("***************************************************\n"+ignite.cacheNames()+"\n****************************");
    CacheConfiguration<String, BinaryObject> cacheConfiguration = new CacheConfiguration<>(CACHE_NAME);
    IgniteCache<String, BinaryObject> cache = ignite.getOrCreateCache(cacheConfiguration).withKeepBinary();

Answer 1

原因：class org.apache.ignite.spi.ignitespiException：本地节点的封送器与远程节点的封送器不同（要确保拓扑中的所有节点具有相同的封送器，请在配置中显式配置封送器）[locmarshaller=org.apache.ignite.internal.binary.binarymarshaller,rmtmarshaller=org.apache.ignite.marshaller.optimized.optimizedmarshaller

在ignite.xml中，您显式设置了marshaller。请检查xml配置文件中的 。您应该为集群中的所有节点配置相同的封送器，否则它们将无法通信。