Как разобрать объект JSON в Spring AMQP? - PullRequest
Новая
       15

Как разобрать объект JSON в Spring AMQP?

0 голосов
/ 03 сентября 2018

Существует удаленный сервер RabbitMQ, который позволяет мне только отправлять и получать сообщения. Это значит, что я не могу ничего создать. Я отправляю определенный запрос и получаю ответ в формате JSON.

В моем приложении у меня есть простой класс Receiver: 

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Receiver {

@RabbitListener(queues = "QueueName")
    public void receive(String in) {
        System.out.println(" [x] Received '" + in + "'");
    }
}

И я ожидаю получить объект JSON. Вместо этого я получаю кучу цифр: 

 [x] Received '123,34,97,99,116,105,111,110,34,58,34,103,101,116,73,110,102,111,34,44,34,114,101,115,117,108,116,34,58,34,78,111,116,82,101,103,105,115,116,101,114,101,100,34,44,34,112,97,121,108,111,97,100,34,58,110,117,108,108,125'

Полагаю, это объект JSON, но как я могу преобразовать его в читаемый формат?

Ответы [ 2 ]

0 голосов
/ 11 сентября 2018

На мой вопрос есть еще один хороший ответ.

Вы можете просто изменить сигнатуру изменяющего аргумента метода слушателя с String на org.springframework.amqp.core.Message. Это выглядит так: 

public void receive(Message in) {

Вывод будет: 

[x] Received '(Body:'{"action":"getInfo","result":"NotRegistered","payload":null}' MessageProperties [headers={timestamp_in_ms=1536656426171}, timestamp=Tue Sep 11 16:00:26 KRAT 2018, contentType=application/json, contentLength=0, redelivered=false, receivedExchange=, receivedRoutingKey=routing_key, deliveryTag=1, consumerTag=amq.ctag-gHh9m1_cs52ramBUle_x0A, consumerQueue=queue])'

Если вы не хотите получать всю информацию о сообщении, тогда метод слушателя будет: 

@RabbitListener(queues = "queue")
    public void receive(Message in) {
        String body = new String(in.getBody());
        System.out.println(" [x] Received '" + body + "'");
    }

Полагаю, теперь этот вывод вам больше подходит: 

 [x] Received '{"action":"getInfo","result":"NotRegistered","payload":null}'

Вы также можете посмотреть похожую проблему здесь: Преобразование сообщения из RabbitMQ в строку / json

0 голосов
/ 03 сентября 2018

Скорее всего, сообщение отправлено в неправильном формате (строковый массив байтов), поэтому вы получаете такую ​​форму сообщения. Измените отправителя или преобразуйте это в правильную строку, подобную этой. 

    String str = "123,34,97,99,116,105,111,110,34,58,34,103,101,116,73,110,102,111,34,44,34,114,101,115,117,108,116,34,58,34,78,111,116,82,101,103,105,115,116,101,114,101,100,34,44,34,112,97,121,108,111,97,100,34,58,110,117,108,108,125";
    String[] chars = str.split(",");
    StringBuilder builder = new StringBuilder();
    Arrays.asList(chars).stream().map(Byte::valueOf).forEach(b -> builder.append((char)b.byteValue()));
    System.out.println(builder.toString());

выводов

{ "действие": "GetInfo", "результат": "NotRegistered", "полезная нагрузка": нулевая}

...