如何在Kotlinx序列化中序列化“任何”类型？

我已经使用Java序列化通过网络发送它。接收者无法知道有效载荷的类型，但是Java将其反序列化就很好了，然后我使用when（dataType）作为查找来正确将Any对象转换为正确的类型。容易疯了。

这是因为Java序列化是相当原始的-只有一种方法可以序列化（并反序列化）对象。在kotlinx.serialization中，每个类都可以有自己的序列化策略（甚至几个）。这种灵活性是有代价的。Any可以处理的序列化（针对其子类的声明列表），但是dataType在一般情况下，无法基于部分反序列化对象的字段动态确定反序列化策略，因为无法保证首先对dataType字段进行反序列化。一些序列化格式（例如JSON或Protobuf）具有无序模式。可能会payload在之前被反序列化dataType，并且Decoder接口不允许返回/进行多次传递。

如果您确定序列化格式/消息中的属性顺序（或者感到很幸运），则可以使用以下自定义序列化器：

import kotlinx.serialization.*
import kotlinx.serialization.descriptors.*
import kotlinx.serialization.encoding.*

@Serializable(with = PacketSerializer::class)
data class Packet(val dataType: String, val payload: Any)

object PacketSerializer : KSerializer<Packet> {
    override val descriptor: SerialDescriptor = buildClassSerialDescriptor("Packet") {
        element("dataType", serialDescriptor<String>())
        element("payload", buildClassSerialDescriptor("Any"))
    }

    @Suppress("UNCHECKED_CAST")
    private val dataTypeSerializers: Map<String, KSerializer<Any>> =
        mapOf(
            "String" to serializer<String>(),
            "Int" to serializer<Int>(),
            //list them all
        ).mapValues { (_, v) -> v as KSerializer<Any> }

    private fun getPayloadSerializer(dataType: String): KSerializer<Any> = dataTypeSerializers[dataType]
        ?: throw SerializationException("Serializer for class $dataType is not registered in PacketSerializer")

    override fun serialize(encoder: Encoder, value: Packet) {
        encoder.encodeStructure(descriptor) {
            encodeStringElement(descriptor, 0, value.dataType)
            encodeSerializableElement(descriptor, 1, getPayloadSerializer(value.dataType), value.payload)
        }
    }

    @ExperimentalSerializationApi
    override fun deserialize(decoder: Decoder): Packet = decoder.decodeStructure(descriptor) {
        if (decodeSequentially()) {
            val dataType = decodeStringElement(descriptor, 0)
            val payload = decodeSerializableElement(descriptor, 1, getPayloadSerializer(dataType))
            Packet(dataType, payload)
        } else {
            require(decodeElementIndex(descriptor) == 0) { "dataType field should precede payload field" }
            val dataType = decodeStringElement(descriptor, 0)
            val payload = when (val index = decodeElementIndex(descriptor)) {
                1 -> decodeSerializableElement(descriptor, 1, getPayloadSerializer(dataType))
                CompositeDecoder.DECODE_DONE -> throw SerializationException("payload field is missing")
                else -> error("Unexpected index: $index")
            }
            Packet(dataType, payload)
        }
    }
}