Quarkus - 按需启动 Web 服务器

Question

有一个用 Quarkus 编写的 CLI 应用程序，其工作原理如下：

$ quarkus-app --input Hello
Output: olleH

现在还应该可以通过 REST 调用它。但是，只有在传递了参数“--server”时，才应启动此服务器：

$ quarkus-app --server &
Listening on '127.0.0.1:7070'
$ curl http://127.0.0.1:7070/api/reverse?input=Hello
Output: olleH

现在如何让 WebServer 仅在“--server”上启动？

我的代码目前如下所示：

@QuarkusMain
class CommandLine : QuarkusApplication {

    override fun run(vararg args: String?): Int {
        val options: Options = Options()
        options.addOption("i", "input", false, "Input to reverse")
        options.addOption("s", "server", false, "Start server")

        val parser: CommandLineParser = DefaultParser()
        val cmd: CommandLine = parser.parse(options, args)
        if (cmd.hasOption("server")) {
          // TODO: Start server
        } else if (cmd.hasOption("input")) {
          println("Output: ${cmd.getOptionValue("input").toString().reversed()}")
        }
        return 0
    }
}

Answer 1

这可以通过定义 QuarkusMain 并稍后调用 Quarkus.run() 来实现。

import io.quarkus.runtime.Quarkus
import io.quarkus.runtime.annotations.QuarkusMain

@QuarkusMain
object Main {

    @JvmStatic
    fun main(args: Array<String>) {
        if (args.isNotEmpty() && args[0] == "--serve") {
            // Start HTTP server
            Quarkus.run(*args)
        } else if (args.size >= 2 && args[0] == "--input") {
            // Run CLI logic without starting HTTP server
            runCliLogic(args[1])
        } else {
            println("Usage: application [--serve | --input]")
        }
    }

    private fun runCliLogic(content: String) {
        // Implement your CLI logic here
        println(content.reversed())
    }
}

此外，当然必须安装 io.quarkus:quarkus-resteasy 并定义资源：

import javax.ws.rs.GET
import javax.ws.rs.Path
import javax.ws.rs.QueryParam
import javax.ws.rs.core.MediaType
import javax.ws.rs.core.Response

@Path("api/reverse")
class ReverseResource {

    @GET
    fun reverseInput(@QueryParam("input") input: String?): Response {
        if (input.isNullOrEmpty()) {
            return Response.status(Response.Status.BAD_REQUEST)
                .entity("Input parameter is required")
                .type(MediaType.TEXT_PLAIN_TYPE)
                .build()
        }

        val reversedInput = input.reversed()
        return Response.ok(reversedInput).build()
    }
}