1

我一直在为使用 AMQP 在两个微服务之间设置异步消息传递“铺平道路”。我们希望促进对每个服务使用单独的域对象，这意味着每个服务必须定义自己的跨队列传递的任何对象的副本。

我们Jackson2JsonMessageConverter在生产者和消费者端都使用，并且我们使用 Java DSL 将流连接到队列/从队列连接。

我确信有一种方法可以做到这一点，但它正在逃避我：我希望消费者方忽略__TypeID__从生产者传递的标头，因为消费者可能对该事件有不同的表示形式（而且很可能是在不同的java包中）。

似乎已经完成了一些工作，如果使用注释@RabbitListener，则派生一个inferredArgumentType参数并将覆盖标题信息。这正是我想做的，但我想使用 Java DSL 来做。我还没有找到一种干净的方法来做到这一点，也许我只是错过了一些明显的东西。使用以下 DSL 时派生类型似乎相当简单：

return IntegrationFlows
        .from(
                Amqp.inboundAdapter(factory, queueRemoteTaskStatus())
                        .concurrentConsumers(10)
                        .errorHandler(errorHandler)
                        .messageConverter(messageConverter)
        )
        .channel(channelRemoteTaskStatusIn())
        .handle(listener, "handleRemoteTaskStatus")
        .get();

但是，这会导致ClassNotFound异常。到目前为止，我发现解决此问题的唯一方法是设置自定义消息转换器，这需要明确定义类型。

public class ForcedTypeJsonMessageConverter extends Jackson2JsonMessageConverter {

    ForcedTypeJsonMessageConverter(final Class<?> forcedType) {
        setClassMapper(new ClassMapper() {

            @Override
            public void fromClass(Class<?> clazz, MessageProperties properties) {
                    //this class is only used for inbound marshalling.
            }

            @Override
            public Class<?> toClass(MessageProperties properties) {
                return forcedType;
            }
        });
    }
}

我真的很想得到这个，所以开发人员不必真正处理这个问题。

有没有更简单的方法来做到这一点？

4

1 回答 1

1

最简单的方法是DefaultJackson2JavaTypeMapper用TypeIdMapping( setIdClassMapping()) 配置 Jackson 转换器。

在发送系统上， mapfoo:com.one.Foo和在接收系统上 map foo:com.two.Foo。

然后，__TypeId__获取标头foo，接收系统将其映射到其表示的 a Foo。

编辑

另一种选择是向afterReceiveMessagePostProcessor入站通道适配器的侦听器容器添加一个 - 它可以更改__TypeId__标头。

于 2017-12-22T20:01:51.760 回答