春云流用RabbitMQ绑定器，如何应用@transactional？

Question

@Transactional
@StreamListener(MySink.SINK_NAME)
public void processEvents(Flux<Event> events) {
       // Transform events and store them in MongoDB using 
       // spring-boot-data-mongodb-reactive
       ...
}

假设我希望实现与在spring-amqp函数周围使用@transaction时基本相同的功能：

1. 在Rabbit绑定器中使用Spring Cloud Stream时，是否必须手动将消息访问到RabbitMQ？
2. 如果是，如何实现？

Answer 1

这里有几个问题。

1. 确认邮件不需要事务
2. 基于Reactor的@StreamListener方法只调用一次，只是为了设置flux，所以该方法的@transactional是没有意义的-消息会流经flux，因此与单个消息有关的任何事情都必须在flux的上下文中完成。
3. Spring事务绑定到线程-反应器是非阻塞的；消息将在第一次切换时被发送。

是的，你需要使用手动工具；大概是基于mongodb存储操作的结果。您可能需要使用flux > ，以便能够访问通道和传递标记头。