Jar-файл поврежден при отправке через сокет в Scala

Question

Я знаю, что Scala использует сокеты Java, но я не совсем понимаю ответы на вопросы, которые были у людей с одной и той же проблемой, но строго на Java.

Вот мой код:

Я пытаюсь отправить файл банки через сокет, но когда я пытаюсь открыть файл банки с другой стороны, файл, кажется, поврежден. Как я могу это исправить?

Сервер:

object server extends App { 
    import java.net._ 
    import java.io._ 
    import scala.io._ 

    import scala.io.Source 

    val server = new ServerSocket(9999) 

    //Master should ping the slave actor to request for jar file 
    while (true) { 
     val s = server.accept() 
     val in = new BufferedSource(s.getInputStream()).getLines() 
     val out = new PrintStream(s.getOutputStream()) 

     val filename = "mapReduce.jar" 
     for (line <- Source.fromFile(filename, "ISO-8859-1").getLines)  { 
      out.println(line) 
      // println(line) 
     } 


     out.flush() 
     s.close() 
    } 
} 

Наряду с Клиентом:

object client extends App { 
    import java.net._ 
    import java.io._ 
    import scala.io._ 
    import java.util.jar._ 

    val s = new Socket(InetAddress.getByName("localhost"), 9999) 
    lazy val in = new BufferedSource(s.getInputStream()).getLines() 
    val out = new PrintStream(s.getOutputStream()) 

    out.println("Give me the jar file!") 
    out.flush() 

    val file = new File("testmapReduce.jar") 
    val bw = new BufferedWriter(new FileWriter(file)) 
    while(in.hasNext) { 
     val buf = in.next() 
     bw.write(buf) 
     // println(buf) 
    } 


    s.close() 
    bw.close() 


    println("Done!") 
    val jar = new JarFile(file) //this part fails 
} 

Answer 1

Source, PrintStream и т.д., предназначены для борьбы с текстом, а не двоичные данные. Они преобразуют данные как для чтения, так и для записи в соответствии с набором символов, который они используют («iso-8859-1» в вашем случае). Не используйте их для чтения/записи двоичных данных.

Если вам просто нужно отправить байт, не заморачиваться с их интерпретации:

val f = new FileInputStream(filename) 
    val bos = new BufferedOutputStream(out) 
    Stream.continually(f.read).takeWhile(_ != -1).foreach(bos.write) 
    f.close 
    bos.close