not able to connect...

[mark smith]

hi

in a client/server application, i can connect many client to the server


Client class

import java.io.*;
import java.net.*;
 
public class Client {
    public static void main(String[] args) throws IOException {
 
        String serverHostname = new String ("127.0.0.1");
        System.out.println ("Essai de se connecter a l'hote " + serverHostname + " au port 444.");
 
        Socket echoSocket = null;
        PrintWriter out = null;
        BufferedReader in = null;
 
        try {
            echoSocket = new Socket(serverHostname, 4444);
            out = new PrintWriter(echoSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
        } catch (UnknownHostException e) {
            System.err.println("Hote inconnu: " + serverHostname);
            System.exit(1);
        } catch (IOException e) {
            System.err.println("Ne pas se connecter au serveur: " + serverHostname);
            System.exit(1);
        }
 
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
        String userInput;
        System.out.print ("Entree: ");
        while ((userInput = stdIn.readLine()) != null) {
            out.println(userInput);
            System.out.println("echo: " + in.readLine());
            System.out.print ("Entree: ");
        }
 
        out.close();
        in.close();
        stdIn.close();
        echoSocket.close();
    }
}

now i try to connect to another server after 10 second...
i'm able to connect to it... but the server don't respond...

import java.io.*;
import java.net.*;
import java.lang.*;
import java.util.Timer;
import java.util.TimerTask;
 
public class Client {

  Timer timer;
  int nbEssai =0;
    
  public void compteur(){
    timer = new Timer();
    timer.schedule(new Tolerance(),0,1*1000);
  }

  public void connection(int port) throws IOException {
    String serverHostname = new String ("127.0.0.1");
    System.out.println ("try to connect to host " + serverHostname + " au port " + port);
    Socket echoSocket = null;
    PrintWriter out = null;
    BufferedReader in = null;
        
    try {
      echoSocket = new Socket(serverHostname, port);
      out = new PrintWriter(echoSocket.getOutputStream(), true);
      in = new BufferedReader(new InputStreamReader(echoSocket.getInputStream()));
     } catch (SocketException e) { 
       compteur();
     } catch (UnknownHostException e) {
       System.err.println("Hote inconnu: " + serverHostname);
       System.exit(1);
     } catch (IOException e) {
       System.err.println("Not able to connect to: " + serverHostname);
       System.exit(1);
     }
 
     BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
     String userInput;
     System.out.print ("Entree: ");
     while ((userInput = stdIn.readLine()) != null) {
       out.println(userInput);
       System.out.println("echo: " + in.readLine());
       System.out.println("echo: " + in.readLine());
       System.out.print ("Entree: ");
     }
     out.close();
     in.close();
     stdIn.close();
     echoSocket.close();
    }
    public static void main(String[] args) throws IOException {
      Client client = new Client();
      int port=4444;
      client.connection(4444);   
    }
    public class Tolerance extends TimerTask {
      public void run() {
    try{     
      nbEssai++;
      System.out.println("try : "+nbEssai);   
      if (nbEssai>=10){
        System.out.println("try to connect to a new server...");
          connection(4445);
      timer.cancel();  
    }
    else{
      connection(4444);
    }
     }
    catch(IOException e){   
    }
    }
    }
}

Server main class (commnet server 4444 to test my client...)

import java.net.*;
import java.io.*;
 
public class ServerMain {
 
private static int nbRequest=0;
 
    public synchronized void addRequest(){
        nbRequest++;
    }
 
    public synchronized int getRequest(){
        return nbRequest;
    }

    public static void main(String[] args) throws IOException {
    ServerMain serverMain = new ServerMain();
//    Server server1 = new Server(4444,serverMain);
    Server server2 = new Server(4445,serverMain);
//    server1.start();
        server2.start();
   }
}

server code

import java.net.*;
import java.io.*;
 
public class Server extends Thread{
 
public ServerMain serverMain;


    public synchronized void addRequest(){
        serverMain.addRequest();
    }
 
    public synchronized int getRequest(){
        return serverMain.getRequest();
    }
    
    public int port=0;
    
    public Server(int port,ServerMain s) {   
    super("Server");
        this.port = port;
        this.serverMain=s;       
    }
 
    public void run() {
        ServerSocket serverSocket = null;
        Socket s=null;
        System.out.println("server run, wait connecting....");
        boolean listening = true;
        try {
            serverSocket = new ServerSocket(port);
            
           while (listening){
           s=serverSocket.accept();
           new ServerThread(s,this).start();
          }
            
        }      
        catch (IOException e) {
            System.err.println("Could not listen on port.");
            System.exit(-1);
        }
    }
}

ServerThread class

import java.net.*;
import java.io.*;
 
public class ServerThread extends Thread {
 
    private Socket socket = null;
    private Server server = null;
    
    public ServerThread(Socket socket,Server s) {
        super("ServerThread");
        this.socket = socket;
        this.server = s;
    }
 
    public void run() {
 
      try {
        System.out.println("Attente de l'entree.....");
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        BufferedReader in = new BufferedReader(
                  new InputStreamReader(
                     socket.getInputStream()));
 
        String inputLine, outputLine;
        while ((inputLine = in.readLine()) != null) {
          server.addRequest();
          System.out.println("Server : " + inputLine);
          System.out.println("Server - Nb. Requete : " + server.getRequest());
                
                
          inputLine = inputLine.toUpperCase();
          out.println(inputLine);
          out.println("Nb. Requete : " +  server.getRequest());
          if (inputLine.equals("Bye."))
            break;
          }
          out.close();
          in.close();
          socket.close();
 
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

i start my server:

server run, wait connecting....

i start my client:

try to connect to 127.0.0.1 to portt 4444
Entree: Try: 1
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 2
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 3
try to connect to 127.0.0.1 to portt 4444
Entree: Tentative : 4
Essai de Trya� l'hote 127.0.0.1 au port 4444
Entree: Tentative : 5
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 6
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 7
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 8
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 9
try to connect to 127.0.0.1 to portt 4444
Entree: Try: 10
try to connect to a new server...
Entree:

i type some text:fsdfsf

nothing is displayed on client and server side...

any idea?