VPF::SAXBuilder и ByteBuffer - Форум программистов

HugeX

Дата 2.10.2009, 14:49 (ссылка)

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

Загрузка ...

Новичок

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

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

Приветствую всех посетителей форума!
Есть сервер и клиент. Для обмена данных с клиентом сервер использует каналы. Из канала писать можно только в объект ByteBuffer. Мне нужно распарсить полученный от клиента XML-документ, который я сперва записываю в объект класса ByteBuffer. Потом из него нужно каким-то образом сгенерировать входной поток и подать его на SAXBuilder.build(). Проблема состоит в том, что программа не двигается дальше строки Document hisXML = saxBuilder.build(reader);. Перепробовал уже множество вариантов и ни один не подходит. На форуме есть одна тема, но она полностью не осветляет этот вопрос, в интернете тоже куча инфы, но вся приблизительно одинакова. Вот то, к чему я в итоге пришел:
Часть кода сервера:

Код


        InputStream is = newInputStream(buffer);
        BufferedReader reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
        SAXBuilder saxBuilder = new SAXBuilder(false);
        Document hisXML = saxBuilder.build(reader);
        System.out.println(hisXML.getRootElement().getName());
        reader.close();
        is.close();

Метод newInputStream(ByteBuffer buf):

Код


public static InputStream newInputStream(final ByteBuffer buf) {
        return new InputStream() {
            public synchronized int read() throws IOException {
                if (!buf.hasRemaining()) {
                    return -1;
                }
                return buf.get();
            }

            @Override
            public synchronized int read(byte[] bytes, int off, int len) throws IOException {
                len = Math.min(len, buf.remaining());
                buf.get(bytes, off, len);
                return len;
            }
        };
    }

Часть кода клиента, ответственная за отправку XML:

Код


Socket fromserver = new Socket("127.0.0.1", 443);
OutputStream out = fromserver.getOutputStream();
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(out, "UTF-8"));
/*Генерирование документа*/
Document myXML = new Document(requestEl);
try {
        XMLOutputter outputter = new XMLOutputter();
        outputter.output(myXML, bw);
} catch (java.io.IOException e) {
        e.printStackTrace();
}

Буду благодарен всем вашим советам smile

LSD

Дата 2.10.2009, 15:42 (ссылка)

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

Загрузка ...

Leprechaun Software Developer

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

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

1. В read(byte[], int, int) ты не обрабатываешь ситуацию что данные в буфере закончились. Из-за этого все и висит. Добавь туда:

Код


      @Override
      public synchronized int read(byte[] bytes, int off, int len) throws IOException
      {
        if(!buf.hasRemaining())
        {
          return -1;
        }
        len = Math.min(len, buf.remaining());
        buf.get(bytes, off, len);
        return len;
      }

2. Ты уверен что у тебя в буфере находится весь XML полностью? Данные по сети могут приходить порциями, не все сразу.

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

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.

HugeX

Дата 2.10.2009, 16:07 (ссылка)

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

Загрузка ...

Новичок

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

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

Спасибо, это помогло smile

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