Reactor 和 Spring 是否可以通过事件类型（或事件参数类型）进行选择？

Question

我想使用类似的 Reactor：

reactor.notify(new CreatedEvent<A>(a));
reactor.notify(new CreatedEvent<B>(b));

我的活动在哪里：

public class CreatedEvent<E> extends Event<E> {
    public CreatedEvent(E data) {
        super(data);
    }
}

然后像这样消费那些事件：

reactor.on(new Consumer<CreatedEvent<A>>() {
    @Override
    public void accept(CreatedEvent<A> t) {
        /* do something with a */
    }
});

reactor.on(new Consumer<CreatedEvent<B>>() {
    @Override
    public void accept(CreatedEvent<B> t) {
        /* do something with b */
    }
});

但我收到了两个消费者的两个事件。

如果我使用选择器，它会起作用，即：

reactor.notify("created.a", Event.wrap(a));

reactor.on(Selectors.$("created.a"), new Consumer<Event<A>>() {
    @Override
    public void accept(Event<A> t) {
        /* do something with a */
    }
});

但是使用选择器我将不得不编写和维护非常多的字符串。

都是关于使用选择器的吗？或者我可以以某种方式“按参数化类类型选择”？

Answer 1

但我收到了两个消费者的两个事件。

没错。因为您将两个事件都发送到同一个reactor 只是发送到defaultKey。 并将consumers 订阅到defaultSelector。 在这种情况下，您使用哪种类型的Event 没有价值：默认情况下它们都将被调度Selector 策略。

我认为你需要使用ClassSelector:

reactor.notify(a);
reactor.notify(b);

reactor.on(Selectors.T(A.class), new Consumer<Event<A>>() {});
reactor.on(Selectors.T(B.class), new Consumer<Event<B>>() {});

当然，您必须为每个class-consumer 键入Selectors.T，但它比ObjectSelector 和自定义Event 更简单。

更新

如何注入custom consumer filter：

Reactors.reactor()
            .eventFilter(new GenericResolverFilter())
            .get()

如何解决来自consumerKey 对象的通用参数以及来自List<T> items 的每个Consumer 取决于您。无论如何，您应该在这里考虑一些缓存，以允许 Reactor 继续为 reactive。