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

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

10.09.2017, 11:30. Показов 1799. Ответов 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
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами
8Observer8 20.02.2026
Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .
Конвертировать закладки radiotray-ng в m3u-плейлист
damix 19.02.2026
Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI
Eddy_Em 18.02.2026
Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru