椰Ye 2023-04-04 17:15 采纳率: 63.2%
浏览 40
已结题

Java网络编程invalid stream header

简易多人聊天室项目
跟着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,然后开始聊天就会报空指针,实在不知道怎么办。

img

认真检查了线程和socket,找不到问题
[](链接: https://pan.baidu.com/s/1bqGp-WIHbqgFe_2PJtPr_w?pwd=b8gx)
  • 写回答

2条回答 默认 最新

  • pzzhao 2023-04-04 22:08
    关注

    你这里有三个问题:

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

      img

    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 转发消息给客户端,而不是直接操作客户端的界面显示

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论 编辑记录
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 4月16日
  • 已采纳回答 4月8日
  • 创建了问题 4月4日

悬赏问题

  • ¥15 plotBAPC画图出错
  • ¥30 关于#opencv#的问题:使用大疆无人机拍摄水稻田间图像,拼接成tif图片,用什么方法可以识别并框选出水稻作物行
  • ¥15 Python卡尔曼滤波融合
  • ¥20 iOS绕地区网络检测
  • ¥15 python验证码滑块图像识别
  • ¥15 根据背景及设计要求撰写设计报告
  • ¥20 能提供一下思路或者代码吗
  • ¥15 用twincat控制!
  • ¥15 请问一下这个运行结果是怎么来的
  • ¥15 单通道放大电路的工作原理