1

通过阅读有关 Apache Ignite 的文档,我的印象是,我在 Eclipse 中使用的(例如)类会自动(我敢说,神奇地?)发送到 Ignite 服务器的分布式实例。

我有 3 台香草服务器,没有加载运行的自定义类 (./bin/ignite.sh) ,都在本地主机上。他们很好地对视​​。

我运行一个带有一个自定义类的 Eclipse 程序,我用它来加载到缓存中。简单 POJO、Serializable 等

当我尝试运行一段计算代码时,远程服务器抱怨该类不在类加载器中。

Caused by: java.lang.ClassNotFoundException: com.company.dms.ignite.batch.model.MessageCustAccount
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:348)
at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8213)
at org.apache.ignite.internal.MarshallerContextAdapter.getClass(MarshallerContextAdapter.java:185)
at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:607)
... 29 more

还有更多的魔法吗?

        ExecutorService exec = ignite.executorService(ignite.cluster().forRemotes());

         // Iterate through all words in the sentence and create jobs.
        quickCounter = 10;
         while(it.hasNext() && quickCounter-- > 0){// "Print words using runnable".split(" ")) {
           final String word = it.next();
           // Execute runnable on some node.
           String interna_cache_name = DMSIgniteHelpers.getInstance().getCurrentCacheLocation(ignite, MSG_CUST_ACCT_CACHE);

           exec.submit(new IgniteRunnable() {
             @Override public void run() {
                  String delimeter = "\u0001";
                   String[] lineTokens = word.split("\\"+delimeter);

                    String three_pk = null; 
                    if(lineTokens[2].toString() != null && lineTokens[4].toString() != null && lineTokens[3] != null) {
                            String sor_id = new Integer(lineTokens[2]).toString();
                            String cust_id = new Long(lineTokens[4]).toString();
                            String acct_id = lineTokens[3];
                             three_pk = sor_id + cust_id + acct_id;
                             System.out.println("Looking for ("+sor_id+") ("+cust_id+") ("+acct_id+") : " + three_pk + " ----- ");
                             System.out.println("Going to query cache: " + interna_cache_name);
                             IgniteCache<Integer, MessageCustAccount> msgCustAccountCache = ignite.cache(interna_cache_name);

                             MessageCustAccount a =  sqlQuery(msgCustAccountCache,three_pk);
                            System.out.println("*************=================\n\n"  +  a.toString() + "\n@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$@#$");

                    }
               System.out.println(">>> Printing '" + word + "' on this node from grid job.");
             }
           });
         }
4

1 回答 1

3

模型类不是对等部署的,但您可以withKeepBinary()在缓存和查询上使用标志BinaryObject。这样,您将避免在服务器端进行反序列化,并且不会得到ClassNotFoundException.

有关如何做到这一点,请参阅此示例:https ://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/binary/datagrid/CacheClientBinaryQueryExample.java

于 2016-04-22T21:06:32.063 回答