Server gets crashed and throws IOException

[Steiphan Jason]

I have created very simple multi-threaded java socket chat program, and that works fine when they are chatting and new clients join to the program.But as soon as one client gets terminated or closed, the entire server fails with all other active clients in the chat. Could you guys give me an idea to solve this, please friends.

//Server threading class
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerThread {
private ServerSocket serverSocket; //server type socket needed only in server side
private Socket localSocket; //normal socket accepting any client requesting from same port
public ServerThread(){
try{
serverSocket = new ServerSocket(7605);
while (true) {
localSocket = serverSocket.accept();
Server srvr=new Server(localSocket);
Thread t=new Thread(srvr);
t.start();
}
}
catch(java.net.BindException e){
System.out.println("Server Port/Socket address already in use! Server can't startup");
}
catch(IOException e){
//e.printStackTrace();
System.out.println("Error occured when creating a new thread");
}
}
}

//simple server class
//import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
public class Server implements Runnable {
//private ServerSocket serverSocket;
private Socket localSocket;
private BufferedReader br;
private DataInputStream inStream;
private DataOutputStream outStream;
private String clientIP="";
public Server(Socket tempSocket){
try{
this.localSocket=tempSocket;
this.clientIP=this.localSocket.getRemoteSocketAddress().toString();
br=new BufferedReader(new InputStreamReader(System.in)); //read console input&put in buffered reader
inStream = new DataInputStream(localSocket.getInputStream()); //get data(text)comes from client
outStream = new DataOutputStream(localSocket.getOutputStream()); //send data to the client
}
catch(IOException ex){
//System.out.println(ex);
System.out.println("Error occured when initiating new Server Object");
}
}
public void run() {
try{
while(true){ //loop works until server or client stops/terminate/raise exception
System.out.println("Client "+clientIP+" Says :"+inStream.readUTF()); //print string received from client
outStream.writeUTF(br.readLine()); //send data to the client
}
}
catch(SocketException e){
System.out.println("Connection error with client "+clientIP);
}
catch(IOException e){
//e.printStackTrace();
System.out.println("Error occured when read/write data from client");
}
finally{
try {
clearResources();
} catch (IOException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
System.out.println("Error occured when clearing resources");
}
}
}
public void clearResources() throws IOException{
//closing resources
br.close();
inStream.close();
outStream.close();
//localSocket.close();
//serverSocket.close();
}
}

//Client class
import java.net.Socket;
import java.net.SocketException;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
public class Client {
private Socket localSocket;
private BufferedReader br;
private DataOutputStream outStream;
private DataInputStream inStream;
public Client(){
try{
localSocket=new Socket("localhost",7605); //normal socket requesting to the server
br=new BufferedReader(new InputStreamReader(System.in)); //read console input&put in buffered reader
outStream = new DataOutputStream(localSocket.getOutputStream()); //send data to the Server
inStream = new DataInputStream(localSocket.getInputStream()); //get data(text)comes from server
while(true){ //loop works until server or client stops/terminate/raise exception
outStream.writeUTF(br.readLine()); //send data to the server
System.out.println("Server Says:"+inStream.readUTF()); //print string received from server
}
}
catch(java.net.BindException ex){
System.out.println("Port/Socket in use. Can't run on the same port");
}
catch(IOException e) {
// TODO: handle exception
System.out.println("Error occured when read/write data from server");
}
finally{
//closing resources
try {
br.close();
inStream.close();
outStream.close();
localSocket.close();
} catch (IOException e2) {
// TODO: handle exception
System.out.println("Error occured when clear resources by client constructor");
}
}
}
}

[Henry Wong]

 

Steiphan Jason wrote:I have created very simple multi-threaded java socket chat program, and that works fine when they are chatting and new clients join to the program.But as soon as one client gets terminated or closed, the entire server fails with all other active clients in the chat. Could you guys give me an idea to solve this, please friends.

The process of closing one client, includes terminating the buffered reader, which is wrapped around standard input. This means that when a client is closed, standard input is closed. And when standard input is closed, then you can't type anything for that client, or any of the other clients.

Henry

[Steiphan Jason]

Thank you so much Henry Wong! Now I solved the problem. Thank you