0

我想将文件从客户端发送到服务器，并且将来能够再次发送。

所以我的客户端连接到服务器并上传文件，好的 - 它可以工作，但它在最后挂起..

所以这是我在客户端的代码，服务器端非常相似。

private void SenderFile(File file) {


    try {

            FileInputStream fis = new FileInputStream(file);
            OutputStream os = socket.getOutputStream();

            IoUtil.copy(fis, os);

        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

在 Stack 上找到的 IoUtils :)

public static class IoUtil {

    private final static int bufferSize = 8192;

    public static void copy(InputStream in, OutputStream out)
            throws IOException {
        byte[] buffer = new byte[bufferSize];
        int read;

        while ((read = in.read(buffer, 0, bufferSize)) != -1) {
            out.write(buffer, 0, read);
        }
        out.flush();
    }
}

解释：我的客户端有一个连接到服务器的套接字，我向他发送任何文件。我的服务器下载了它，但最后挂起，因为他正在监听更多信息。如果我选择另一个文件，我的服务器会将新数据下载到现有文件中。

如何将任何文件上传到服务器，使我的服务器正常工作并能够正确下载另一个文件？

附言。如果我在函数结束时添加到 ioutil.copy，out.close我的服务器将继续工作，但连接将丢失。我不知道该怎么办 ：{

更新后：客户端：

private void SenderFile(File file) {
    try {

        FileInputStream fis = new FileInputStream(file);
        OutputStream os = socket.getOutputStream();

        DataOutputStream wrapper = new DataOutputStream(os);
        wrapper.writeLong(file.length());
        IoUtil.copy(fis, wrapper);

    } catch (Exception ex) {
        ex.printStackTrace();
    }
}

服务器端（线程监听来自客户端的任何消息）：

public void run() {
    String msg;
    File newfile;

    try {
        //Nothing special code here

        while ((msg = reader.readLine()) != null) {


            String[] message = msg.split("\\|");
            if (message[0].equals("file")) {//file|filename|size

                String filename = message[1];
                //int filesize = Integer.parseInt(message[2]);

                newfile = new File("server" + filename);


                InputStream is = socket.getInputStream();
                OutputStream os = new FileOutputStream(newfile);

                DataInputStream wrapper = new DataInputStream(is);

                long fileSize = wrapper.readLong();
                byte[] fileData = new byte[(int) fileSize];
                is.read(fileData, 0, (int) fileSize);
                os.write(fileData, 0, (int) fileSize);


                System.out.println("Downloaded file");
            } else

                //Nothing special here too
        }

    } catch (Exception ex) {
        ex.printStackTrace();
    }

}

好的，现在我可以下载文件了 - 仍然有一次，另一个已下载但无法读取。例如，第二次我想由客户端发送一个 file.png。我在服务器上得到了它，但是无法查看此文件。提前致谢 ：）

4

1 回答 1

2

您需要使您的服务器能够区分文件。最简单的方法是提前告诉接收端应该对单个文件有多少字节；这样，它就知道何时停止阅读并等待下一个。

这就是该SenderFile方法的样子：

private void SenderFile(File file)
{
    try
    {
        FileInputStream fis = new FileInputStream(file);
        OutputStream os = socket.getOutputStream();

        DataOutputStream wrapper = new DataOutputStream(os);
        wrapper.writeLong(file.length());
        IoUtil.copy(fis, wrapper);
    }
    catch (Exception ex)
    {
        ex.printStackTrace();
    }
}

这就是该ReceiveFile方法的样子：

// the signature of the method is complete speculation, adapt it to your needs
private void ReceiveFile(File file)
{
    FileOutputStream fos = new File(file);
    InputStream is = socket.getInputStream();
    DataInputStream wrapper = new DataInputStream(is);

    // will not work for very big files, adapt to your needs too
    long fileSize = wrapper.readLong();
    byte[] fileData = new byte[fileSize];
    is.read(fileData, 0, fileSize);
    fos.write(fileData, 0, fileSize);
}

然后不要关闭套接字。

于 2012-09-08T14:24:44.847 回答