Форум программистов, компьютерный форум, киберфорум
Java: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.80/5: Рейтинг темы: голосов - 5, средняя оценка - 4.80
2 / 2 / 3
Регистрация: 04.12.2015
Сообщений: 114

Клиент на JAVA десериализация PROTOBUF сервер на С++

24.08.2016, 09:35. Показов 1101. Ответов 2
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Помогите пожалуйста получить данные в протобуф.
Ситуация:
С сервера написанного на C++ отправляется пакет данных по сокету клиенту работающему на JAVA.
Клиент на JAVA сам предварительно инициализирует соединение с сервером и отправляет данные. При этом до сервера все доходит, чаще всего без проблем.
Но вот с Сервера на клиента сообщение отправляю, а получить его не могу.
Вернее не могу его десериализавать.
На сколько я понял для того, чтобы выполнить операцию в PROTOBUF есть 2 оператора parseFrom и parseDelimitedFrom
Проблема возникает тогда, когда я пытаюсь десериализовать поток BufferedReader.
Более подробные комментарии в коде ниже, под катом:

Кликните здесь для просмотра всего текста
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
                //инициируем протобуф
               ProtosClass.RegData.Builder regdata = ProtosClass.RegData.newBuilder(); 
               regdata.setEmail("newEmail@newmail.com");
 
            try {
 
                    Process p1 = java.lang.Runtime.getRuntime().exec("ping -c 1"+ dstAddress);
                    int returnVal = p1.waitFor();
                    boolean reachable = (returnVal==0);
 
                    if (reachable = true) 
                    {
                        System.out.println("cool connect");
                    //Тут отсылаем собщение
 
                    // Создается соккет
                    Socket SimpleSock = new Socket(dstAddress, dstPort); 
 
                    //Формируем сообщение для protobuf
                    ByteArrayOutputStream baos=new ByteArrayOutputStream();
 
                    regdata.build().writeDelimitedTo(baos);
                    System.out.println(baos);
 
                    //copy the message to a bytebuffer
                    ByteBuffer socketBuffer1=ByteBuffer.wrap(baos.toByteArray());
 
                    SimpleSock.getOutputStream().write(baos.toByteArray());
                    baos.flush();
                    baos.close();
 
                    //До этого момента все проходит хорошо, отправка сообщения получается нормально
                    
 
                    //Теперь читаем ответочку, и тут начинаются сложности
 
 
                        boolean listening = true;
 
                        try {
                            String xml = null;
 
                            while (listening) 
                            {
                                BufferedReader reader =
                                        new BufferedReader(new InputStreamReader(SimpleSock.getInputStream()));
                                xml = reader.readLine();
 
                                if (xml == null) 
                                {
                                    // Закончили прием
                                    break;
                                }
                                if (xml != null) {
                                    System.out.println("XML222: " + xml + "\n\n"); 
                                    //Тут я вижу, что сообщение приходит вполне обьемное,
                                    // я посылаю не закодированные символы, поэтому их можно даже прочитать
                                    
                                    System.out.println(xml.getBytes());
                                    ProtosClass.SERVICE Service = ProtosClass.SERVICE.parseFrom(xml.getBytes());
                                    //А тут протобуф выкидывает ошибку
                                    System.out.println(Service);
                                    reader.close();
                                }
                            }
                        }
                        catch (Exception e)
                        {
                            System.out.println(e+"_____failed");
                        }
 
                        SimpleSock.close();
                        System.out.println("Cool Mess Was Send"+socketBuffer1);
                        } 
                        
                        else 
                        {
                                throw new Exception("Ping timeout");
                        }
 
                } catch (Exception e)
                                        
                    {
                        System.out.println("Ping failed. This means that ICMP messages are blocked by this host. (This may not be an issue) ");
                    }
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
24.08.2016, 09:35
Ответы с готовыми решениями:

Protobuf сериализация десериализация
Добрый день уважаемые форумчане. Помогите разобраться. Имеется клиент серверное приложение. Как мне при помощи protobuff-net настроить...

Десериализация в Protobuf неизвестного файла
Разбираюсь с google protocol buffers. Ситуация такая, что есть файл .proto c описанием структур и есть готовый бинарный файл с данными. Как...

