在 Apache Ignite 上部署服务

Question

我有一个在 Ignite 上部署服务的 util 方法：

private static void startNewService(String queryId, String sqlQuery, long timeInterval) {
    QueryServiceImpl cepService = new QueryServiceImpl(queryId, sqlQuery, timeInterval);

    ServiceConfiguration cfg = new ServiceConfiguration();
    cfg.setService(cepService);
    cfg.setName(queryId);
    cfg.setTotalCount(1);
    cfg.setMaxPerNodeCount(1);

    System.out.println("---- Deploying the service. "+queryId);
    services.deploy(cfg);
    System.out.println("---- Deployed the service. "+queryId);
}

当我从客户端机器运行执行此操作时，服务器机器出现以下错误：

[12:13:26,640][SEVERE][srvc-deploy-#35%myGrid%][GridServiceProcessor] Failed to initialize service (service will not be deployed): Query1
class org.apache.ignite.IgniteCheckedException: com.demo.ignite.service.QueryServiceImpl
    at org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9739)
    at org.apache.ignite.internal.processors.service.GridServiceProcessor.copyAndInject(GridServiceProcessor.java:1206)
    at org.apache.ignite.internal.processors.service.GridServiceProcessor.redeploy(GridServiceProcessor.java:1127)
    at org.apache.ignite.internal.processors.service.GridServiceProcessor.processAssignment(GridServiceProcessor.java:1750)
   ......
 Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: com.demo.ignite.service.QueryServiceImpl
    at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:695)
    at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1755)
    ....
 Caused by: java.lang.ClassNotFoundException: com.demo.ignite.service.QueryServiceImpl
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    .... 
    at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8465)
    at org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:347)
    at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:686)

我的 QueryServiceImpl 实现了 Service, QueryService，其中 QueryService 是一个带有方法运行ContinuousQuery() 的接口。

请注意，我没有手动将此 jar/class 复制到服务器类路径。我希望 ignite 将所需的类加载到 Ignite 服务器节点并运行那里的服务。我该怎么做？

Answer 1

目前服务不支持对等部署，因此您的服务应该在每个节点的类路径上。您可以在文档中找到关于它的注释：https://apacheignite.readme.io/docs/service-grid

在 Apache Ignite 上部署服务

Deploying a service on Apache Ignite

ignite