Cannot convert from [[B] to [com.***.CoursePub] for GenericMessage [……………………]

电玩女神 2023-10-01 20:53 29阅读 0赞

org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
    Endpoint handler details:
    Method [public void com.***.***.syn(com.***.***)]
    Bean [com.***.***.mq.CoursePost@23a9c04b]
    	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:185)
    	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:120)
    	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1414)
    	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1337)
    	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1324)
    	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1303)
    	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:785)
    	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:769)
    	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$700(SimpleMessageListenerContainer.java:77)
    	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1010)
    	at java.lang.Thread.run(Thread.java:745)
    Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [[B] to [com.***.***] for GenericMessage [payload=byte[876], headers={amqp_receivedDeliveryMode=PERSISTENT, amqp_receivedRoutingKey=course_pub, amqp_contentEncoding=UTF-8, amqp_receivedExchange=xuecheng, amqp_deliveryTag=2, amqp_consumerQueue=xc_course, amqp_redelivered=false, id=c194c0f4-559b-a6b3-9a13-a697ee4e1a74, amqp_consumerTag=amq.ctag-OPkBbdXuIUmzyJOtqd3vQw, contentType=application/json, __TypeId__=com.xuecheng.framework.domain.course.CoursePub, timestamp=1646190050549}]
    	at org.springframework.messaging.handler.annotation.support.PayloadArgumentResolver.resolveArgument(PayloadArgumentResolver.java:144)
    	at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:116)
    	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:137)
    	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:109)
    	at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:51)
    	at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:182)
    	... 10 common frames omitted

#### 解决方法： ####

在请求数据时会有数据格式转换，只需要添加以下片段就可以解决

@Configuration
    public class RabbitConfig {
    
        // 自定义 json 格式发送消息
        @Bean
        public MessageConverter messageConverter(){
            return new Jackson2JsonMessageConverter();
        }
    }