Spring AMQP 错误:无法对传入消息调用侦听器方法

Question

我有类：

public class MqMessage implements Serializable{
private String event;
private String absolutePath;
private boolean isDirectory;
private Integer hash;
private Node node;
get/set
}

配置类： 公共类兔子配置 {

@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory =
new CachingConnectionFactory("localhost");
return connectionFactory;
}
@Bean
public AmqpAdmin amqpAdmin() {
return new RabbitAdmin(connectionFactory());
}
@Bean
public RabbitTemplate rabbitTemplate() {
RabbitTemplate template = new RabbitTemplate(connectionFactory());
template.setExchange("exchange-events");
return template;
}
//объявляем очередь
@Bean
public Queue myQueue1() {
return new Queue("queue-events");
}
@Bean
public FanoutExchange fanoutExchangeA() {
return new FanoutExchange("exchange-events");
}
@Bean
public Binding binding1() {
return BindingBuilder.bind(myQueue1()).to(fanoutExchangeA());
}

发送消息

public class ServerHandler implements EventHandler {
//сама структура отражающая состояние файлов, содеражащая метоы для работы с ними
@Autowired
Node fileTreeRoot;
SimpleMessageConverter simpleMessageConverter;
@Override
public void setRoot(Node fileTreeRoot) {
this.fileTreeRoot = fileTreeRoot;
}
@Autowired
RabbitTemplate rabbitTemplate;
//логика обработки событий
@Override
public void eventHandle(String event, String path) {
/*bussines-logick
*/
rabbitTemplate.setExchange("exchange-events");
rabbitTemplate.convertAndSend(new MqMessage(event,fileTreeRoot));
return;
}
public ServerHandler() {
}

听者：

public class Client {
Node rootNodeClient = new Node();
EventHandler handlerClient = new ClientHandler();

@RabbitListener(queues = "queue-events")
public void onMessage(MqMessage message) {
System.out.println(message.getNode().hashCode());
rootNodeClient = message.getNode();
}

A 只有错误启动应用

2017-08-08 12：58：02.128 警告 5024 --- [cTaskExecutor-1] s.a.r.l.ConditionalRejectingErrorHandler ： 执行兔子消息 侦听器失败。

org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException： 无法对传入消息调用侦听器方法

引起： org.springframework.messaging.handler.annotation.support.MethodArgumentNotValidException： 无法解析公共无效中索引 0 处的方法参数 prcjt.client.Client.onMessage(prcjt.message.MqMessage(： 1 错误： [对象"消息"中的错误：代码 [];参数 [];默认消息 [有效负载值不得为空]]

错误并不总是存在 请帮忙

Answer 1

使用mappingJackson2MessageConverted对我不起作用。经过大量调查，发现我使用了错误的转换器。在侦听器服务中添加以下代码，它对我有用。

@Bean
public Jackson2JsonMessageConverter converter() {
return new Jackson2JsonMessageConverter();
}

Answer 2

Caused by: org.springframework.messaging.handler.annotation.support.MethodArgumentNotValidException: Could not resolve method parameter at index 0

从异常信息来看，Spring 似乎无法正确解析侦听器中的MqMessage，您可以尝试向客户端添加mappingJackson2MessageConverter。请参阅此链接。

Answer 3

我遇到这个问题有几个原因：

1. 不使用"实现可序列化"(我看到您已经在使用(

2. 模型类中没有构造函数。(使用空构造函数(

   public ClassToGetQData() {
   super();
   // TODO Auto-generated constructor stub
   }
   

此外，使用@JsonIgnoreProperties(ignoreUnknown = true)帮助我解决了传入数据中缺少的数据元素的问题。