TCP 文件传输问题

Question

I. 简介

我正在打开并读取一个文件，在读取时通过 TCP 套接字发送数据块。

发送者代码

byte[] buffer = new byte[16384];
while ((in.read(buffer)) > 0)
{
    SendProtocol(new FileTransfer(sender, receiver, buffer);
}

接收者代码

if(o instanceOf FileTransfer)
    FileTransfer tf = (FileTransfer) o;
    out.write(tf.getData);
}

II.问题

通过 TCP 套接字发送协议后，我查看了正在发送的字节。他们都是独一无二的。但在接收方，接收到的字节只是一遍又一遍相同的 byte[]。

三．例子

SENDER BYTES  
[3, 3, 5, -44, 4, 3]      
[99, -3, 5, -44, 7, 3]
[-11, 3, 5, -44, 4, 7]
[10, 6, 5, -44, 4, 66]

RECEIVER BYTES
[3, 3, 5, -44, 4, 3]
[3, 3, 5, -44, 4, 3]
[3, 3, 5, -44, 4, 3]
[3, 3, 5, -44, 4, 3]

Answer 1

您遇到的一个问题是您没有检查收到的字节数。可能您几乎每次通过环回都会获得完整的缓冲区，但您不太可能通过真实网络获得此缓冲区。您必须记录读入缓冲区的字节数并仅使用该数量。

Answer 2

也许我所做的这个测试示例清楚地表明了您错过了什么：

public class Test {
    public static void main(String args[]) throws Exception {

        Server server = new Server(12345);

        Socket s = null;
        InputStream fs = null; 
        try {
            s = new Socket("localhost", 12345);
            fs = new FileInputStream("test.txt");

            OutputStream os = s.getOutputStream();
            byte[] bytes = new byte[1024];
            int read;
            while ((read = fs.read(bytes)) != -1)
                os.write(bytes, 0, read);
        }
        finally {
            if (s != null)
                s.close();
            if (fs != null)
                fs.close();
        }


        server.join();
    }

    static class Server extends Thread {

        ServerSocket serverSocket;

        Server(int port) throws IOException {
            serverSocket = new ServerSocket(port);

            start();
        }

        @Override
        public void run() {
            try {
                Socket s = serverSocket.accept();

                InputStream is = s.getInputStream();

                try {

                    StringBuffer sb = new StringBuffer();
                    {
                        byte[] bytes = new byte[1024];
                        int read;
                        while ((read = is.read(bytes)) != -1) 
                            sb.append(new String(bytes, 0, read));
                    }

                    System.out.println(sb);
                }
                finally {
                    if (is != null)
                        is.close();
                }
            }
            catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

Answer 3

写入所有信息后使用out.flush()。

Answer 4

什么是 FileTransfer，它的构造函数是否复制缓冲区？它的操作是异步的吗？它的缓冲区可能在复制到 TCP 套接字之前被循环重新填充。即，您不断将指向同一缓冲区的指针排队，然后在循环中覆盖该缓冲区。

使 FileTransfer 承担缓冲区参数的所有权，并在发送时将其删除。然后为循环中的每次行程分配一个新的，并将其交给 FileTransfer。