单个JVM中的多个Spark服务器

Question

有没有办法在同一个JVM中运行多个Sparkjava服务器实例？我在"插件"软件中使用它,并根据外部环境启动我的插件的多个实例,然后导致

java.lang.IllegalStateException: This must be done before route mapping has begun
at spark.SparkBase.throwBeforeRouteMappingException(SparkBase.java:256)
at spark.SparkBase.port(SparkBase.java:101)
at com.foo.bar.a(SourceFile:59)

在我看来,通过查看它是围绕代码中的静态字段构建的代码,所以我正在考虑类加载器技巧或以SparkServerFactory某种方式消除SparkBase.

Answer 1

从Spark 2.5您可以使用ignite():

http://sparkjava.com/news.html#spark25released

例:

public static void main(String[] args) {
    igniteFirstSpark();
    igniteSecondSpark();
}

static void igniteSecondSpark() {
    Service http = ignite();

    http.get("/basicHello", (q, a) -> "Hello from port 4567!");
}

static void igniteFirstSpark() {
    Service http = ignite()
                      .port(8080)
                      .threadPool(20);

    http.get("/configuredHello", (q, a) -> "Hello from port 8080!");
}

我个人初始化它们是这样的:

import spark.Service

public static void main(String[] args) {
    Service service1 = Service.ignite().port(8080).threadPool(20)
    Service service2 = Service.ignite().port(8081).threadPool(10)
}

我建议阅读有关如何在主方法之外使用这些服务的内容,我认为这在这里很有用.