Как преобразовать класс данных в ByteBuffer в Kotlin? - PullRequest
0 голосов
/ 07 февраля 2019

Я пытаюсь использовать Kinesis, который ожидает данные в формате байтового буфера.Все примеры, которые я видел до сих пор, написаны на Java и передают простые строки.Кто-нибудь может дать представление о том, как преобразовать класс данных kotlin в байтовый буфер?

например, класс данных abc (var a: Long, var b: String, var c: Double)

Ответы [ 3 ]

0 голосов
/ 07 февраля 2019

Возможно, вы захотите взглянуть на kotlinx.serialization .Это официальный проект Kotlin и поддерживает несколько форматов из коробки.Вы можете использовать вывод и обернуть его в ByteBuffer.wrap

0 голосов
/ 14 февраля 2019

Спасибо за все предложения.

Решил проблему, используя ObjectMapper () из библиотеки Джексона (jackson-databind) и аннотации.Следующий код, используемый для сериализации:

val objectMapper = ObjectMapper()
objectMapper.registerModule(JavaTimeModule())
val buf = ByteBuffer.wrap(objectMapper.writeValueAsString(className).toByteArray(Charsets.UTF_8))

код для десериализации:

val objectMapper = ObjectMapper()
objectMapper.registerModule(JavaTimeModule())
val obj = objectMapper.readValue(Charsets.UTF_8.decode(record.data()).toString(), ClassName::class.java)

Помимо этого мне пришлось добавить конструкторы всех классов данных и добавить следующую аннотацию квсе атрибуты LocalDateTime:

@DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)
@JsonFormat(pattern = "YYYY-MM-dd HH:mm")
var edd: LocalDateTime?,
0 голосов
/ 07 февраля 2019

Проверьте следующий метод

fun toByteArray(): ByteArray? {
val size: Int = 8 + 8 + string.Size

val byteBuffer = ByteBuffer.allocate(size)
        .put(long) //long veriable 
        .put(double) // double veriable 
        .put(string)


   return byteBuffer.array()
}

Вы можете выделить размер на основе размера dataType, например, Int 4 байта, Double и Long 8 байтов

для чтения обратно в dataType

  val byteBuffer = ByteBuffer.wrap(byteArray)
        byteBuffer.get(Int) //Int variable
        byteBuffer.get(Double) //Double variable
        byteBuffer.get(nonce)
...