通过TCP / IP接收对象

Question

我要通过TCP / IP编写程序，我应该通过客户端或服务器发送对象，当我想发送或接收字符串但尝试读取对象时，它是正确的：

private Socket client;

public ThreadedClient(Socket client) {
    this.client = client;
}

@Override
public void run() {
        try {
            ObjectInputStream objIn = new ObjectInputStream(client.getInputStream());
            while(true){
                try {
                    Object fromClient = objIn.readObject();

                } catch (ClassNotFoundException e) {e.printStackTrace();}
            }
        } catch (IOException e) {e.printStackTrace();}
    }

我收到一个例外：

java.io.StreamCorruptedException: invalid stream header: 306E6165
    at java.io.ObjectInputStream.readStreamHeader(Unknown Source)
    at java.io.ObjectInputStream.<init>(Unknown Source)
    at org.bihe.serverSocket.ThreadedClient.run(Server.java:137)
    at java.lang.Thread.run(Unknown Source)

它指的是这一行：

    ObjectInputStream objIn = new ObjectInputStream(client.getInputStream());

这是我的服务器代码：

            ServerSocket ss = new ServerSocket(8800);
            while(true){
                Socket newClient = ss.accept();

                System.out.println(">>>> Client number " + (++counter) + " connected.");
                OutputStream outputStream = newClient.getOutputStream();
                PrintWriter sender = new PrintWriter(outputStream);
                sender.println(true);
                sender.flush();
                ThreadedClient client = new ThreadedClient(newClient);
                clients.add(client);
                new Thread(client).start();

客户端代码：

sc = new Socket("127.0.0.1", 8800);
            InputStream inputStream = sc.getInputStream();
            Scanner scanner = new Scanner(inputStream);
            boolean s = scanner.nextBoolean();
            if(s){
                System.out.println("Client connected successfully.");
                return true;
            }else{
                System.out.println("Ohhh, Some problem happened, try again later!");
            }

谁能解释我发生了什么，这个例外是什么，为什么我收到这个例外？

Answer 1

只是摆脱发送和接收布尔值的麻烦。这是多余的。如果在创建连接时遇到问题，则不会创建套接字：而是抛出异常。您会将所有内容与同一套接字上的多个流混淆。不要那样做

在您的读取对象循环中，您需要分别捕获EOFException，并在获取它时关闭套接字并退出循环。如果还有其他IOException，请记录它，关闭套接字，然后退出循环。