Convert json to object rabbit

@Левиафам · Регистрация: 31.05.2012

Студворк — интернет-сервис помощи студентам

Всем привет! Работаю с rabbit и хочу его настроить так, чтобы реквесты (json-ны) автоматически конвертились в объекты по приходу, но у меня не выходит это реализовать

Имеется следующая конфигурация:

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
@Configuration
@EnableAutoConfiguration
public class RabbitConf implements CommandLineRunner {
 
    @Value("${rabbitmq.in.queue_name}")
    private String queueName;
    @Value("${rabbitmq.exchange}")
    private String exchange;
 
    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate temp = new RabbitTemplate(connectionFactory);
        temp.setMessageConverter(jsonMessageConverter());
        return temp;
    }
 
    @Bean
    public MessageConverter jsonMessageConverter(){
        return new JsonMessageConverter();
    }
 
 
 
    @Bean
    Queue queue() {
        return new Queue(queueName, false);
    }
 
    @Bean
    TopicExchange exchange() {
        return new TopicExchange(exchange);
    }
 
    @Bean
    Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(queueName);
    }
 
    @Bean
    SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setQueueNames(queueName);
        container.setMessageListener(listenerAdapter);
        container.setErrorHandler(errorHandler());
        container.setMessageConverter(jsonMessageConverter());
        return container;
    }
 
    @Bean
    MessageListenerAdapter listenerAdapter(Receiver receiver) {
        return new MessageListenerAdapter(receiver, "receiveMessage");
    }
 
    @Bean
    public ErrorHandler errorHandler() {
        return new ConditionalRejectingErrorHandler(new RabbitMQErrorHandler());
    }
 
    @Override
    public void run(String... args) throws Exception {
    }
}

В нем я объявил конвертер jsonMessageConverter который закинул в темплейт и контейнер рэбита (хотя не знаю обязательно в два закидывать или только в контейнер достаточно?).

Имеется метод который служит обработчиком (в конфиге "receiveMessage"):

Java
1
2
3
public void receiveMessage(Request request){
           ...logic 
    }

Я думал что конвертация будет происходить автоматически в тот объект который я прописал в сигнатуре обработчика, но исходя из ошибки которая валится - мне наверно нужно что-то еще дописать т.е. как то явно прописать тип объекта в который хочу автоматически преобразовать json и я что-то подобное пробовал но не вышло

Вот стэектрейс ошибки при отправке json

