java - 如何将 JSON 消息从 RabbitMQ 转换为 Java 对象？

Question

我有两个独立的 Java 应用程序，我需要使用 spring-rabbit 通过 RabbitMQ 在它们之间发送消息。在作为生产者的应用程序中，我JsonMessageConverter用作消息转换器，以便RabbitTemplate在将 Java 对象发送到队列之前将它们转换为 JSON 消息。

在作为消费者的另一个应用程序中，我想将 JSON 消息转换回 Java 对象。我尝试使用SimpleMessageListenerContainer自定义MessageListener，我可以Message从队列中获取 s，但我不知道将它们从 JSON 转换回 Java 对象。

JsonMessageConverter从 RabbitMQ 异步消费消息时如何使用？

Answer 1

我最终将 aMessageListenerAdapter与自定义委托对象一起使用JsonMessageConverter，并将MessageConverter. 像这样：

SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();
listenerContainer.setMessageListener(new MessageListenerAdapter(new EventHandler(), new JsonMessageConverter()));

我的EventHandler类有一个名为 handleMessage 的方法，它获取传递给它的反序列化 JSON 对象。