java - 通过套接字从 Android 客户端向 Java 服务器发送图像时数据丢失

Question

我正在尝试将我的图像从 Android 客户端发送到 Java 服务器。我发送的图像大小约为 99kb，但服务器总是读取少几 kb，有时是 98，有时是 96，依此类推。我想知道为什么数据丢失以及如何以正确的方式发送图像。请帮助:)

代码:

Client(sending image):
    public void sendImage(File file){
        try {
            out = new PrintWriter(socket.getOutputStream(),true);
            out.println("Image");
            out.println(file.length());
            byte[] byteArray = new byte[(int) file.length()];
            FileInputStream fis = new FileInputStream(file);
            BufferedInputStream bis = new BufferedInputStream(fis);
            bis.read(byteArray,0,byteArray.length);
            OutputStream os = socket.getOutputStream();
            FilterOutputStream bos = new  FilterOutputStream(os);
            bos.write(byteArray,0,byteArray.length);
            bos.flush();
            os.close();
            bis.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

服务器(接收图片):

if(input.equals("Image")){
                        input = in.readLine();
                        int fileSize = Integer.parseInt(input);
                        System.out.println("FILESIZE:" +fileSize);
                        byte[] byteArray = new byte[fileSize];
                        FileOutputStream fileOutputStream = 
                                new FileOutputStream("filename.jpg");
                        BufferedOutputStream bos = 
                                new BufferedOutputStream(fileOutputStream);
                        BufferedInputStream bis = new BufferedInputStream(in_);
                        int bytesRead = bis.read(byteArray, 0, byteArray.length);
                        int current = bytesRead;
                        do {
                                bytesRead = bis.read(byteArray, current,
                                                (byteArray.length - current));
                                if (bytesRead >= 0) {
                                    current += bytesRead;
                                    System.out.println(current);
                                }
                         } while (bytesRead != -1);
                        bos.write(byteArray, 0, current);
                        bos.flush();
                        bos.close();
}

编辑问题已解决，工作代码如下:

客户端:

        public void sendImage(File file){
             try {
                    DataOutputStream out = new DataOutputStream(
                            socket.getOutputStream());
                    out.writeChar('I');
                    DataInputStream dis = new DataInputStream(new FileInputStream(file));
                    ByteArrayOutputStream ao = new ByteArrayOutputStream();
                    int read = 0;
                    byte[] buf = new byte[1024];
                    while ((read = dis.read(buf)) > -1) {
                        ao.write(buf, 0, read);
                    }

                    out.writeLong(ao.size());
                    out.write(ao.toByteArray());
                    out.flush();
                    out.close();
                    dis.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
        }

服务器端:

                if(input =='I'){
                    DataInputStream dis = new DataInputStream(clientSocket.getInputStream());
                    long length = dis.readLong();
                    File to = new File("filename.jpg");
                    DataOutputStream dos = new DataOutputStream(
                            new FileOutputStream(to));
                    byte[] buffer = new byte[1024];
                    int len, current = 0;
                    System.out.println(length);
                    while ( current != length) {
                        len = dis.read(buffer);
                        dos.write(buffer, 0, len);
                        current += len;
                        System.out.println(current);
                    }
                    dis.close();
                    dos.close();
                }

Answer 1

根据我的个人经验，PrintWriter 和 Buffers 不能很好地协同工作。因为在您告诉它之前尝试读取数据的缓冲区可以“窃取”它不应该做的数据。例如，如果您使用任何类型的缓冲读取器读取服务器端的输入，该缓冲区将在传入图像的“开始”处窃取一些部分，因为它认为它只是另一行。您总是可以尝试改用 DataInputStream 和 DataOutputStream..

客户:

public void sendImage(File file) {
    try {
        DataOutputStream out = new DataOutputStream(
                socket.getOutputStream());
        out.writeChar('I'); // as image,
        DataInputStream dis = new DataInputStream(new FileInputStream(file));
        ByteArrayOutputStream ao = new ByteArrayOutputStream();
        int read = 0;
        byte[] buf = new byte[1024];
        while ((read = dis.read(buf)) > -1) {
            ao.write(buf, 0, read);
        }
        out.writeLong(ao.size());
        out.write(ao.toByteArray());
        out.flush();
        out.close();
        dis.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

服务器:

// assuming folder structure exists.
public void readImage(Socket s, File to) throws IOException {

    DataInputStream dis = new DataInputStream(s.getInputStream());
    char c = dis.readChar();
    if (c == 'I') {
        long length = dis.readLong();
        DataOutputStream dos = new DataOutputStream(
                new FileOutputStream(to));
        byte[] buffer = new byte[1024];
        int len;
        while ((len = dis.read(buffer)) != -1) {
            dos.write(buffer, 0, len);
        }
        dis.close();
        dos.close();
    }

}