Форум программистов [Powered by Invision Power Board]

Здравствуйте, мне снова нужна ваша помощь...
Нужно увидеть всех клиентов в сети и построить их список, чтобы потом можно было подключиться к выбранному посредством отправки запроса и его подтверждению на противоположном сокете.
Всё это должно быть одном приложении, т.е. клиенты равнозначны, они должны увидеть друг друга.
Итак, как я понял, для этого нужно использовать многопоточность. Как я это вижу:
1) Приложение пытается подключиться (пока на локалхосте) к порту 2012.
2) Если не получается, то создаётся сервер, который слушает подключения.
3) Если получается, то вынести подключение в отдельный поток (с одной стороны создаётся клиентский поток, с другой - серверный).
Но я не совсем улавливаю логику, вот мои коды:
Потоки практически одинаковые, можно смотреть один)

Код


public class serverThread extends Thread
{
    private Socket socket;
    private BufferedReader br;
    private PrintWriter pw;
    
    public serverThread (Socket s) throws IOException
    {
        System.out.println("Create Server thread");
        socket = s;
        br =
          new BufferedReader(
            new InputStreamReader(
              socket.getInputStream()));
        // Включаем автоматическое выталкивание:
        pw =
          new PrintWriter(
            new BufferedWriter(
              new OutputStreamWriter(
                socket.getOutputStream())), true);
        // Если любой из вышеприведенных вызовов приведет к
        // возникновению исключения, то вызывающий отвечает за
        // закрытие сокета. В противном случае, нить
        // закроет его.
        start(); // вызываем run()
    }
    
    public void run()
    {
        try 
        {
            pw.println(socket);
            while (true) 
            { 
                String str = br.readLine();
                if (str.equals("END")) 
                    break;
                System.out.println("Echoing: " + str);
            }
            System.out.println("closing...");
        } 
        catch(IOException e) 
        {
            System.err.println("IO Exception");
        } 
        finally 
        {
            try 
            {
                socket.close();
            } 
            catch(IOException e) 
            {
                System.err.println("Socket not closed");
            }
        }
    }
}

Код


public class clientThread extends Thread
{
    private Socket socket;
    private BufferedReader br;
    private PrintWriter pw;

    public clientThread (Socket s) throws IOException
    {
        socket = s;
        br =
          new BufferedReader(
            new InputStreamReader(
              socket.getInputStream()));
        // Включаем автоматическое выталкивание:
        pw =
          new PrintWriter(
            new BufferedWriter(
              new OutputStreamWriter(
                socket.getOutputStream())), true);
        // Если любой из вышеприведенных вызовов приведет к
        // возникновению исключения, то вызывающий отвечает за
        // закрытие сокета. В противном случае, нить
        // закроет его.
        start(); // вызываем run()
    }

    public void run()
    {
        try
        {
            pw.println(socket);
            while (true)
            {
                 String str = br.readLine();
                if (str.equals("END"))
                    break;
                System.out.println("Echoing: " + str);
            }
            System.out.println("closing...");
        }
        catch(IOException e)
        {
            System.err.println("IO Exception");
        }
        finally
        {
            try
            {
                socket.close();
            }
            catch(IOException e)
            {
                System.err.println("Socket not closed");
            }
        }
    }
}

Код


public void getClientList() throws IOException, InterruptedException
{
    Socket clientSocket = null;
    ServerSocket serverSocket = null;
    int portPrev = 0;
    while (true)
    {
        try
        {
             clientSocket = new Socket("localhost", 2012);
             int port = clientSocket.getLocalPort();
             if (portPrev != port)     //тут я хотел сделать проверку, чтобы не произошло зацикливания...
             try
             {
                 new clientThread(clientSocket);
                 portPrev = port;
             }
             catch(IOException e)
             {
                 // Если завершится неудачей, закрывается сокет,
                 // в противном случае, нить закроет его:
                 clientSocket.close();
             }
             isClient = 0;
        }
        catch(Exception e)
        {
            System.out.println("No clients! Create server!");
        }
        
         try
         {
             serverSocket = new ServerSocket(2012);
         }
         catch (IOException e)
         {
             System.out.println(e);
             System.exit(-1);
         }

            try
            {
                System.out.println("Waiting for a client...");
                clientSocket = serverSocket.accept();
                try
                {
                    new serverThread(clientSocket);
                }
                catch(IOException e)
                {
                    // Если завершится неудачей, закрывается сокет,
                    // в противном случае, нить закроет его:
                    clientSocket.close();
                }
                System.out.println("Client connected");
            }
            catch (Exception e)
            {
                System.out.println("Can't accept");
                System.exit(-1);
            }
    }
}

Прошу помощи, хотя бы советом, как это должно быть...
По-идее, в консоли должен построиться список вида:
Echoing: Socket[addr=localhost/127.0.0.1,port=2012,localport=64749]
Echoing: Socket[addr=localhost/127.0.0.1,port=2012,localport=64750]
...
А у мну ошибка

Код


java.net.BindException: Address already in use: JVM_Bind
Echoing: Socket[addr=localhost/127.0.0.1,port=2012,localport=65170]
Java Result: -1