如何停止同一连接的while循环的连续执行

Question

我正在为Java的一个聊天应用程序做一个服务器。

while循环应该连接到新的客户端，但代码仍然重复连接到第一个客户端，甚至在它连接之后也是如此，从而导致绑定失败错误。我该换什么？

import java.io.*;
import java.net.*;
import java.util.Scanner;

public class ServerM
{   
    public static void main(String args[])
    {
        while(true)
        {
            Listener l = new Listener();
            l.run();
        }
    }

}

class Listener implements Runnable
{
    static InetAddress arr[] = new InetAddress[10];
    static int i = 0;

    public void run()
    {

        try
        {
            ServerSocket ss = new ServerSocket(44444);
            System.out.println("Waiting...");
            Socket s = ss.accept();
            System.out.println("Connected!\n");

            DataInputStream din=new DataInputStream(s.getInputStream());
            String ip = din.readUTF();

            InetAddress addr = InetAddress.getByName(ip);

            for(int j=0; j<=i; j++)
            {
                if(arr[j] == addr)
                    return;
            }

            arr[i++] = addr;

            ChatThread c = new ChatThread(addr,s);//This creates a thread to allow communication with Client
            c.run();

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
}

Answer 1

Catch Exception是错误的实践

 catch(Exception e)
    {
        e.printStackTrace();
    }

尝试将自定义异常（MyException.class）转发到顶层，并在Try..catch中的ServerM类中处理此异常。并且不要忘记在finally块中关闭socket

ss.close();
s.close();

Answer 2

你的问题在于解决方案的设计。您正在运行服务器套接字的多个实例（并且使用相同的端口，这将以异常结束），并且使用这个线程来获取客户端连接，因此您只能有一个连接。

您应该做的是，为将监听所有连接的服务器套接字运行一个线程，然后在无限循环中运行每个客户端实例（新线程）。

public class ServerM
{   
    public static void main(String args[])
    {

        Listener l = new Listener();
        l.run();

    }

}

class Listener implements Runnable
{
    static InetAddress arr[] = new InetAddress[10];
    static int i = 0;

    public void run()
    {

        try
        {
            ServerSocket ss = new ServerSocket(44444);
            System.out.println("Waiting...");
            while (true) {
                Socket s = ss.accept();
                ClientListener clientListener = new ClientListener(s);
                clientListener.run();
            }

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
}

class ClientListener implements Runnable {

    private Socket socket;

    public ClientListener(Socket socket) {
        this.socket = socket;
    }

    public void run() {
        System.out.println("Connected!\n");

        DataInputStream din=new DataInputStream(s.getInputStream());
        String ip = din.readUTF();

        InetAddress addr = InetAddress.getByName(ip);

        for(int j=0; j<=i; j++)
        {
            if(arr[j] == addr)
                return;
        }

        arr[i++] = addr;

        ChatThread c = new ChatThread(addr,socket);
        c.run();
    }

}

您必须这样做，因为您只需要一个ServerSocket实例在特定端口侦听新连接，然后您需要[1..n]个客户端实例来处理每个连接。