Форум программистов, компьютерный форум, киберфорум
Java: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.63/8: Рейтинг темы: голосов - 8, средняя оценка - 4.63
6 / 6 / 3
Регистрация: 22.09.2013
Сообщений: 166

Работа с ObjectInputStream из разных потоков

10.09.2017, 11:30. Показов 1773. Ответов 1
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
У меня есть:
Java
1
private ObjectInputStream serverReader;
этот стрим необходим для приема сообщений с сервера. Подскажите как можно организовать с ним работу, если нужно одновременно считывать информацию из сервера с разных Thread-ов. (один нужен для прослушивания текущего списка клиентов, второй для получения объектов отправленных с другого клиента)

Просто делать что-то вроде такого в каждом потоке не прокатывает:
Java
1
Object list = serverReader.readObject();
потому-что при попытке считать возникает:
java.io.StreamCorruptedException: invalid type code: 00
at java.io.ObjectInputStream.readObject0(Ob jectInputStream.java:1381)
at java.io.ObjectInputStream.readObject(Obj ectInputStream.java:373)
at com.network.Network$BeeListener.run(Netw ork.java:210)

была идея просто сделать так, чтобы за эти две задачи отвечали разные Input и Output стримы. Но в этом случае происходит ошибка при повторном получении стрима из сокета. Код потока отвечающего за подключение к серверу и инит стримов:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
    private class ServerListener extends Thread {
        private long timeout = 5000;
 
        @Override
        public void run() {
            while(!this.isInterrupted()) {
                boolean succesfull = startConnection();
                if(succesfull) {
                    this.interrupt();
                    break;
                } else {
                    try {
                        this.sleep(timeout);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
 
        /**
         * Запуск соединения с сервером
         * @return
         */
        private boolean startConnection() {
            try {
                connection = new Socket(Constans.IP, Constans.PORT);
                if(connection != null) {
                    serverReader = new ObjectInputStream(connection.getInputStream());
                    serverWriter = new ObjectOutputStream(connection.getOutputStream());
 
                    beeReader = new ObjectInputStream(connection.getInputStream());
                    beeWriter = new ObjectOutputStream(connection.getOutputStream());
 
                    startListener();
                    return true;
                } else {
                    return false;
                }
            } catch (IOException e) {
                e.printStackTrace();
                return false;
            }
        }
    }
В этом случае возникает ошибка:
java.io.StreamCorruptedException: invalid stream header: 73720013
at java.io.ObjectInputStream.readStreamHead er(ObjectInputStream.java:808)
at java.io.ObjectInputStream.<init>(ObjectI nputStream.java:301)
at com.network.Network$ServerListener.start Connection(Network.java:129)
at com.network.Network$ServerListener.run(N etwork.java:101)

возникает она я так понимаю потому что нелья стрим поток одного сокета использовать несколько раз.
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
10.09.2017, 11:30
Ответы с готовыми решениями:

Работа из разных потоков с очередью
Здравствуйте. В общем, дела такие, есть у меня два потока и между ним некий &quot;буфер&quot;, коим служит очередь. Идёт приём данных...

Работа с QSerialPort из разных потоков
Задача такая. есть POS-принтер на COM порту. Необходимо иметь возможность передавать ему команды как из одного потока (основного) так и из...

Доступ к БД с разных потоков
как реализовать доступ к одной базе данных с разных потоков? когда один сервер обрабатывает несколько клиентов то у меня выходит...

1
Эксперт Java
378 / 370 / 114
Регистрация: 30.06.2010
Сообщений: 1,445
10.09.2017, 18:57
Считываешь из стрима только в одном потоке и по типу объекта определяешь обработчик, там уже делаешь сколько угодно потоков обработки
1
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
10.09.2017, 18:57
Помогаю со студенческими работами здесь

Изменение переменной из разных потоков
есть код class Counter { private int c = 0; public void increment() { c++; } public void...

Использование данных из разных потоков
Привет всем! Возникла проблема с использованием данных из разных потоков в многопоточном приложении 1) Допустим созданы два...

Обращение к массиву из разных потоков
Работа с потоками - материал объемный и я его осваиваю частями и по мере необходимости. Делегатами для управлением формой я пользоваться...

Доступ к очереди из разных потоков
Подскажите по многопоточности, у меня есть очередь (Queue) и мне надо организовать к ней доступ из разных потоков, выискал несколько...

Заполнение коллекции из разных потоков
Добрый день. Что я могу использовать вместо удобной ObservableCollection&lt;T&gt;, если мне надо добавлять данные из разных потоков?


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
2
Ответ Создать тему
Новые блоги и статьи
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Как объединить две одинаковые БД Access с разными данными
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru