Creación de un servidor de socket que permite múltiples conexiones a través de subprocesos y Java

Question

Estoy intentando adaptar mi servidor de socket simple para que pueda tener múltiples conexiones TCP, a través de subprocesamiento múltiple, pero parece que no puedo hacerlo funcionar. Mi código hasta el momento es el siguiente, no estoy realmente seguro de a dónde ir desde aquí:

import java.net.*; 
import java.io.*; 

public class DoSomethingWithInput implements Runnable { 
    private final Socket clientSocket; //initialize in const'r 
    public void run() { 


    BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); 
     String nextline; 
     while ((nextline = in.readLine())!=null) { 
      System.out.println(nextline); 
     } //... close socket, etc. 
    } 
} 


public class Socket{ 

    public Socket() { 
} 
@Override 
public void run() { 
    try { 
    ServerSocket serverSocket = null; 
    serverSocket = new ServerSocket(5432); 
    for (;;) { 
     ServerSocket serverSocket = null; 
     serverSocket = new ServerSocket(5432); 
     for (;;) { 
     Socket clientSocket = null; 
     clientSocket = serverSocket.accept(); 
     //delegate to new thread 
     new Thread(new DoSomethingWithInput(clientSocket)).start(); 
     } 
    } 
    }catch (IOException e) { 
    System.err.println("Could not listen on port: 5432."); 
    System.exit(1); 
} 
} 
} 

qué alguien sea capaz de darme algunos consejos sobre cómo podría hacer esto, y por qué mi aplicación actual no serán trabajo ? Estaba ejecutando las sugerencias en el tutorial de Java http://download.oracle.com/javase/tutorial/networking/sockets/examples/KKMultiServerThread.java aquí, pero el ejemplo que dan aquí parece usar muchas fuentes externas y clases como KnockKnockProtocol, etc.

¿Alguien podría ayudarme con esto?

¡Muchas gracias!

Answer 1

El problema es que en la actualidad se está aceptando la conexión, pero el bloqueo a continuación, realizar inmediatamente lee en él hasta que está cerrado:

// After a few changes... 
Socket clientSocket = serverSocket.accept(); 
BufferedReader in = new BufferedReader(new InputStreamReader(
    clientSocket.getInputStream())); 
String nextLine; 
while ((nextLine = in.readLine()) != null) { 
    System.out.println(nextline); 
} 

Eso significa que el mismo hilo que acepta la conexión está tratando de manejar la conexión. Eso no le permitirá usar múltiples conexiones al mismo tiempo.

En su lugar, cree una clase (por ejemplo, ConnectionHandler) que implemente Runnable y tenga un constructor tomando Socket. Su método run debe manejar la conexión. Luego cambie su código a:

Socket clientSocket = serverSocket.accept(); 
Runnable connectionHandler = new ConnectionHandler(clientSocket); 
new Thread(connectionHandler).start(); 

Eso dejará su hilo "principal" libre de esperar a la próxima conexión.

(Por cierto, la clase KnockKnockProtocol no es realmente "externa" - es parte del ejemplo Ellos simplemente no lo hacen muy claro que el source is here ....)

Answer 2

No tiene multihilo. Está creando un hilo que se une a un puerto y luego lee desde cualquier socket de cliente hasta que se cierre la conexión.

Necesita pasar el socket a un nuevo hilo y hacer que lo lea.

public class DoSomethingWithInput implements Runnable { 
    private final Socket clientSocket; //initialize in const'r 
    public void run() { 

     BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); 
     String nextline; 
     while ((nextline = in.readLine())!=null) { 
      System.out.println(nextline); 
     } //... close socket, etc. 
    } 
} 

//... 
ServerSocket serverSocket = null; 
serverSocket = new ServerSocket(5432); 
for (;;) { 
    Socket clientSocket = null; 
    clientSocket = serverSocket.accept(); 
    //delegate to new thread 
    new Thread(new DoSomethingWithInput(clientSocket)).start(); 
} //...