buenos dias estoy intentando hacer una conexión por sockets desde php y haciendo de servidor con java. a continuacion les describo mas o menos lo que sucede:

FLUJO:
1 - Servidor Inicia
2- Cliente crea la conexion socket.
3- Cliente abre la conexion socket.
4 - Servidor recibe conexion;
5 - Cliente Envia mensaje "ping".
6- al intentar leer el Bufferd el servidor se queda esperando "no se que" (en la linea 42 del codigo java)   . (Este es mi problema)
7. el cliente se le agota el tiempo de espera y se genera excepción.
8. justo al cerrarse la conexión por el tiempo agotado el servidor lee el mensaje "ping".


Servidor Java:

package modelo.conexion;
 
import java.io.*;
import java.net.*;
 
import java.util.logging.Level;
import java.util.logging.Logger;
 
 
public class Servidor extends Thread {
 
    private static Servidor instance;
    public static final int PORT = 9901;
    public static boolean on = true;
    ServerSocket serverSocket = null;
    Socket clientSocket = null;
 
 
    private Servidor() {
 
    }
 
    @Override
    public void run() {
        try {
            // Create the server socket
            serverSocket = new ServerSocket(PORT, 1);
 
            while (on) {
                // Wait for a connection
                System.out.println("Servidor a la escucha...");
                clientSocket = serverSocket.accept();
 
 
                // get input and output streams
                BufferedReader input = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                // PrintWriter output = new PrintWriter (clientSocket.getOutputStream(),true);
 
                DataOutputStream output = new DataOutputStream(clientSocket.getOutputStream());
 
                //read data json
                String data = input.readLine();
 
                //output.write(data);
                output.writeBytes("OK");
                output.flush();
 
                clientSocket.close();
 
            }
        } catch (IOException ioe) {
            Logger.getLogger(Servidor.class.getName()).log(Level.SEVERE, null, ioe);
        }
    }
 
    public static synchronized Servidor getInstance() {
        if (instance == null) {
            instance = new Servidor();
            instance.run();
        }
        return instance;
    }
 
}
 

Codigo Cliente PHP:

<?php
$fp = stream_socket_client("tcp://127.0.0.1:9901", $errno, $errstr, 15);
if (!$fp) {
    echo "$errstr ($errno)<br />\n";
} else {
       $delimitador = "\n\n"; // -------- ESTA ES LA SOLUCION --------
	$mensaje = "ping".$delimitador;
    fwrite($fp, $mensaje, strlen($mensaje));
 
    sleep(2);
    while (!feof($fp)) {
        echo fgets($fp, 1024);
    }
    fclose($fp);
}
?>