2

Пишу клиент-сервер используя сокеты, передача файлов работает но с файлами не более 64 килобайт, почему так и как с этим бороться?

Сервер

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket servsock = new ServerSocket(4444);
        File myFile = new File("D:\\Games\\Dog.mp3");
        long len = myFile.length();
        System.out.print(len);
        while (true) {
            Socket sock = servsock.accept();
            byte[] mybytearray = new byte[(int) myFile.length()];
            BufferedInputStream bis = new BufferedInputStream(new FileInputStream(myFile));
            bis.read(mybytearray, 0, mybytearray.length);
            OutputStream os = sock.getOutputStream();
            os.write(mybytearray, 0, mybytearray.length);
            os.flush();
            sock.close();
        }
    }
}

Клиент

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.net.Socket;

public class Client {
    public static void main(String[] argv) throws Exception {
        Socket sock = new Socket("127.0.0.1", 4444);
        byte[] mybytearray = new byte[50000000];
        InputStream is = sock.getInputStream();
        FileOutputStream fos = new FileOutputStream("D:\\Dog.mpe");
        BufferedOutputStream bos = new BufferedOutputStream(fos);
        System.out.println(mybytearray);
        System.out.println(mybytearray.length);
        int bytesRead = is.read(mybytearray, 0, mybytearray.length);
        bos.write(mybytearray, 0, bytesRead);
        bos.close();
        sock.close();
    }
}
1
  • 2
    метод read не объязательно прочитает все данные. Он может прочитать и меньше (и он, кстати, возвращает число реально прочитанных байт). Поэтому, чтения/запись нужно заворачивать в цикл и контроллировать кол-во прочитанных-записанных байт.
    – KoVadim
    9 сен 2017 в 17:41

1 ответ 1

4

Как вам уже ответили в комментариях - чтение данных нужно производить в цикле, контролируя всё вручную.

Сервер

ByteArrayOutputStream byteArrayStream = new ByteArrayOutputStream();
byte[] buffer = new byte[1024]; // Буфер
int length;
// Читаем файл "складывая" прочитанные байты в byteArrayStream
while ((length = bis.read(buffer, 0, buffer.length)) != -1) {
    byteArrayStream.write(buffer, 0, length);
}
// Отправляем их клиенту
os.write(byteArrayStream.toByteArray());
os.flush();

Клиент

ByteArrayOutputStream byteArrayStream = new ByteArrayOutputStream();
byte[] buffer = new byte[1024];
int length;
// Теперь таким же образом читаем данные из входящего потока
while ((length = is.read(buffer, 0, buffer.length)) != -1) {
    byteArrayStream.write(buffer, 0, length);
}
// Запись в файл
bos.write(byteArrayStream.toByteArray());
bos.flush();

Альтернативы:

Apache Commons IO

byte[] bytes = IOUtils.toByteArray(inputStream);

Google Guava

byte[] bytes = ByteStreams.toByteArray(inputStream);

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.