Отказ в соединении после подключения 75 клиентов к серверу

Question

Я разработал сокет канала сервера, используя следующий код:

public class EchoServer {
private static final int BUFFER_SIZE = 1024;

private final static int DEFAULT_PORT = 9090;

private long numMessages = 0;

private long loopTime;

private InetAddress hostAddress = null;

private int port;

private Selector selector;

// The buffer into which we'll read data when it's available
private ByteBuffer readBuffer = ByteBuffer.allocate(BUFFER_SIZE);

int timestamp=0;

public EchoServer() throws IOException {
    this(DEFAULT_PORT);
}

public EchoServer(int port) throws IOException {
    this.port = port;
    hostAddress = InetAddress.getByName("127.0.0.1");
    selector = initSelector();
    loop();
}

private Selector initSelector() throws IOException {
    Selector socketSelector = SelectorProvider.provider().openSelector();

    ServerSocketChannel serverChannel = ServerSocketChannel.open();
    serverChannel.configureBlocking(false);

    InetSocketAddress isa = new InetSocketAddress(hostAddress, port);
    serverChannel.socket().bind(isa);
    serverChannel.register(socketSelector, SelectionKey.OP_ACCEPT);
    return socketSelector;
}

private void loop() {
    for (;true;) {
        try {
            selector.select();
            Iterator<SelectionKey> selectedKeys = selector.selectedKeys()
                    .iterator();
            while (selectedKeys.hasNext()) {
                SelectionKey key = selectedKeys.next();
                selectedKeys.remove();
                if (!key.isValid()) {
                    continue;
                }
                 // Check what event is available and deal with it
                if (key.isAcceptable()) {
                    accept(key);
                } else if (key.isWritable()) {
                    write(key);
                }
            }
            Thread.sleep(3000);
            timestamp+=3;
        } catch (Exception e) {
            e.printStackTrace();
            System.exit(1);
        }



    }
}

private void accept(SelectionKey key) throws IOException {

    ServerSocketChannel serverSocketChannel = (ServerSocketChannel) key.channel();

    SocketChannel socketChannel = serverSocketChannel.accept();
    socketChannel.configureBlocking(false);
    socketChannel.setOption(StandardSocketOptions.SO_KEEPALIVE, true);
    socketChannel.setOption(StandardSocketOptions.TCP_NODELAY, true);
  //  socketChannel.register(selector, SelectionKey.OP_READ);
    socketChannel.register(selector, SelectionKey.OP_WRITE);

    System.out.println("Client is connected");
}

private void write(SelectionKey key) throws IOException {
    SocketChannel socketChannel = (SocketChannel) key.channel();
    ByteBuffer dummyResponse = ByteBuffer.wrap(("ok:" + String.valueOf(timestamp)) .getBytes("UTF-8"));

    socketChannel.write(dummyResponse);
    if (dummyResponse.remaining() > 0) {
        System.err.print("Filled UP");
    }
    System.out.println("Message Sent");
 //   key.interestOps(SelectionKey.OP_READ);
}

}

Как видите, я запускаю его localhost порт 9090, Чтобы протестировать код для тяжелых соединений, я разработал тестовое приложение, которое каждую секунду запускает новый поток и подключается к серверу. Это код моего тестового приложения:

    public class Main {

    /**
     * @param args
     */
    public static void main(String[] args) {
        int i = 0;
        try {
            while (i < 10000) {
                RunnableDemo temp = new RunnableDemo("Thread-"
                        + String.valueOf(i));
                temp.start();
                i++;
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

class RunnableDemo implements Runnable {
    private Thread t;
    private String threadName;

    InetAddress host = null;
    int port = 9090;

    RunnableDemo(String name) {
        threadName = name;
        System.err.println("Creating " + threadName);

    }

    public void run() {
        System.err.println("Running " + threadName);
        try {
            SocketChannel socketChannel = SocketChannel.open();

            socketChannel.connect(new InetSocketAddress(host, port));

            while (!socketChannel.finishConnect())
                ;

            System.out.println("Thread " + threadName + " Connected");
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            while (true) {
                if (socketChannel.read(buffer) > 0) {
                    buffer.flip();
                    byte[] bytes = new byte[buffer.limit()];
                    buffer.get(bytes);  
                    System.out.println(threadName+ ":" + new String(bytes));
                    buffer.clear();
                }
            }

        } catch (Exception e) {
            System.out.println("Thread " + threadName + " interrupted.");
            e.printStackTrace();
        }
        System.out.println("Thread " + threadName + " exiting.");
    }

    public void start() {
        System.out.println("Starting " + threadName);
        try {
            host = InetAddress.getByName("127.0.0.1");
            if (t == null) {
                t = new Thread(this, threadName);
                t.start();
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

}

Тестовое приложение запускается, но только 75 потоков могут подключиться к серверу, и все потоки после 75-го показывают следующее исключение:

java.net.ConnectException: Connection refused: connect
at sun.nio.ch.Net.connect0(Native Method)
at sun.nio.ch.Net.connect(Unknown Source)
at sun.nio.ch.Net.connect(Unknown Source)
at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
at net.behboodi.client.RunnableDemo.run(Main.java:48)
at java.lang.Thread.run(Unknown Source)

Есть ли ограничения по количеству одновременных подключений к сокету? Или есть ли ограничения на использование порта 127.0.0.1 и локального хоста? Другая идея заключается в том, что, возможно, приложение Java или JVM не могут создать более 75 потоков.

Я обыскал их все, но не нашел ответа, который показал бы мне, какая из перечисленных выше причин является моей главной проблемой и как я могу исправить код, чтобы я мог протестировать приложение с более чем 10000 параллельными потоками?

Answer 1

Избавься от сна. Селектор уже блокируется. Спать в сетевом коде - буквально пустая трата времени. NB (1) Вы не звоните finishConnect() в режиме блокировки: (2) вы не подключаете потоки к ServerChannel, вы подключаете клиентские сокеты к серверному сокету, (3) ваш клиентский код не обрабатывает конец потока, и (4) это не эхо сервер. - EJP