Various experimental proposals and extensions to Javalin 4.x used in Reposilite 3.x

Related tags

Kotlin kotlin kotlin-coroutines javalin javalin-openapi reposilite

Overview

Javalin RFCs

Various experimental extensions to Javalin 4.x used in Reposilite 3.x. Provides basic support for Kotlin coroutines and async routes with a set of useful utilities.

repositories {
    maven { url 'https://repo.panda-lang.org/releases' }
}

dependencies {
    val version = "1.0.8"
    implementation "com.reposilite.javalin-rfcs:javalin-context:$version"
    implementation "com.reposilite.javalin-rfcs:javalin-reactive-routing:$version"
}

Project also includes panda-lang :: expressible library as a dependency. It's mainly used to provide Result<VALUE, ERROR> type and associated utilities.

Reactive Routing

Experimental router plugin that supports generic route registration with custom context and multiple routes within the same endpoints.

// Custom context
class AppContext(val context: Context)

// Some dependencies
class ExampleFacade

// Endpoint (domain router)
class ExampleEndpoint(private val exampleFacade: ExampleFacade) : AbstractRoutes<AppContext, Unit>() {

    private val sync = route("/sync", GET, async = false) { blockingDelay("Sync") }

    private val blockingAsync = route("/async-blocking", GET) { blockingDelay("Blocking Async") }

    private val nonBlockingAsync = route("/async", GET) { nonBlockingDelay("Non-blocking Async") }

    override val routes = setOf(sync, blockingAsync, nonBlockingAsync)

}

private suspend fun nonBlockingDelay(message: String): String = delay(100L).let { message }
@Suppress("BlockingMethodInNonBlockingContext")
private suspend fun blockingDelay(message: String): String =  sleep(100L).let { message }

fun main() {
    val exampleFacade = ExampleFacade()
    val exampleEndpoint = ExampleEndpoint(exampleFacade)

    val sharedThreadPool = QueuedThreadPool(4)
    val dispatcher = DispatcherWithShutdown(sharedThreadPool.asCoroutineDispatcher())
    sharedThreadPool.start()

    Javalin
        .create { config ->
            config.server { Server(sharedThreadPool) }

            ReactiveRoutingPlugin<AppContext, Unit>(
                errorConsumer = { name, throwable -> println("$name: ${throwable.message}") },
                dispatcher = dispatcher,
                syncHandler = { ctx, route -> route.handler(AppContext(ctx)) },
                asyncHandler = { ctx, route, _ -> route.handler(AppContext(ctx)) }
            )
            .registerRoutes(exampleEndpoint)
            .let { config.registerPlugin(it) }
        }
        .events {
            it.serverStopping { dispatcher.prepareShutdown() }
            it.serverStopped { dispatcher.completeShutdown() }
        }
        .start("127.0.0.1", 8080)
}

~ source: RoutingExample.kt

Context

Provides utility methods in io.javalin.http.Context class:

Context.error(ErrorResponse)
Context.contentLength(Long)
Context.encoding(Charset)
Context.encoding(String)
Context.contentDisposition(String)
Context.resultAttachment(Name, ContentType, ContentLength, InputStream)

Provides generic ErrorResponse that supports removal of exception based error handling within app:

ErrorResponse(Int httpCode, String message)
ErrorResponse(HttpCode httpCode, String message)
/* Methods */
errorResponse(HttpCode httpCode, String message) -> Result<*, ErrorResponse>
// [...]

OpenAPI

Reimplemented OpenAPI module:

https://github.com/reposilite-playground/javalin-openapi

To enable annotation processor, Swagger or ReDoc you have to add extra dependencies from repository listed above.

Used by

Reposilite

Kotlin MPP bindings for various clis

kommander Kotlin MPP bindings for various cli tools. The libraries only wrap around the clis and still require them to be natively available on the PA

3 Mar 18, 2022

This is a Kotlin multiplatform template project used to generate and deploy a natively compiled AWS lambda function using the custom runtime.

Overview This is a Kotlin multiplatform template project used to generate and deploy a natively compiled AWS Lambda function using a custom runtime. U

5 Jun 25, 2022

Comments

Coroutines FastHttpLoader - 11.08.2021

Spec

val sharedThreadPool = QueuedThreadPool(4)

class ExampleEndpoint(private val exampleFacade: ExampleFacade) : AbstractRoutes<AppContext>() {

    private val sync = route("/sync", GET, async = false) { context.result(blockingDelay("Sync")) }

    private val blockingAsync = route("/asyncBlocking", GET) { blockingDelay("Blocking Async") }

    private val nonBlockingAsync = route("/async", GET) { nonBlockingDelay("Non-blocking Async") }

    override val routes = setOf(sync, blockingAsync, nonBlockingAsync)

}

private suspend fun nonBlockingDelay(message: String): String =
    delay(100L).let { message }

@Suppress("BlockingMethodInNonBlockingContext")
private suspend fun blockingDelay(message: String): String =
    sleep(100L).let { message }

Results

Requests done per route in Burst Throughput (10s), Adjustment test (30s) and Loading test (30s):

/sync           - 192 / 491  / 335
/asyncBlocking  - 96  / 251  / 172
/async          - 785 / 7203 / 10499

Details

Tool: https://github.com/hagen1778/fasthttploader

Sync

------ Burst Throughput ------
Elapsed time: 10.094717s
Req done: 192; Success: 100.00 %
QPS: 19.019849; Connections: 8
Errors: 0; Timeouts: 0

------ Adjustment test ------
Elapsed time: 30.001615s
Req done: 491; Success: 100.00 %
QPS: 16.365786; Connections: 102
Errors: 0; Timeouts: 0

------ Loading test ------
Elapsed time: 30.002567s
Req done: 335; Success: 100.00 %
QPS: 11.165711; Connections: 107
Errors: 188; Timeouts: 188

Async (blocking)

------ Burst Throughput ------
Elapsed time: 10.050572s
Req done: 96; Success: 100.00 %
QPS: 9.551695; Connections: 8
Errors: 0; Timeouts: 0

------ Adjustment test ------
Elapsed time: 30.003456s
Req done: 251; Success: 100.00 %
QPS: 8.365703; Connections: 86
Errors: 0; Timeouts: 0

------ Loading test ------
Elapsed time: 30.002243s
Req done: 172; Success: 100.00 %
QPS: 5.732905; Connections: 172
Errors: 146; Timeouts: 146

Async (non-blocking)

------ Burst Throughput ------
Elapsed time: 10.050354s
Req done: 785; Success: 100.00 %
QPS: 78.106699; Connections: 8
Errors: 0; Timeouts: 0

------ Adjustment test ------
Elapsed time: 30.001574s
Req done: 7203; Success: 100.00 %
QPS: 240.087406; Connections: 30
Errors: 0; Timeouts: 0

------ Loading test ------
Elapsed time: 30.004469s
Req done: 10499; Success: 100.00 %
QPS: 349.914540; Connections: 29
Errors: 0; Timeouts: 0

documentation

opened by dzikoysk 0