axon 3通过RabbitMQ分离命令和查询服务：json vs.xml

Question

@Bean
RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) {
  final RabbitTemplate rabbitTemplate = new  RabbitTemplate(connectionFactory);
  rabbitTemplate.setMessageConverter(converter);
  return rabbitTemplate;
}

@Bean
Jackson2JsonMessageConverter producerJackson2MessageConverter() {
  return new Jackson2JsonMessageConverter();
}

这是有效的，当我将命令发送到命令服务时，我可以检查RabbitMQ队列中正确的JSON格式。

我的聚合接收命令和触发器事件，它们正确地存储在mySQL-EventStore中。在这里，事件是xml格式的。

现在来了棘手的部分。我使用axon-springboot通过属性再次将事件发送到rabbit队列：

axon.amqp.exchange: my-event-exchange

@Bean
public SpringAMQPMessageSource myMessageSource(Serializer serializer, EventHandlingConfiguration ehConfig) {
   return new SpringAMQPMessageSource(serializer) {
      @RabbitListener(queues = "my-event-queue")
      @Override
      public void onMessage(Message message, Channel channel) throws Exception {
           log.info("receiving event: {}#{}", message, channel);
           super.onMessage(message, channel);
      }
    };
   }

   @Autowired
   public void configure(EventHandlingConfiguration ehConfig, SpringAMQPMessageSource myMessageSource) {
     ehConfig.registerSubscribingEventProcessor(
          "taskQueryObjectUpdater", c -> myMessageSource);
   }

2017-06-16 15:17:38.168  WARN 69212 --- [cTaskExecutor-1] o.s.a.s.c.Jackson2JsonMessageConverter   : Could not convert incoming message with content-type [null]

警告，并且从未调用我的h2-repository-service。

我担心我为rabbit配置的json转换器和axon中的xml事件处理会干扰...或者我走错路了？如何通过rabbit正确地分离命令和查询服务，以及eventProcessor的名称有什么用处？我使用了处理eventstream的spring bean的bean名称...

Answer 1

您的配置中的两种方法似乎相互冲突。自动配置使用没有特定类型的bean来定义默认值。但是，如果您定义了一个预期类型的bean（即使用于不同的目的），那么该bean将被使用。

Axon使用Spring的AMQP自动配置来读取消息。如果您指定要以特定的方式转换消息，那么Axon也将间接地使用该方式。

解决办法可以是不将Jackson2JsonMessageConverter定义为bean。我怀疑MessageListenerContainer（Spring用来调用@RabbitListener方法）是否使用RabbitTemplate，但我几乎可以肯定它将使用应用程序上下文中定义的任何MessageConverter。