1

问题是我得到 java.io.StreamCorruptedException: invalid type code: 9E 每次的代码都不一样。

我拥有的是一个客户端-服务器应用程序，当客户端处于上传状态而服务器处于下载状态时会出现问题。

用户从 ui 中按下一个按钮，所有选定的文件将被一一传输到服务器。

这是按钮代码：

try {
    _client.setProtocolFiles(_uploadTree.getFiles());
if(_uploadTree.getFiles().getFiles().size() > 0) {
    _client.write("iwanttoupload");
} else {
    CustomDialog.showInfoDialog("Πρέπει να επιλέξετε αρχεία", "Προσοχή");
}
} catch (Exception e) {
    e.printStackTrace();
}

这是客户端的上传状态：

@Override
public void interact(Object theInput) throws Exception {
    if(theInput.equals("uploadedsuccessfully")) {
        System.out.println("uploadedsuccessfully");
        _client.setState(new TranferState(_client));
    } else if(theInput.equals("letsgo") || theInput.equals("sendmemore")) {
        if(_fileToBeSent < _client.getProtocolFiles().getFiles().size())
            sendFiles(theInput);
        else
            _client.write("iuploadedall");
        _fileToBeSent++;
    } else if(theInput.equals("idontunderstandyou")) {
        _client.setState(new TranferState(_client));
    }
}

private void sendFiles(Object theInput) throws Exception {
    FileInputStream fis = null;
    try {
        fis = new FileInputStream(new File(_client.getProtocolFiles().getFiles().get(_fileToBeSent).getPath()));
        byte[] buffer = new byte[fis.available()];
        fis.read(buffer);
        _client.getProtocolFiles().getFiles().get(_fileToBeSent).setFile(buffer);
        try {
            _client.write(_client.getProtocolFiles().getFiles().get(_fileToBeSent));
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    } catch(IOException ex) {
        System.out.println(ex.getMessage());
        _fileToBeSent++;
        interact(theInput);
    }
}

这是服务器的下载状态：

@Override
public String reply(Object theInput) {
    String outPut = "";
    if(theInput.equals("iuploadedall")) {
        outPut = "uploadedsuccessfully";
        _connection.setConnectionState(new TranferState(_connection));
    } else if (theInput.equals("startedupload")) {
        outPut = "letsgo";
    } else if(theInput instanceof ProtocolFile) {
        try {
            System.out.println(theInput.toString());
            ProtocolFile file = (ProtocolFile)theInput;
            FileOutputStream fos = new FileOutputStream("C:\\" + file.getName());
            fos.write(file.getFile());
            fos.close();
            outPut = "sendmemore";

        } catch (IOException e) {
            e.printStackTrace();
        }
    } else {
        outPut="idontunderstandyou";
        _connection.setConnectionState(new TranferState(_connection));
    }
    return outPut;

}

这一切都适用于这个订单：

  1. 用户点击并发送“iwanttoupload”
  2. 服务器发送正常。---- 客户端和服务器现在处于上述状态。
  3. 客户端发送“startedupload”
  4. 服务器发送“letsgo”
  5. 客户端发送协议文件（序列化）
  6. 服务器发送“sendmemore”，直到他从客户端“iuploadedall”获取

如果用户按下一次按钮并等待上传等待然后再次按下它，这将非常有用。如果用户在上传完成之前按下它，我会得到这个异常。

一个快速解决方法是检查用户何时按下按钮，如果客户端状态是传输状态，否则不执行操作，但我想解决套接字问题或了解为什么会发生这种情况。我认为当它试图读取序列化对象时，新上传会发送数据并且会出现混乱。我实现的状态将避免根据消息进行通信，但是消息已发送并且存在问题。

客户端编写代码：

public void write(Object credentials) throws Exception {
if (credentials != null && _socket !=null && !_socket.isClosed()) {
        _oos.writeObject(credentials);
} else {
     connect();
     _oos.writeObject(_credentials);
    _oos.flush();
    _oos.writeObject(credentials);
}
_oos.flush();
}

服务器读取代码：

while ((input = ois.readObject()) != null) {
    if (_connectionState.getClass().equals(ClosedState.class)) {
    break;
}
oos.writeObject(Protocol.processInput(input, _connectionState));
oos.flush();
}

例外在这里：

while ((input = ois.readObject()) != null)
4

1 回答 1

1

我怀疑问题是在您的按钮代码中，您立即向客户端写入：

if(_uploadTree.getFiles().getFiles().size() > 0) {
    _client.write("iwanttoupload");
}

如果您遵循在后台线程中处理客户端通信的典型模式，那么您只能从该线程写入流。该按钮应该只排队一个通知，当它有机会时，该线程将处理该通知。

您看到此错误是因为“iwanttoupload”被插入到后台线程正在写入的对象中间，从而破坏了流。

于 2013-07-08T20:33:41.693 回答