feat(v7): fastjson2 for serialization of GraphQLResponse and deserialization of GraphQLRequest

gradle/libs.versions.toml

@@ -15,6 +15,7 @@ kotlinx-coroutines = "1.7.3"
 # TODO kotlin 1.9 upgrade -> kotlinx-serialization 1.6.0+ uses kotlin 1.9
 kotlinx-serialization = "1.5.1"
 ktor = "2.3.10"
+fastjson2 = "2.0.53"
 maven-plugin-annotation = "3.12.0"
 maven-plugin-api = "3.9.6"
 maven-project = "2.2.1"
@@ -88,6 +89,8 @@ spring-boot-config = { group = "org.springframework.boot", name = "spring-boot-c
 spring-boot-netty = { group = "org.springframework.boot", name = "spring-boot-starter-reactor-netty", version.ref = "spring-boot" }
 spring-boot-webflux = { group = "org.springframework.boot", name = "spring-boot-starter-webflux", version.ref = "spring-boot" }
 spring-webflux = { group = "org.springframework", name = "spring-webflux", version.ref = "spring" }
+fastjson2 = { group = "com.alibaba.fastjson2", name = "fastjson2-kotlin", version.ref = "fastjson2" }
+fastjson2-spring = { group = "com.alibaba.fastjson2", name = "fastjson2-extension-spring6", version.ref = "fastjson2" }
 
 # test dependencies
 compile-testing = { group = "dev.zacsweers.kctfork", name = "core", version.ref = "compile-testing" }

plugins/server/graphql-kotlin-graalvm-metadata-generator/src/main/resources/default-reflect-config.json

@@ -120,22 +120,6 @@
     "allDeclaredFields": true,
     "queryAllDeclaredMethods": true
   },
