将消息转换为多个

Question

我正在尝试将单个输入消息转换为多个消息。我有一个带有以下签名的方法：

@Incoming("CH_IN")
@Outgoing("CH_OUT")
Multi<Message<B>> process(Message<A> in) {

}

类A类似于：

class A {
    private List<String> ids

    // getters and setters
}

对于A中的每个id，我想创建一个B的实例。我如何做到这一点并处理消息中的的确认？

这是对我所拥有的东西的简化，但我不确定这是否是正确的方式：

@Incoming("CH_IN")
@Outgoing("CH_OUT")
Multi<Message<B>> process(Message<A> in) {
    List<Message<B>> out = new ArrayList<>();

    // Code to iterate ids and create instances of Message<B>
    // In certain cases the out list will be empty

    return Multi.createFrom().iterable(out).on().completion(in::ack);
}

这是确认信息的正确方式吗？




Answer 1

匿名用户

这是一个简化我所拥有的但我不确定这是否是正确的做法

只要你的评论处理部分不需要任何阻塞调用，它就可以工作，但它不是理想的IMHO：

• 文体上，混合命令式

相反，我主张：

return Multi.createFrom().item(in)
        .flatMap(m -> Uni.createFrom().item(m).repeat().atMost(5)) //Replace with your actual processing
        .on().completion(in::ack);

...它将整个方法保持为一个反应链，并使您能够在需要时将平映射（）传递给其他发布者（例如，如果您的处理需要Web调用、数据库调用或其他阻塞IO）。

这是确认信息的正确方式吗？

只要你只想在处理完成后确认，是的。

唯一的缺点是，如果灾难性故障发生在处理过程的一半，可以想象，在确认中的之前可以处理一些故障。唯一其他明智的行为是使用on（）。subscribed（），这只会产生相反的问题（中的将被确认，但部分或所有消息可能不会发布到您的传出频道。）哪个更可取取决于您的用例。