Java网络编程invalid stream header

Question

简易多人聊天室项目

跟着b站韩顺平老师做的，自己有一些小改动。为什么总是出现这个错误啊java.io.StreamCorruptedException: invalid stream header，实在检查不出来哪里出的问题。下面是源码压缩包，提取码: b8gx

package com.company.Server.model;

/**
 * @Title:
 * @Package
 * @Description: 服务器和客户端通信线程
 * @author: Yeeasy
 **/

import com.company.Client.tools.TalkingViewManage;
import com.company.Client.tools.UserThreads;
import com.company.Client.tools.UserThreadsManage;
import com.company.Client.view.TalkingView;
import com.company.Shared.Message;

import java.net.*;
import java.io.*;

public class ConnectThread extends Thread {

    Socket socket;

    public ConnectThread(Socket socket) {
        this.socket = socket;
    }

    public void run() {

        while (true) {

            try {
                //接受信息
                ObjectInputStream in;
                ObjectOutputStream out;

                in = new ObjectInputStream(socket.getInputStream());
                Message msg = (Message) in.readObject();

                //从usersThread中获取friend线程，转发信息
                UserThreads userThread= UserThreadsManage.getUserThreads(msg.getUser());

                out = new ObjectOutputStream(userThread.getSocket().getOutputStream());
                out.writeObject(msg);

                TalkingView talkingView= TalkingViewManage.getTalkingView(msg.getUser());
                talkingView.showMessage(msg);

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

只要一登陆成功就会报 invalid stream header，然后开始聊天就会报空指针，实在不知道怎么办。

认真检查了线程和socket，找不到问题

[](链接: https://pan.baidu.com/s/1bqGp-WIHbqgFe_2PJtPr_w?pwd=b8gx)

Answer 1

你这里有三个问题：

1. ConnectToServer 类 44行，为啥还要去在输出一次msg，就是这个导致了 invalid header ，注释之后这个异常就没了。
   

   

2. ActListener 类 47 行应该换成下面这个，要不然后面ConnectThread 里面 getUserThreads 会报空指针，你可能会觉得你的客户端有添加，但是客户端和服务端是两个独立的进程，内存不共享的。

   UserThreadsManage.addUserThreads(u.getUserID(), new UserThreads(socket));
   

3. ConnectThread 类中 45 行代码获取 TalkingView，和上面情况一样。那个是客户端add进去的，服务端无法获取，另外服务端也没法add，因为add了获取到的也不是客户端的那个 TalkingView。

   TalkingView talkingView= TalkingViewManage.getTalkingView(msg.getUser());
   

而且正常服务端也应该是通过socket 转发消息给客户端，而不是直接操作客户端的界面显示