Модераторы: LSD, AntonSaburov
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Зависание при чтении InputStream 
V
    Опции темы
DOKA
Дата 6.7.2008, 00:20 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Шустрый
*


Профиль
Группа: Участник
Сообщений: 68
Регистрация: 13.8.2006

Репутация: нет
Всего: нет
Доброго дня!


Требуется из входного сокета (m_inSocket) перенаправить поток на выходной сокет (m_outSocket). 
Но проблема в том, что на строчке 
Код

read1 = m_inSocket.getInputStream().read(buff);

чтение в какой-то момент останавливается. Сам не понимаю почему.

Обратите внимание на строку
Код

m_inSocket.setReceiveBufferSize(1);

- если её нет, то зависание происходит гораздо раньше.


Данные перенаправляются целиком только в редких случаях. Помогите, пожалуйста. Вот код:


Код

try
{
                m_inSocket.setReceiveBufferSize(1);
                int read1;
                int read2;
                byte[] buff = new byte[1024*64];
                do
                {
                    read1 = m_inSocket.getInputStream().read(buff);
                    if (read1 > 0)
                    {
                        System.out.println("o  " + read1);
                        m_outSocket.getOutputStream().write(buff, 0, read1);
                    }
                    
                    read2 = m_outSocket.getInputStream().read(buff);
                    if (read2 > 0)
                    {
                        System.out.println("i  " + read2);
                        m_inSocket.getOutputStream().write(buff, 0, read2);
                    }
                    
                } 
                while (read1 != -1 || read2 != -1);
}
catch (IOException e)
{
        e.printStackTrace();
}
PM MAIL   Вверх
AlexeyVorotnikov
Дата 7.7.2008, 09:57 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


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

Репутация: 1
Всего: 18
Операция read является блокирующей, т.е. пока не придёт очередная порция данных, программа будет стоять и ждать.


--------------------
RTFM!
Три источника и три составные части Java: The Java Language Specification, Java Platform API Specification, The Java Virtual Machine Specification
PM MAIL   Вверх
DOKA
Дата 8.7.2008, 12:24 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Шустрый
*


Профиль
Группа: Участник
Сообщений: 68
Регистрация: 13.8.2006

Репутация: нет
Всего: нет
Цитата(AlexeyVorotnikov @ 7.7.2008,  09:57)
Операция read является блокирующей, т.е. пока не придёт очередная порция данных, программа будет стоять и ждать.

Да, спасибо. Решением было использование available().
Только теперь почему-то нагрузга на процессор просто дикая. Как можно не ждать не бегая постоянно в цикле? Да и скорость передачи данных хромает :(
PM MAIL   Вверх
Platon
Дата 8.7.2008, 14:45 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Завсегдатай
Сообщений: 1801
Регистрация: 25.4.2006

Репутация: 3
Всего: 40
Если это клиент, используй отдельный поток, в котором читаешь блок методом read(buffer), если сервер, используй NIO или какой-нибудь фреймворк, типа Apache MINA


--------------------
user posted image
Блог на винграде
Мой Блог о Java
For Java developers... only
PM MAIL ICQ   Вверх
DOKA
Дата 9.7.2008, 12:55 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Шустрый
*


Профиль
Группа: Участник
Сообщений: 68
Регистрация: 13.8.2006

Репутация: нет
Всего: нет
Цитата(Platon @ 8.7.2008,  14:45)
Если это клиент, используй отдельный поток, в котором читаешь блок методом read(buffer), если сервер, используй NIO или какой-нибудь фреймворк, типа Apache MINA

Хм, и правда. Только что-то потоков много стало smile А самое плохое - соединения не всегда закрываются, несмотря на то, что я для теста выставил таймаут в 2000 мс.
PM MAIL   Вверх
  
 Ответ в темуСоздание новой темы Создание опроса
Правила форума "Java"
LSD   AntonSaburov
powerOn   tux
  • Прежде, чем задать вопрос, прочтите это!
  • Книги по Java собираются здесь.
  • Документация и ресурсы по Java находятся здесь.
  • Используйте теги [code=java][/code] для подсветки кода. Используйтe чекбокс "транслит", если у Вас нет русских шрифтов.
  • Помечайте свой вопрос как решённый, если на него получен ответ. Ссылка "Пометить как решённый" находится над первым постом.
  • Действия модераторов можно обсудить здесь.
  • FAQ раздела лежит здесь.

Если Вам помогли, и атмосфера форума Вам понравилась, то заходите к нам чаще! С уважением, LSD, AntonSaburov, powerOn, tux.
 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Java: Работа с сетью | Следующая тема »

Подписаться на тему | Подписка на этот форум | Скачать/Распечатать тему


 




[ Время генерации скрипта: 0.0839 ]   [ Использовано запросов: 22 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
 По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.