Несколько серверов Spark в одной JVM

Question

Есть ли способ запустить несколько экземпляров сервера Sparkjava в одной JVM? Я использую его в программном обеспечении "плагина" и, исходя из внешних обстоятельств, может быть запущено несколько экземпляров моего плагина, которые затем вызывают

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

Пример:

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)
}

Я рекомендую прочитать о том, как использовать эти сервисы вне вашего основного метода, что, я думаю, было бы очень полезно здесь.

Answer 2

Хитрость заключается в том, чтобы игнорировать внешнюю статическую оболочку вокруг Spark, реализованную в spark.Spark и напрямую работать с внутренним spark.webserver.SparkServer, В коде есть некоторые препятствия, требующие обхода, например spark.webserver.JettyHandler не является общедоступным, поэтому вы не можете создать его экземпляр из своего кода, но вы можете расширить его, поместив свой собственный класс в этот пакет, и сделать его общедоступным.

Таким образом, решение заключается в следующем:

SimpleRouteMatcher routeMatcher1 = new SimpleRouteMatcher();
routeMatcher1.parseValidateAddRoute("get '/foo'", "*/*", wrap("/foo", "*/*", (req, res) -> "Hello World 1"));

MatcherFilter matcherFilter1 = new MatcherFilter(routeMatcher1, false, false);
matcherFilter1.init(null);
PublicJettyHandler handler1 = new PublicJettyHandler(matcherFilter1);
SparkServer server1 = new SparkServer(handler1);

new Thread(() -> {
            server1.ignite("0.0.0.0", 4567, null, null, null, null, "/META-INF/resources/", null, new CountDownLatch(1),
                    -1, -1, -1);
        }).start();

И нужно продублировать метод wrap в вашей кодовой базе:

protected RouteImpl wrap(final String path, String acceptType, final Route route) {
        if (acceptType == null) {
            acceptType = "*/*";
        }
        RouteImpl impl = new RouteImpl(path, acceptType) {
            @Override
            public Object handle(Request request, Response response) throws Exception {
                return route.handle(request, response);
            }
        };
        return impl;
    }

Это кажется приемлемым решением, если в вашем приложении требуется несколько серверов Spark.

Answer 3

У меня проблема с запуском юнит-тестов в Spark, чтобы исправить pom.xml файл.

forkCount=1 reuseForks=false

        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-surefire-plugin</artifactId>
            <version>${surefire.version}</version>
            <dependencies>
                <dependency>
                    <groupId>org.junit.platform</groupId>
                    <artifactId>junit-platform-surefire-provider</artifactId>
                    <version>${junit.platform.version}</version>
                </dependency>
            </dependencies>
            <configuration>
                <forkCount>1</forkCount>
                <reuseForks>false</reuseForks>