-  {
-    "name":"com.expediagroup.graphql.server.types.GraphQLRequest",
-    "fields":[{"name":"Companion"}]
-  },
-  {
-    "name":"com.expediagroup.graphql.server.types.GraphQLRequest$Companion",
-    "methods":[{"name":"serializer","parameterTypes":[] }]
-  },
-  {
-    "name":"com.expediagroup.graphql.server.types.GraphQLBatchRequest",
-    "fields":[{"name":"Companion"}]
-  },
-  {
-    "name":"com.expediagroup.graphql.server.types.GraphQLBatchRequest$Companion",
-    "methods":[{"name":"serializer","parameterTypes":[] }]
-  },
   {
     "name": "com.expediagroup.graphql.server.types.GraphQLServerRequestDeserializer",
     "methods": [

servers/graphql-kotlin-server/build.gradle.kts

@@ -5,15 +5,14 @@ description = "Common code for running a GraphQL server in any HTTP server frame
 plugins {
     id("com.expediagroup.graphql.conventions")
     alias(libs.plugins.benchmark)
-    alias(libs.plugins.kotlin.serialization)
 }
 
 dependencies {
     api(projects.graphqlKotlinSchemaGenerator)
     api(projects.graphqlKotlinDataloaderInstrumentation)
     api(projects.graphqlKotlinAutomaticPersistedQueries)
     api(libs.jackson)
-    api(libs.kotlinx.serialization.json)
+    api(libs.fastjson2)
     testImplementation(libs.kotlinx.coroutines.test)
     testImplementation(libs.logback)
 }
@@ -32,6 +31,14 @@ kotlin.sourceSets.getByName("benchmarks") {
 }
 
 benchmark {
+    configurations {
+        register("graphQLRequest") {
+            include("com.expediagroup.graphql.server.GraphQLServerRequest*")
+        }
+        register("graphQLResponse") {
+            include("com.expediagroup.graphql.server.GraphQLServerResponse*")
+        }
+    }
     targets {
         register("benchmarks") {
             this as JvmBenchmarkTarget

servers/graphql-kotlin-server/src/benchmarks/kotlin/GraphQLServerRequestBatchDeserializationBenchmark.kt

@@ -0,0 +1,64 @@
+/*
+ * Copyright 2024 Expedia, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.expediagroup.graphql.server
+
+import com.alibaba.fastjson2.JSON
+import com.alibaba.fastjson2.JSONWriter
+import com.alibaba.fastjson2.to
+import com.expediagroup.graphql.server.types.GraphQLServerRequest
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+import com.fasterxml.jackson.module.kotlin.readValue
+import org.openjdk.jmh.annotations.Benchmark
+import org.openjdk.jmh.annotations.Fork
+import org.openjdk.jmh.annotations.Measurement
+import org.openjdk.jmh.annotations.Scope
+import org.openjdk.jmh.annotations.Setup
+import org.openjdk.jmh.annotations.State
+import org.openjdk.jmh.annotations.Warmup
+import java.util.concurrent.TimeUnit
+
+@State(Scope.Benchmark)
+@Fork(value = 5, jvmArgsAppend = ["--add-modules=jdk.incubator.vector", "-Dfastjson2.readerVector=true"])
+@Warmup(iterations = 1, time = 1, timeUnit = TimeUnit.SECONDS)
+@Measurement(iterations = 4, time = 5, timeUnit = TimeUnit.SECONDS)
+open class GraphQLServerRequestBatchDeserializationBenchmark {
+    private val mapper = jacksonObjectMapper()
+    private lateinit var request: String
+    private lateinit var batchRequest: String
+
+    @Setup
+    fun setUp() {
+        JSON.config(JSONWriter.Feature.WriteNulls)
+        val loader = this::class.java.classLoader
+        val operation = loader.getResource("StarWarsDetails.graphql")!!.readText().replace("\n", "\\n")
+        val variables = loader.getResource("StarWarsDetailsVariables.json")!!.readText()
+        batchRequest = """
+            [
+                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
+                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
+                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
+                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables }
+            ]
+        """.trimIndent()
+    }
+
+    @Benchmark
+    fun JacksonDeserializeGraphQLBatchRequest(): GraphQLServerRequest = mapper.readValue(batchRequest)
+
+    @Benchmark
+    fun FastJsonDeserializeGraphQLBatchRequest(): GraphQLServerRequest = batchRequest.to<GraphQLServerRequest>()
+}

servers/graphql-kotlin-server/src/benchmarks/kotlin/GraphQLServerRequestDeserializationBenchmark.kt

@@ -16,10 +16,12 @@
 
 package com.expediagroup.graphql.server
 
-import com.expediagroup.graphql.server.testtypes.GraphQLServerRequest
+import com.alibaba.fastjson2.JSON
+import com.alibaba.fastjson2.JSONWriter
+import com.alibaba.fastjson2.to
+import com.expediagroup.graphql.server.types.GraphQLServerRequest
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
-import kotlinx.serialization.json.Json
 import org.openjdk.jmh.annotations.Benchmark
 import org.openjdk.jmh.annotations.Fork
 import org.openjdk.jmh.annotations.Measurement
@@ -30,16 +32,16 @@ import org.openjdk.jmh.annotations.Warmup
 import java.util.concurrent.TimeUnit
 
 @State(Scope.Benchmark)
-@Fork(5)
-@Warmup(iterations = 1, time = 5, timeUnit = TimeUnit.SECONDS)
-@Measurement(iterations = 5, time = 2, timeUnit = TimeUnit.SECONDS)
+@Fork(value = 5, jvmArgsAppend = ["--add-modules=jdk.incubator.vector", "-Dfastjson2.readerVector=true"])
+@Warmup(iterations = 1, time = 1, timeUnit = TimeUnit.SECONDS)
+@Measurement(iterations = 4, time = 5, timeUnit = TimeUnit.SECONDS)
 open class GraphQLServerRequestDeserializationBenchmark {
     private val mapper = jacksonObjectMapper()
     private lateinit var request: String
-    private lateinit var batchRequest: String
 
     @Setup
     fun setUp() {
+        JSON.config(JSONWriter.Feature.WriteNulls)
         val loader = this::class.java.classLoader
         val operation = loader.getResource("StarWarsDetails.graphql")!!.readText().replace("\n", "\\n")
         val variables = loader.getResource("StarWarsDetailsVariables.json")!!.readText()
@@ -50,25 +52,11 @@ open class GraphQLServerRequestDeserializationBenchmark {
                 "variables": $variables
             }
         """.trimIndent()
-        batchRequest = """
-            [
-                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
-                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
-                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables },
-                { "operationName": "StarWarsDetails", "query": "$operation", "variables": $variables }
-            ]
-        """.trimIndent()
     }
 
     @Benchmark
     fun JacksonDeserializeGraphQLRequest(): GraphQLServerRequest = mapper.readValue(request)
 
     @Benchmark
-    fun JacksonDeserializeGraphQLBatchRequest(): GraphQLServerRequest = mapper.readValue(batchRequest)
-
-    @Benchmark
-    fun KSerializationDeserializeGraphQLRequest(): GraphQLServerRequest = Json.decodeFromString(request)
-
-    @Benchmark
-    fun KSerializationDeserializeGraphQLBatchRequest(): GraphQLServerRequest = Json.decodeFromString(batchRequest)
+    fun FastJsonDeserializeGraphQLRequest(): GraphQLServerRequest = request.to()
 }

servers/graphql-kotlin-server/src/benchmarks/kotlin/GraphQLServerResponseDeserializationBenchmark.kt → servers/graphql-kotlin-server/src/benchmarks/kotlin/GraphQLServerResponseBatchSerializationBenchmark.kt

@@ -16,10 +16,12 @@
 
 package com.expediagroup.graphql.server
 
-import com.expediagroup.graphql.server.testtypes.GraphQLServerResponse
+import com.alibaba.fastjson2.JSON
+import com.alibaba.fastjson2.JSONWriter
+import com.expediagroup.graphql.server.types.GraphQLBatchResponse
+import com.expediagroup.graphql.server.types.GraphQLResponse
 import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import com.fasterxml.jackson.module.kotlin.readValue
-import kotlinx.serialization.json.Json
 import org.openjdk.jmh.annotations.Benchmark
 import org.openjdk.jmh.annotations.Fork
 import org.openjdk.jmh.annotations.Measurement
@@ -30,36 +32,32 @@ import org.openjdk.jmh.annotations.Warmup
 import java.util.concurrent.TimeUnit
 
 @State(Scope.Benchmark)
-@Fork(5)
-@Warmup(iterations = 1, time = 5, timeUnit = TimeUnit.SECONDS)
-@Measurement(iterations = 5, time = 10, timeUnit = TimeUnit.SECONDS)
-open class GraphQLServerResponseDeserializationBenchmark {
+@Fork(value = 5, jvmArgsAppend = ["--add-modules=jdk.incubator.vector", "-Dfastjson2.readerVector=true"])
+@Warmup(iterations = 1, time = 1, timeUnit = TimeUnit.SECONDS)
+@Measurement(iterations = 4, time = 5, timeUnit = TimeUnit.SECONDS)
+open class GraphQLServerResponseBatchSerializationBenchmark {
     private val mapper = jacksonObjectMapper()
-    private lateinit var response: String
-    private lateinit var batchResponse: String
+    private lateinit var batchResponse: GraphQLBatchResponse
 
     @Setup
     fun setUp() {
-        response = this::class.java.classLoader.getResource("StarWarsDetailsResponse.json")!!.readText()
-        batchResponse = """
-            [
-                $response,
-                $response,
-                $response,
-                $response
-            ]
-        """.trimIndent()
+        JSON.config(JSONWriter.Feature.WriteNulls)
+        val data = mapper.readValue<Map<String, Any?>>(
+            this::class.java.classLoader.getResourceAsStream("StarWarsDetailsResponse.json")!!
+        )
+        batchResponse = GraphQLBatchResponse(
+            listOf(
+                GraphQLResponse(data),
+                GraphQLResponse(data),
+                GraphQLResponse(data),
+                GraphQLResponse(data)
+            )
+        )
     }
 
     @Benchmark
-    fun JacksonDeserializeGraphQLResponse(): GraphQLServerResponse = mapper.readValue(response)
+    fun JacksonSerializeGraphQLBatchResponse(): String = mapper.writeValueAsString(batchResponse)
 
     @Benchmark
-    fun JacksonDeserializeGraphQLBatchResponse(): GraphQLServerResponse = mapper.readValue(batchResponse)
-
-    @Benchmark
-    fun KSerializationDeserializeGraphQLResponse(): GraphQLServerResponse = Json.decodeFromString(response)
-
-    @Benchmark
-    fun KSerializationDeserializeGraphQLBatchResponse(): GraphQLServerResponse = Json.decodeFromString(batchResponse)
+    fun FastJsonSerializeGraphQLBatchResponse(): String = JSON.toJSONString(batchResponse)
 }