使用自定义ApplicationEventPublisher发送Spring域事件

Question

我试图使用Spring Boot/Spring数据，遵循DDD体系结构准则来实现一个应用程序。我有一个聚合根，它使用方法AbstractAggregateRoot：：RegisterEvent（）发布域事件。此外，为了日志/跟踪的目的，我需要截获这些事件，所以我决定做一个实验：

首先，实现自定义ApplicationEvent发布服务器

public class CustomEventPublisher implements ApplicationEventPublisher {
    private final ApplicationEventPublisher publisher;

    private final Logger logger = getLogger(CustomEventPublisher.class);

    public CustomEventPublisher(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    @Override
    public void publishEvent(ApplicationEvent event) {
        logger.info("sending an event...");
        publisher.publishEvent(event);
    }

    //.....
}

然后注册为bean

@Configuration
public class CustomEventPublisherConfig {

    @Bean
    @Primary
    public ApplicationEventPublisher getCustomEventPublisher(ApplicationEventPublisher publisher , RabbitTemplate rabbitTemplate) {
        return new CustomEventPublisher(publisher, rabbitTemplate);
    }
}

一旦我用注入的ApplicationEventPublisher显式发布来自某个示例对象的事件，这就很好了

public void pub() {
    publisher.publishEvent(new Event(this , 1));
}

@EventListener
public void sub(Event e) {
    this.value = e.getValue();
}

我收到了“发送一个活动...”日志条目

然后我尝试定义聚合根

@Entity
public class AggregateRoot extends AbstractAggregateRoot {

    @Id
    @GeneratedValue
    private Long id;

    private int value = 0;

    public AggregateRoot setValue(int value) {
        registerEvent(new Event(this , value));
        return this;
    }
}

public void pub() {
    repository.save(new AggregateRoot().setValue(1));
}

有什么克服这个问题的建议吗？

提前致谢

Answer 1

据我所知，Spring没有提供替换EventPublishingRepositoryProxyPostProcessor使用的发布服务器的方法。在我看来，你没有选择一条正确的道路来获得你想要实现的目标，所以我不是直接回答你的问题，而是在开始时描述的你的要求。

我建议您使用@eventlistener注册一个侦听器，并在那里处理您的事件：

@EventListener
public void handleEvent(Event event) {
    System.out.println(event);
}

也可以使用@TransactionalEventListener将侦听器绑定到事务阶段：

@TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
public void handleEvent(Event event) {
    System.out.println(event);
}