java DataInputStream read() 停止并且不继续

Question

• 我想发送和接收一个对象并归档顺序是

  1. client -> server by ObjectOut(In)putStream

  2. client -> server String(file name) by DataIn(Out)putStrean writeUTF

  3. client -> server by BufferedIn(Out)putStream

  4. 服务器 -> 客户端通过 ObjectOut(In)putStream

但是当代码达到 3 个写入文件时需要永远（我认为...它正在等待），关键代码是

byte[] data = new byte[BUFFER_SIZE];
while ((length = bis.read(data)) != -1) {
    bos.write(data, 0, length);
    System.out.println(length);
}

bis(BufferedInputStream).read() 当我打印输出的长度时不要继续

4096
4096
879

那就等着吧……

有没有人知道问题或解决方案是什么？

服务器线程

public void run() {

    System.out.println("\n New FileUploadServer thread started");
    msg = (Message) objComm.recvObject(clientSocket);
    System.out.println("server get message");
    if (checkState(msg.getState()))
        System.out.println(clientAddr + " session over");

    System.out.println("");
}

private boolean checkState(int _state) {
    switch (_state) {
        case ST_EXCEL_FILE:
            return receiveExcel();
        default:
            return false;
    }
}


private boolean receiveExcel() {

    Message sendMsg = receiveStr();
    System.out.println("receiveStr() success");
    BufferedInputStream bis;
    DataOutputStream dos;
    DataInputStream dis;
    FileOutputStream fos;
    BufferedOutputStream bos;

    VoteInfo sendVoteInfo = (VoteInfo) msg.getObj();

    try {
        dis = new DataInputStream(clientSocket.getInputStream());
        dos = new DataOutputStream(clientSocket.getOutputStream());
        // check file name extension is "xls" or "xlsx"
        String fName = dis.readUTF();


        int idx = fName.lastIndexOf(".");
        String extension = fName.substring(idx + 1, fName.length());
        if (!excelFileCheck(extension))
            return false;

        dos.writeUTF("read_ok");
        dos.flush();
        System.out.println("File name: " + fName);
        File f = new File(EXCEL_FILE_DIR + fName);

        fos = new FileOutputStream(f);
        bos = new BufferedOutputStream(fos);
        bis = new BufferedInputStream(clientSocket.getInputStream());

        int length;
        byte[] data = new byte[BUFFER_SIZE];
        while ((length = bis.read(data)) != -1) {
            bos.write(data, 0, length);
            System.out.println(length);
        }
        bos.flush();
        // send success message to web server
        System.out.println("kangji2");

        objComm.sendObject(sendMsg, clientSocket);


        System.out.println("File receive success!");

        if (!dataToDB.excelToDB(EXCEL_FILE_DIR + fName, extension)) {
            //delete all db related to this excel file here
            return false;
        } else {


        }
        bos.close();
        fos.close();
        dis.close();

        clientSocket.close();

        // send candidates information to DB server
        return makeResult(sendVoteInfo);

    } catch (IOException e) {
        System.out.println("ReceiveExcel error");
        e.printStackTrace();
    }
    return false;
}


public class ObjectComm {

    private Message receiveMsg = null;
    private ObjectOutputStream out = null;
    private ObjectInputStream in = null;

    public Message commObject(Message _sendMsg, Socket _clntSocket) {

        if (!_clntSocket.isConnected()) {
            System.out.println("clnt Socket not connected");
            return null;
        }

        try {
            out = new ObjectOutputStream(_clntSocket.getOutputStream());
            out.writeObject(_sendMsg);
            out.flush();

            System.out.println("kangji1");
            in = new ObjectInputStream(_clntSocket.getInputStream());
            receiveMsg = (Message) in.readObject();
            System.out.println("kangji2");
            return receiveMsg;
        } catch (Exception e) {
            System.out.println("commObject err");
            e.printStackTrace();
            return null;
        }

    }

    public boolean sendObject(Message _msg, Socket _clntSocket) {
        if (!_clntSocket.isConnected()) {
            System.out.println("clnt Socket not connected");
            return false;
        }

        try {
            out = new ObjectOutputStream(_clntSocket.getOutputStream());
            out.writeObject(_msg);
            out.flush();

            return true;
        } catch (IOException e) {
            System.out.println("Object comm send err");
            e.printStackTrace();
            return false;
        }
    }

    public Message recvObject(Socket _clntSocket) {
        if (!_clntSocket.isConnected()) {
            System.out.println("clnt Socket not connected");
            return null;
        }

        try {
            in = new ObjectInputStream(_clntSocket.getInputStream());
            receiveMsg = (Message) in.readObject();
            return receiveMsg;

        } catch (Exception e) {
            System.out.println("Object comm recvObject err");
            e.printStackTrace();
            return null;
        }
    }

}

Answer 1

您是否关闭了客户端（发送方，或与您的输入流相反的任何地方）的连接？ BufferedInputStream 中的 read(byte[], int, int ) 将在到达流末尾时返回。

http://docs.oracle.com/javase/7/docs/api/java/io/BufferedInputStream.html#read(byte[],%20int,%20int)

Answer 2

• 客户端 -> 由 ObjectOut(In)putStream 提供的服务器
• client -> server String(file name) by DataIn(Out)putStrean writeUTF
• 客户端 -> BufferedIn(Out)putStream 的服务器
• 服务器 -> ObjectOut(In)putStream 客户端

这里的东西太多了。

在流堆栈的不同级别播放流根本不起作用。

如果您想发送对象，请使用ObjectInput/OutputStreams 来表示所有内容。按如下方式构造它们：

new ObjectOutputStream(new BufferedOutputStream(...))

和

new ObjectInputStream(new BufferedInputStream(...))

用writeObject(); 发送对象，用writeObject() 或writeUTF(); 发送字符串，通过ObjectOutputStream.write(); 发送字节数组，并在另一端使用ObjectInputStream 的互补方法。