为什么在重新启动 Spark 服务器后出现 "connection refused" 错误？

Question

我有这个测试classes:

class PostIT {

    companion object {

        @BeforeClass
        @JvmStatic
        fun initialise() {
            baseURI = "http://localhost:4567"
            Server.start()
        }

        @AfterClass
        @JvmStatic
        fun tearDown() {
            Server.stop()
        }

    }

    //some test cases

}

class UserIT {

    companion object {

        @BeforeClass
        @JvmStatic
        fun initialise() {
            baseURI = "http://localhost:4567"
            Server.start()
        }

        @AfterClass
        @JvmStatic
        fun tearDown() {
            Server.stop()
        }

    }

    //some test cases

}

和Server对象：

object Server {

    fun start() {
        Spark.init()
        prepareRoutes()
    }

    fun stop() {
        Spark.stop()
    }

    private fun prepareRoutes() {
        get("/users", whatever)
        //more routes
    }        

}

当我运行都分别测试 class 时，它工作正常。但是，当我告诉 IDE 到运行两个测试 classes 时，我得到 connection refused error 当第二个测试 class 是运行.

好像服务器停止后就再也不会启动了。就像服务器停止后 Spark.init() 无法正常工作。

我也试过在 Spark.init() 之后调用 Spark.awaitInitialization()。

我错过了什么？

Answer 1

已解决！实际上，问题不在于停止后的服务器初始化。我们必须等到服务器停止。我找到了解决方案 .

fun stop() {
    try {
        Spark.stop()
        while (true) {
            try {
                Spark.port()
                Thread.sleep(500)
            } catch (ignored: IllegalStateException) {
                break
            }

        }
    } catch (ex: Exception) {
    }
}

为什么在重新启动 Spark 服务器后出现 "connection refused" 错误？

Why am I getting "connection refused" error after restart Spark server?

junit

kotlin

integration-testing

spark-java