java.lang.NoSuchMethodError: org.codehaus.jackson.map.ObjectMapper.co nstructType(Ljava/lang/reflect/Type

Lorg/codehaus/jackson/type/JavaType;

at org.springframework.amqp.support.convert er.JsonMessageConverter.createMessage(Js onMessageConverter.java:174)
at org.springframework.amqp.support.convert er.AbstractMessageConverter.toMessage(Ab stractMessageConverter.java:56)
at org.springframework.amqp.rabbit.core.Rab bitTemplate.convertMessageIfNecessary(Ra bbitTemplate.java:1226)
at org.springframework.amqp.rabbit.core.Rab bitTemplate.convertAndSend(RabbitTemplat e.java:780)
at org.springframework.amqp.rabbit.core.Rab bitTemplate.convertAndSend(RabbitTemplat e.java:776)
at com.example.uprid.ReceiverUnitTest.sendR equestToRabbit(ReceiverUnitTest.java:79)
at sun.reflect.NativeMethodAccessorImpl.inv oke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.inv oke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl .invoke(DelegatingMethodAccessorImpl.jav a:43)
at java.lang.reflect.Method.invoke(Method.j ava:498)
at org.junit.runners.model.FrameworkMethod$ 1.runReflectiveCall(FrameworkMethod.java :50)
at org.junit.internal.runners.model.Reflect iveCallable.run(ReflectiveCallable.java: 12)
at org.junit.runners.model.FrameworkMethod. invokeExplosively(FrameworkMethod.java:4 7)
at org.junit.internal.runners.statements.In vokeMethod.evaluate(InvokeMethod.java:17 )
at org.springframework.test.context.junit4. statements.RunBeforeTestMethodCallbacks. evaluate(RunBeforeTestMethodCallbacks.ja va:75)
at org.springframework.test.context.junit4. statements.RunAfterTestMethodCallbacks.e valuate(RunAfterTestMethodCallbacks.java :86)
at org.springframework.test.context.junit4. statements.SpringRepeat.evaluate(SpringR epeat.java:84)
at org.junit.runners.ParentRunner.runLeaf(P arentRunner.java:325)
at org.springframework.test.context.junit4. SpringJUnit4ClassRunner.runChild(SpringJ Unit4ClassRunner.java:252)
at org.springframework.test.context.junit4. SpringJUnit4ClassRunner.runChild(SpringJ Unit4ClassRunner.java:94)
at org.junit.runners.ParentRunner$3.run(Par entRunner.java:290)
at org.junit.runners.ParentRunner$1.schedul e(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildr en(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$00 0(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluat e(ParentRunner.java:268)
at org.springframework.test.context.junit4. statements.RunBeforeTestClassCallbacks.e valuate(RunBeforeTestClassCallbacks.java :61)
at org.springframework.test.context.junit4. statements.RunAfterTestClassCallbacks.ev aluate(RunAfterTestClassCallbacks.java:7 0)
at org.junit.runners.ParentRunner.run(Paren tRunner.java:363)
at org.springframework.test.context.junit4. SpringJUnit4ClassRunner.run(SpringJUnit4 ClassRunner.java:191)
at org.junit.runner.JUnitCore.run(JUnitCore .java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner .startRunnerWithArgs(JUnit4IdeaTestRunne r.java:68)
at com.intellij.rt.execution.junit.IdeaTest Runner$Repeater.startRunnerWithArgs(Idea TestRunner.java:47)
at com.intellij.rt.execution.junit.JUnitSta rter.prepareStreamsAndStart(JUnitStarter .java:242)
at com.intellij.rt.execution.junit.JUnitSta rter.main(JUnitStarter.java:70)

как всегда буду очень благодарен за помощь

Добавлено через 1 час 12 минут
Я изменил конфиг вот так:

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
@Configuration
@EnableAutoConfiguration
public class RabbitConf implements CommandLineRunner {
 
    @Value("${rabbitmq.in.queue_name}")
    private String queueName;
    @Value("${rabbitmq.exchange}")
    private String exchange;
 
    @Bean
    @Primary
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setMessageConverter(jsonMessageConverter());
        return template;
    }
 
    @Bean
    public Jackson2JsonMessageConverter jsonMessageConverter () {
        Jackson2JsonMessageConverter jsonConverter = new Jackson2JsonMessageConverter ();
        jsonConverter.setClassMapper(classMapper());
        return jsonConverter;
    }
 
    @Bean
    public DefaultClassMapper classMapper () {
        DefaultClassMapper classMapper = new DefaultClassMapper ();
        Map<String, Class <? >> idClassMapping = new HashMap<>();
        idClassMapping.put ("receiveMessage", Request.class);
        idClassMapping.put ("bar", Response.class);
        classMapper.setIdClassMapping (idClassMapping);
        return classMapper;
    }
 
    @Bean
    Queue queue() {
        return new Queue(queueName, false);
    }
 
    @Bean
    TopicExchange exchange() {
        return new TopicExchange(exchange);
    }
 
    @Bean
    Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with(queueName);
    }
 
    @Bean
    SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setQueueNames(queueName);
        container.setMessageListener(listenerAdapter);
        container.setErrorHandler(errorHandler());
        return container;
    }
 
    @Bean
    MessageListenerAdapter listenerAdapter(Receiver receiver) {
        return new MessageListenerAdapter(receiver, "receiveMessage");
    }
 
    @Bean
    public ErrorHandler errorHandler() {
        return new ConditionalRejectingErrorHandler(new RabbitMQErrorHandler());
    }
 
    @Override
    public void run(String... args) throws Exception {
    }
}

я добавил мапер, но теперь другие ошибки....я не знаю чего он хочет...честно

org.springframework.amqp.rabbit.listener .exception.ListenerExecutionFailedExcept ion: Failed to invoke target method 'receiveMessage' with argument type = [class [B], value = [{[B@2c6356ad}]
at org.springframework.amqp.rabbit.listener .adapter.MessageListenerAdapter.invokeLi stenerMethod(MessageListenerAdapter.java :408) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .adapter.MessageListenerAdapter.onMessag e(MessageListenerAdapter.java:298) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .AbstractMessageListenerContainer.doInvo keListener(AbstractMessageListenerContai ner.java:848) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .AbstractMessageListenerContainer.invoke Listener(AbstractMessageListenerContaine r.java:771) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer.access$0 01(SimpleMessageListenerContainer.java:1 02) [spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer$1.invoke Listener(SimpleMessageListenerContainer. java:198) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer.invokeLi stener(SimpleMessageListenerContainer.ja va:1311) [spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .AbstractMessageListenerContainer.execut eListener(AbstractMessageListenerContain er.java:752) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer.doReceiv eAndExecute(SimpleMessageListenerContain er.java:1254) [spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer.receiveA ndExecute(SimpleMessageListenerContainer .java:1224) [spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer.access$1 600(SimpleMessageListenerContainer.java: 102) [spring-rabbit-1.7.4.RELEASE.jar:na]
at org.springframework.amqp.rabbit.listener .SimpleMessageListenerContainer$AsyncMes sageProcessingConsumer.run(SimpleMessage ListenerContainer.java:1470) [spring-rabbit-1.7.4.RELEASE.jar:na]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_151]
Caused by: java.lang.NoSuchMethodException: com.example.uprid.Receiver.receiveMessag e([B)
at java.lang.Class.getMethod(Class.java:178 6) ~[na:1.8.0_151]
at org.springframework.util.MethodInvoker.p repare(MethodInvoker.java:170) ~[spring-core-4.3.12.RELEASE.jar:4.3.12.RELEASE]
at org.springframework.amqp.rabbit.listener .adapter.MessageListenerAdapter.invokeLi stenerMethod(MessageListenerAdapter.java :386) ~[spring-rabbit-1.7.4.RELEASE.jar:na]
... 12 common frames omitted

Новые блоги и статьи Все статьи Все блоги /
Контроль заполнения и очистка дат в зависимости от значения перечислений Maks 12.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .	Архитектура слоя интернета для сервера-слоя. Hrethgir 11.04.2026 В продолжение https:/ / www. cyberforum. ru/ blogs/ 223907/ 10860. html Знаешь что я подумал? Раз мы все источники пишем в голове ветки, то ничего не мешает добавить в голову такой источник, который сам. . .	Подстановка значения реквизита справочника в табличную часть документа Maks 10.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: при выборе сотрудника (справочник Сотрудники) в ТЧ документа. . .	Очистка реквизитов документа при копировании Maks 09.04.2026 Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .
модель ЗдравоСохранения 8. Подготовка к разному выполнению заданий anaschu 08.04.2026 https:/ / github. com/ shumilovas/ med2. git main ветка * содержимое блока дэлэй из старой модели теперь внутри зайца новой модели 8ATzM_2aurI	Блокировка документа от изменений, если он открыт у другого пользователя Maks 08.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в конфигурации КА2. Задача: запретить редактирование документа, если он открыт у другого пользователя. / / . . .	Система безопасности+живучести для сервера-слоя интернета (сети). Двойная привязка. Hrethgir 08.04.2026 Далее были размышления о системе безопасности. Сообщения с наклонным текстом - мои. А как нам будет можно проверить, что ссылка наша, а не подделана хулиганами, которая выбросит на другую ветку и. . .	Модель ЗдрввоСохранения 7: больше работников, больше ресурсов. anaschu 08.04.2026 работников и заданий может быть сколько угодно, но настроено всё так, что используется пока что только 20% kYBz3eJf3jQ