Java сервер Flash клиент java.io.StreamCorruptedException: invalid stream header
Есть класс сериализованный на стороне java (сервер) и actionscript(клиент). При попытке передачи объекта от клиента к серверу вылетает...

2
2 / 2 / 3
Регистрация: 04.12.2015
Сообщений: 114
26.08.2016, 09:52  [ТС]
Ребят, может быть кто-то подскажет тогда каким образом иначе получить данные с сервера написанного на С++, если не через
Java
1
2
3
BufferedReader reader =
  new BufferedReader(new InputStreamReader(SimpleSock.getInputStream()));
                                xml = reader.readLine();
Подскажите рабочий вариант приема сообщений пожалуйста, уж как-нибудь в протобуф засуну потом.
Конструкция типа
Java
1
BufferedInputStream  reader = new BufferedInputStream ((SimpleSock.getInputStream()));
К сожалению также не дала результата, протобуф опять выплюнул ошибку.

Добавлено через 1 час 54 минуты
Если это важно то с сервера отправляются данные на JAVA клиента таким способом:


C++
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
                ProtoBuf::RegData RegData;
                RegData.set_email("newEmail@newmail.com");
 
                {
                    ProtoBuf::SERVICE *bytesizeback = RegData.add_service();
                    bytesizeback->set_pktsizesrvrcv(16852);//размер переменной
                }
 
            
int varintsize = google::protobuf::io::CodedOutputStream::VarintSize32(RegData.ByteSize());
int ackSize = RegData.ByteSize() + varintsize;
char* ackBuf = new char[ackSize];
 
google::protobuf::io::ArrayOutputStream arrayOut(ackBuf, ackSize);
google::protobuf::io::CodedOutputStream codedOut(&arrayOut);
codedOut.WriteVarint32(regdata.ByteSize());
 
RegData.SerializeToCodedStream(&codedOut);
 
send(Client, ackBuf, ackSize, 0);
 
delete(ackBuf);
            
 
iResult = shutdown(Client, SD_SEND);
0
Эксперт Java
378 / 370 / 114
Регистрация: 30.06.2010
Сообщений: 1,445
01.09.2016, 11:50
lostandleft, ты ошибку то приведи, которая выкидывается. тут нет магистров-астрологов
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
01.09.2016, 11:50
Помогаю со студенческими работами здесь

Protobuf-Converter: Преобразует Domain Object в Google Protobuf Message
Вот разработали Protobuf-Converter который преобразует Domain Object в Google Protobuf Message. Пример: ...

Клиент и сервер на java
Нужно написать приложения клиент и сервер, которые обмениваются пакетами. Написал приложения, которые обмениваются простым текстом. Каким...

Клиент/Сервер Java
Рассматриваю простой клиент-сервер. Клиент имеет текстовое поля для ввода и кнопку отправки, Сервер разбирает кодограммы, что то делает,...

Клиент на C++ сервер на Java
Привет, подскажите пожалуйста Имеется клиент на C++ и сервер на Java. Запускаем сервер и он ждет когда клиент отправит ему файл. После...

Клиент на Си сервер на Java
Всем привет! Подскажите, как соединить клиента написанного на C с сервером на Java .можно ссылку на простенький пример


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

Или воспользуйтесь поиском по форуму:
3
Ответ Создать тему
Новые блоги и статьи
Символьное дифференцирование
igorrr37 13.02.2026
/ * Логарифм записывается как: (x-2)log(x^2+2) - означает логарифм (x^2+2) по основанию (x-2). Унарный минус обозначается как ! */ #include <iostream> #include <stack> #include <cctype>. . .
Камера 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. Пошагово создадим проект для загрузки изображения. . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL3_image
8Observer8 10.02.2026
Содержание блога Библиотека SDL3_image содержит инструменты для расширенной работы с изображениями. Пошагово создадим проект для загрузки изображения формата PNG с альфа-каналом (с прозрачным. . .
Установка Qt-версии Lazarus IDE в Debian Trixie Xfce
volvo 10.02.2026
В общем, достали меня глюки IDE Лазаруса, собранной с использованием набора виджетов Gtk2 (конкретно: если набирать текст в редакторе и вызвать подсказку через Ctrl+Space, то после закрытия окошка. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru