Сбой соединения с несколькими сокетами Java NIO

Question

У меня есть программа, которая пытается подключиться к порту 80 на разных компьютерах и сообщает, если запущен сервер.Я использую NIO, который поэтому использует сокеты для подключения.Я делаю соединение, а затем опрашиваю с помощью finishConnect ().

Я получаю противоречивое поведение.Иногда программа правильно сообщает, что на разных компьютерах, которые я сканирую, работают веб-серверы.Однако в других случаях о соединениях не сообщается, даже если на целевых машинах работают веб-серверы.

Я бы понял это, если бы использовал сокеты UDP, поскольку они ненадежны, но я использую соединение TCP, котороедолжен быть надежным, т. е. не пропущенными пакетами.

Мне нужно иметь возможность сканировать многие машины, но это противоречивое поведение проявляется само собой даже при тестировании программы всего с 4 целевыми IP-адресами, у всех из которых есть веб-серверы на порту 80.

TIA

Удочка

class SiteFinder {

private static final long TIMEOUT = 500;

public void findSites() {

    int numSocketChannels = 100;
    int socketChannelCounter = 0;
    long ipAddressCounter = 0;
    boolean done = false;
    List<String> allIpAddresses =
            IPAddressGenerator.getIPAddresses(170);
    SocketChannel[] socketChannelArray =
            new SocketChannel[numSocketChannels];

    Iterator<String> itr = allIpAddresses.iterator();

    while(itr.hasNext()) {
        int k;
        for (k = 0; k < numSocketChannels && itr.hasNext(); k++) {
            String ipAddress = itr.next();
            ipAddressCounter++;
            if (ipAddressCounter % 50000 == 0)
                System.out.println(ipAddressCounter + " at " + new Date());
            try {
                socketChannelArray[k] = SocketChannel.open();
                socketChannelArray[k].configureBlocking(false);
                if (socketChannelArray[k].connect(
                            new InetSocketAddress(ipAddress,80))) {
                    System.out.println(
                            "connection established after connect() "
                            + ipAddress);
                    socketChannelArray[k].close();
                    socketChannelArray[k] = null;
                }
            } catch (IOException ioe) {
                System.out.println(
                        "error opening/connecting socket channel " + ioe);
                socketChannelArray[k] = null;
            }
        }

        while (k < numSocketChannels) {
            socketChannelArray[k++] = null;
        }

        long startTime = System.currentTimeMillis();
        long timeout = startTime + TIMEOUT;

connect:       
        while (System.currentTimeMillis() < timeout) {
            //System.out.println("passing");
            socketChannelCounter = 0;
            for(int j = 0; j < socketChannelArray.length; j++) {
                //System.out.println("calling finish connect");
                if (socketChannelArray[j] == null) {
                    ++socketChannelCounter;
                    if (socketChannelCounter == numSocketChannels) {
                        System.out.println("terminating connection loop");
                        break connect;
                    }
                    continue;
                }
                try {
                    if (socketChannelArray[j].finishConnect()) {
                        /*try {
                            out.write("connection established after " +
                            finishConnect()" +
                            clientChannelVector.elementAt(j).socket().
                            getInetAddress() + '\n');
                            out.flush();
                        } catch (IOException ioe) {
                            System.out.println(
                                "error writing to site-list "
                                + ioe.getMessage());
                        }*/
                        System.out.println(
                                "connection established after finishConnect()"
                                + socketChannelArray[j].socket().
                                getInetAddress());
                        socketChannelArray[j].close();
                        socketChannelArray[j] = null;
                    }
                } catch (IOException ioe) {
                    System.out.println(
                            "error connecting from "
                            + "clientChannel.finishConnect()");
                    try {
                        socketChannelArray[j].close();
                    } catch (IOException e) {
                        System.out.println("error closing socket channel");
                    } finally {
                        //System.out.println("removing socket channel");
                        //System.out.println(clientChannelVector.size());
                        socketChannelArray[j] = null;
                    }
                }
            }
        }
        closeConnections(socketChannelArray);
    }
}

private void closeConnections(SocketChannel[] socketChannelArray) {
    for (int i = 0; i < socketChannelArray.length; i++) {
        if (socketChannelArray[i] == null) {
            continue;
        }
        try {
            socketChannelArray[i].close();
            //System.out.println(
                //"TIME OUT WAITING FOR RESPONSE CLOSING CONNECTION");
        } catch (IOException ioe) {
            System.out.println(
                    "error closing socket channel " + ioe.getMessage());
        }
    }
}

}