VPF::Пересылка сообщения между двумя peer

lavan

Дата 29.3.2012, 13:31 (ссылка)

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

Загрузка ...

Шустрый

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

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

Народ подскажите кто знает! Использую jxta хочу переслать сообщения между двумя peers которые узнают друг о друге через рандеву peer. пиры удачно связываются с рандеву пиром, пир А регестрирует двунаправленный канал передачи данных пир Б находит его и удачно подключается к каналу. Передеча сообщения происходит НО пир Б получает не то что послал пир А (посылается просто строка) пир А тоже получает не то что послал пир Б. Сообщение создаю так:

Код


public Message sendMMessege(){
        Message mes=new Message();
     StringMessageElement sm=new StringMessageElement("Message","Hello from: "+name,null);
     mes.addMessageElement("Namespace",sm);
     return mes;
    }

Обрабатываю полученное сообщение так:

Код


public void pipeMsgEvent(PipeMsgEvent pme){
      Message mes=pme.getMessage();
      String text=mes.getMessageElements("Namespace","Message").toString();
      System.out.println("Message recieved: "+text);
  }

Как это исправить? Как сделать так,чтобы если пир А послал строку "Hello" пир Б мог прочитать её?

lavan

Дата 31.3.2012, 16:45 (ссылка)

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

Загрузка ...

Шустрый

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

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

Вообщем проблема была решена,может кому пригодится. Проблема была в кодировках. peer получал сообщение и вероятнее всего не имея никакой кодировки по умолчанию не преобразовывал полученные байты,а просто показывал что сообщение полученно. Нужно задать явно какая кодировка нужна

Код


public void pipeMsgEvent(PipeMsgEvent pme){
      Message mes=pme.getMessage();
      MessageElement mel=mes.getMessageElement("Namespace", "Message");
      byte []b=mel.getBytes(false);
      try{
      String text=new String(b,"utf-8");

      System.out.println("Message recieved: "+text);
      System.out.println("Sending answer");
        }catch(IOException ue){}
  }

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