Question

java中使用Socket连接，关闭是出异常如何处理？

//服务器代码
package com.tt;
import java.io.*;
import java.net.*;
public class get extends Thread{
Socket s;
public static void main(String[] args) {
// TODO Auto-generated method stub
get g=new get();
g.run();
}
public get()
{
try {
ServerSocket ss = new ServerSocket(9999);;
System.out.println("9999号监听");
s=ss.accept();

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
public void run()
{
while(true)
{
try {
ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
User u=(User)ois.readObject();
System.out.println(u.getName());
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
//客户端代码
package com.tt;
import java.io.*;
import java.net.*;
public class link extends Thread{
Socket s;
public static void main(String[] args) {
// TODO Auto-generated method stub
link l=new link();
l.run();
}
public link()
{
try {

s= new Socket("127.0.0.1",9999);

} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void run()
{ while(true)
{
User u=new User();
u.setName("1");
ObjectOutputStream oos;
try {

oos = new ObjectOutputStream(s.getOutputStream());
oos.writeObject(u);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

无论先关闭客户端，还是关闭服务器都会不断的抛出异常。请问有没有什么具体可行的解决方案。希望能得到各位大神的解决代码。谢谢了

Answer 1

你光有try catch，但实际并未对产生的网络异常进行处理，然后继续循环，那自然是无限异常下去了。只要在catch到异常后进行相应处理即可，比如关闭连接，然后退出。在服务端，客户端都加上这个处理，比如在客户端加，如下

    public void run()
    {
        while (true)
        {
            User u = new User();
            u.setName("1");
            ObjectOutputStream oos;
            try
            {

                oos = new ObjectOutputStream(s.getOutputStream());
                oos.writeObject(u);
            }
            catch (Exception e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
                
                //注意，这边会看到显示的是true,因为对方并没有调用close来关闭连接，而是直接终止程序
                System.out.println(s.isConnected());
                
                if (s != null)
                {
                    try
                    {
                        s.close();
                        s = null;
                    }
                    catch (Exception ex)
                    {
                        ex.printStackTrace();
                    }
                    
                    System.out.println("远程连接异常，关闭连接");
                    return;
                }
            }
        }
    }

 

注：

你的这种情况即不能用u=ois.readObject())!=null来判断，也不能用s.isConnected&&!s.isColse()来判断，因为你是直接终止服务端或者客户端的运行，而不是先close连接，再终止程序。

Answer 2

服务器端读取的时候怎么可以用死循环，客户端一关闭，你再去读取当然会抛出异常了。
while循环用while((u=ois.readObject())!=null)当连接关闭的时候，readObject会返回null对象，while循环就退出了。

客户端应该用的是socket的isColse()和isConnected()的值来进行循环。
即while(s.isConnected&&!s.isColse())即，连接曾经连接成功并且未关闭的情况下循环。

捕捉异常之后也应该使用return来退出整个run方法不在循环