当前位置: 代码迷 >> J2SE >> 来一直监听,但是报错java.io.StreamCorruptedException:invalid
  详细解决方案

来一直监听,但是报错java.io.StreamCorruptedException:invalid

热度:149   发布时间:2016-04-24 17:48:00.0
怎么让服务端的socket一直处于监听中啊?
我的服务端做成线程,可以正常接受客户端传过来的数据!但是服务端只能
监听一次!我要求服务端一只处于监听中,参照网上的建议,用while(listening=true){...}来一直监听,但是报错java.io.StreamCorruptedException:invalid   Stream   header
这是什么问题?
     


------解决方案--------------------
你搜一下ObjectInputStream,我回答过很多这样的问题了

Object流在创建的时候会产生一个头数据,来标示对象流开始.用循环可以,但不要在循环外面初始化对象流,而是在循环内部创建,也就是说每循环一次都new一下对象流

while(true){
...
ObjectInputStream ois=new ObjectInputStream(inputStream);
ois.readObject();
...
}

发送数据的地方也一样就可以了
------解决方案--------------------
tij2里有例子的
------解决方案--------------------
接受到一个请求就起一个线程,再继续监听
ServerSocket sc=new ServerSocket(8189);
while(true)
{
final Socket socket =sc.accept();
Thread thread=new Thread(new Runnable()
{public void run()
{

try {
OutputStream out = socket.getOutputStream();
PrintWriter pw=new PrintWriter(out,true);
pw.println( "wo kao ");
} catch (IOException ex) {
}

}
});

}
------解决方案--------------------
把 Socket Client=socServer.accept();放到循环里
不就循环监听拉,我前面那个例子,你可以试下~~

------解决方案--------------------
你发送的代码贴出来看看
------解决方案--------------------
问题解决了,我看了下别人的代码
0.ObjectInputStream ois=new ObjectInputStream(fromClient.getInputStream());
这一句都分成2步来做的:
1.ObjectInputStream ois=null 定义成全局变量
2.ois=new ObjectInputStream(fromClient.getInputStream()); 在循环中创建
不知道分开做与一起做的区别在哪里?有点奇怪,感觉没什么区别啊?

--------------------------
一个号不能回复3次,只好又注了个号把结果写出来了
------解决方案--------------------
开始的代码:
Socket Client=socServer.accept(); //这里
while(listenin){
new ChatServer(Client).start();
}
修改后的代码
while(listening){
Socket Client=socServer.accept(); //这里,先后顺序改变了
new ChatServer(Client).start();
}
现在是彻底正常了,写出来给大家参考
------解决方案--------------------
用线程啊................
------解决方案--------------------
import java.io.*;
import java.net.*;
public class MultiThreadServer{
public static void main(String[] args)
{
try
{
//建立通信套接字
ServerSocket serverSocket = new ServerSocket(8000);
int clientNo = 1;
while(true)
{
//监听
Socket connectToClient = serverSocket.accept();
//如果有连接,建立一个线程进行处理
HandleAClient thread = new HandleAClient(connectToClient);
thread.start();
clientNo++;
}
}catch(IOException ex)
{
System.err.println(ex);
}
}
}
//处理客户短消息进程类
class HandleAClient extends Thread{
private Socket connectToClient;
public HandleAClient(Socket socket)
{
connectToClient= socket;
}
public void run()
{
try
{
DataInputStream isFromClient = new DataInputStream(
connectToClient.getInputStrem());
  相关解决方案