VPF::java.nio.channels - Форум программистов

Zandr_Guest

Дата 1.10.2005, 15:30 (ссылка)

(голосов: 0)

Загрузка ...

Unregistered

Есть сервер, который слушает на 8080 порту, на локальной машине, да даже фиг с ним, с сервером пока. Не могу понять, почему блокируюсь на select():

Код


        System.out.println("Делаем клиента.");
        Selector selector = Selector.open();
        SocketChannel channel = SocketChannel.open();
        channel.configureBlocking(false);
        //channel.socket().bind(new InetSocketAddress(8888)); // Никак не влияет на результат
        channel.register(selector, SelectionKey.OP_CONNECT);
        System.out.println("Строка печатается.");
        selector.select();
        System.out.println("Строка не печатается.");

Кто знает - в чем проблема или чего не хватает - подскажите плз...

LSD

Дата 1.10.2005, 15:45 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15719
Регистрация: 24.3.2004
Где: Dublin

Репутация: 19
Всего: 538

Не вижу проблемы

Цитата(java)

This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's wakeup method is invoked, or the current thread is interrupted, whichever comes first.

там есть второй метод с таймаутом.

Или ты имеешь в виду, что доступные каналы есть а он все равно блокируется?

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

Guest

Дата 1.10.2005, 15:57 (ссылка)

(голосов: 0)

Загрузка ...

Unregistered

В то-то и дело. У Брюса Эккеля в TIEE есть такой код (там не закомментирован бинд клиентского сокета и регистрация опреаций чтения и записи вдобавок к коннекту). Так и тот код тоже блокируется в select()'е. Однозначно - такого быть не должно. Пробовал на 1.4 и 1.5.

Guest

Дата 1.10.2005, 15:58 (ссылка)

(голосов: 0)

Загрузка ...

Unregistered

Блин в Thinking in Enterprise Java smile

Zandr

Дата 3.10.2005, 05:57 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 433
Регистрация: 16.7.2004
Где: Новосибирск

Репутация: нет
Всего: 13

Код


        Selector selector = Selector.open();
        SocketChannel channel = SocketChannel.open();
        channel.configureBlocking(false);
        channel.register(selector, SelectionKey.OP_CONNECT | SelectionKey.OP_WRITE | SelectionKey.OP_READ);
        channel.connect(new InetSocketAddress("target.host.ru", 80));

        boolean running = true;

        while (running) {
            selector.select();
            Iterator<SelectionKey> keysIterator = selector.selectedKeys().iterator();

            while (keysIterator.hasNext()) {
                SelectionKey key = keysIterator.next();
                keysIterator.remove();
                
                if (key.isConnectable()) {
                    channel.finishConnect();
                }
                
                //if (key.isWritable()) {
                    // ...

Это сообщение отредактировал(а) Zandr - 3.10.2005, 06:00

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Работа с сетью \| Следующая тема »