解决org.springframework.amqp.AmqpException: No method found for class [B

spring-boot在集成rabbitmq时，如果使用 amqp-client 发送消息，@RabbitListener会一直循环报错

org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener method 'no match' threw exceptionat org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:198) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:127) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1521) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1444) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1431) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1410) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:848) [spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:832) [spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$700(SimpleMessageListenerContainer.java:78) [spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1073) [spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at java.lang.Thread.run(Thread.java:748) [na:1.8.0_152]
Caused by: org.springframework.amqp.AmqpException: No method found for class [Bat org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler.getHandlerForPayload(DelegatingInvocableHandler.java:149) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler.invoke(DelegatingInvocableHandler.java:129) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:60) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:190) ~[spring-rabbit-2.1.2.RELEASE.jar:2.1.2.RELEASE]... 10 common frames omitted

通过debug发现：

rabbitTemplate.convertAndSend发送的消息默认带有消息头

而amqp-client发送的消息默认是不带消息头的

所以第一种解决办法是在rabbitmq的客户端设置响应的属性

@Testpublic void publishTest() throws IOException {channel.exchangeDeclare("testExchange", "direct", true);channel.queueBind("many", "testExchange", "many");String message = "this is the test";AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder().contentEncoding("UTF-8").contentType("text/plain").headers(new HashMap<String, Object>()).priority(0);channel.basicPublish("testExchange", "many",builder.build(), message.getBytes());}

测试发现问题好像是因为缺少contentType("text/plain")导致的

另外一种解决办法是在 @RabbitListener 增加一些配置

There are two conversions in the @RabbitListener pipeline.
The first converts from a Spring AMQP Message to a spring-messaging Message.
There is currently no way to change the first converter from SimpleMessageConverter which handles String, Serializable and passes everything else as byte[].
The second converter converts the message payload to the method parameter type (if necessary).
With method-level @RabbitListeners there is a tight binding between the handler and the method.
With class-level @RabbitListener s, the message payload from the first conversion is used to select which method to invoke. Only then, is the argument conversion attempted.
This mechanism works fine with Java Serializable objects since the payload has already been converted before the method is selected.
However, with JSON, the first conversion returns a byte[] and hence we find no matching @RabbitHandler.
We need a mechanism such that the first converter is settable so that the payload is converted early enough in the pipeline to select the appropriate handler method.
A ContentTypeDelegatingMessageConverter is probably most appropriate.
And, as stated in AMQP-574, we need to clearly document the conversion needs for a @RabbitListener, especially when using JSON or a custom conversion.

@Configuration
public class RabbitConfig {@Beanpublic RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {RabbitTemplate template = new RabbitTemplate(connectionFactory);template.setMessageConverter(new Jackson2JsonMessageConverter());return template;}@Beanpublic SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);factory.setMessageConverter(new Jackson2JsonMessageConverter());return factory;}
}

@Component
public class ReceiverTwo {@RabbitHandler@RabbitListener(queues = "test", containerFactory="rabbitListenerContainerFactory")public void process(String message) {System.out.println("Receiver: " + message);}
}

配置的@RabbitListeners一定要放在method-level上，否则不生效

当然，这样配置方式并不能保证Consumer端能接收到Message，所以最正确的做法是Producer端配置contentType("text/plain")，既能保证消息发送出去也能保证消息被接收。

Producer的BasicProperties配置选项如下：

解决org.springframework.amqp.AmqpException: No method found for class [B相关推荐

Caused by: org.springframework.amqp.AmqpException: No method found for class [B
前言 spring boot 2.2.13.RELEASE 错误内容:Caused by: org.springframework.amqp.AmqpException: No method foun ...
org.springframework.amqp.AmqpException: No method found for class [B
版本:spring-rabbit-1.7.1.RELEASE.jar 错误描述: 调用rabbitTemplate.convertAndSend(exchange, routingKey, objec ...
解决org.springframework.amqp.AmqpIOException: java.io.IOException错误
今天安装好rabiitmq,创建了一个队列,进行测试发现报这个错误 Caused by: org.springframework.amqp.AmqpIOException: java.io.IOExc ...
SpringBoot集成rabbitmq错误:org.springframework.amqp.AmqpConnectException: java.net.ConnectException的解决办法
在集成rabbitmq后,运行项目,报错日志: org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Co ...
org.springframework.amqp.AmqpConnectException java.net.ConnectException的解决办法
一.报错信息 spring cloud集成rabbitmq时报错: org.springframework.amqp.AmqpTimeoutException: java.util.concurren ...
Error creating bean with name 'org.springframework.amqp.rabbit.config.ListenerContainerFactoryBean#0
Spring 整合rabbitmq 出现错误严重: Exception sending context initialized event to listener instance of class ...
RabbitMq org.springframework.amqp.AmqpIOException: java.io.IOException
出现问题 org.springframework.amqp.AmqpIOException: java.io.IOExceptionat org.springframework.amqp.rabbit ...
org.springframework.web.HttpRequestMethodNotSupportedException: Request method 'PUT' not supported
错误描述: org.springframework.web.HttpRequestMethodNotSupportedException: Request method 'PUT' not suppo ...
RabbitMq 本地连接报错 org.springframework.amqp.AmqpIOException: java.io.IOException
前言上一篇博客讲述了ubuntu 16.04上如何安装RabbitMq,并通过web管理界面远程访问. 紧接着我在自己搭建的spring boot项目中,整合了RabbitMq,本地启动项目,发现控 ...

解决org.springframework.amqp.AmqpException: No method found for class [B

解决org.springframework.amqp.AmqpException: No method found for class [B相关推荐

最新文章

热门文章