case对象的Scala序列的组连接

import java.io.{ByteArrayInputStream, ByteArrayOutputStream, ObjectInputStream, ObjectOutputStream}
import scala.collection.mutable.ListBuffer

// 定义一个Case类
case class Person(name: String, age: Int)

// 创建Case类对象
val person1 = Person("John", 30)
val person2 = Person("Alice", 25)
val person3 = Person("Bob", 35)

// 将Case类对象序列化并组连接
val outputStream = new ByteArrayOutputStream()
val objectOutputStream = new ObjectOutputStream(outputStream)
objectOutputStream.writeObject(person1)
objectOutputStream.writeObject(person2)
objectOutputStream.writeObject(person3)
objectOutputStream.close()

val byteArray = outputStream.toByteArray()

// 将字节数组转换为Case类对象
val inputStream = new ByteArrayInputStream(byteArray)
val objectInputStream = new ObjectInputStream(inputStream)

val resultList = ListBuffer[Person]()
var obj: AnyRef = null
while ({ obj = objectInputStream.readObject(); obj != null }) {
  resultList += obj.asInstanceOf[Person]
}

objectInputStream.close()

// 输出结果
resultList.foreach(println)