spring integration dsl配置幂等接收器识别重复

Question

我在使用队列中的消息时使用 DUPS_OK_ACKNOWLEDGE 模式，我需要检测重复项并忽略它们。

.from(Jms.messageDrivenChannelAdapter(activeMQConnectionFactory)
                        .destination(sourceQueue)
                        .configureListenerContainer(spec -> {
                            spec.sessionTransacted(false);
                            spec.sessionAcknowledgeMode(Session.DUPS_OK_ACKNOWLEDGE);
                        }))
                .transform(orderTransformer)
                .handle(orderService, "save")
                .get();

我有一个幂等接收器建议。

@Bean
public IdempotentReceiverInterceptor idempotentReceiverInterceptor() {
    IdempotentReceiverInterceptor idempotentReceiverInterceptor = new IdempotentReceiverInterceptor(new MetadataStoreSelector(m ->
            (String) m.getHeaders().get("JMSMessageId")));
    idempotentReceiverInterceptor.setDiscardChannelName("ignoreDuplicates");
    idempotentReceiverInterceptor.setThrowExceptionOnRejection(false);
    return idempotentReceiverInterceptor;
}

我被两件事困住了

1. 如何在 Jms.messageDrivenChannelAdapter？
2. 如果我需要将元数据存储在 oracle/mysql 中，该表与任何示例链接的外观如何

Answer 1

Idempotent Receiver 绝对是 consumer 的问题，而不是 producer 的问题，即Jms.messageDrivenChannelAdapter()。当然是在 Spring Integration 方面。

如果您不想将重复项传递给下游，则需要在Jms.messageDrivenChannelAdapter() 之后在消费者上配置这样的Advice。在您的情况下，它是.transform(orderTransformer)。因此，代码可能如下所示：

.transform(orderTransformer, e -> e.advice(idempotentReceiverInterceptor()))

oracle/mysql MetadataStore 在这里 - JdbcMetadataStore 自 5.0: https://docs.spring.io/spring-integration/docs/5.0.5.RELEASE/reference/html/jdbc.html#jdbc-metadata-store