我有一个由微服务构建的应用程序。 其中一个服务接收数据，通过Spring JPA和Eclipse Link将其持久化，然后向第二个服务发送警报（AMQP）。
基于特定条件，第二个服务随后调用针对持久化数据的RESTful Web服务以检索保存的信息。
我注意到有时RESTful服务返回空数据集，即使数据以前已保存。 查看持久性服务的代码，发现使用了"save"而不是"saveandflush"，因此我认为数据没有被快速刷新到下游服务以进行查询。
我应该说原始持久性函数包含"@Transactional"。
问题的可能预测
我认为这里的问题与save和saveAndFlush无关。问题似乎与Spring @Transactional方法的性质有关，并且在涉及数据库和AMQP代理商的分布式环境中错误地使用了这些事务，或许还加入了一些对JPA上下文如何工作的基本误解。
在你的解释中，你似乎暗示你在@Transactional方法内开始了JPA事务，并在事务期间（但在提交之前），向AMQP代理商发送消息。稍后，在队列的另一侧，消费者应用程序获取消息并进行REST服务调用。此时，您注意到发布方的事务更改尚未提交到数据库，因此对于消费方而言不可见。
问题似乎是您在JPA事务提交到磁盘之前传播了那些AMQP消息。当消费者读取并处理消息时，您发布方的事务可能尚未完成。因此，这些更改对于消费者应用程序不可见。
如果你的AMPQ实现是Rabbit，那么我之前见过这个问题。当你启动一个使用数据库事务管理器的
@Transactional方法，并在该方法中使用RabbitTemplate发送相应消息时，如果你的RabbitTemplate没有使用事务通道（即channelTransacted=true），则你的消息会在数据库事务提交之前被传送。我认为通过在RabbitTemplate中启用事务通道（默认情况下禁用），你可以解决部分问题。<rabbit:template id="rabbitTemplate"
connection-factory="connectionFactory"
channel-transacted="true"/>
RabbitTemplate会“加入”当前数据库事务（显然是JPA事务）。一旦你的JPA事务提交，它会运行一些结尾代码，也会提交Rabbit通道中的更改，这将强制实际地“发送”消息。@Transactional方法结束时（不幸的是，在你已经发送AMQP消息之后的某个时间点——如果你不使用如上所述的交易通道）。@Transactional方法完成。save(entity)时，EntityManager不需要立即同步任何更改。大多数JPA实现将实体标记为脏数据并等待在最后一刻将所有更改与数据库同步，并在数据库级别提交这些更改。EntityManager决定何时进行同步。经典案例是，在数据库表中存在一个触发器，您需要运行它以生成稍后在事务期间需要使用的其他记录。因此，您强制将更改刷新到磁盘，以便强制触发器运行。<bean id="jdbcTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<bean id="rabbitTransactionManager" class="org.springframework.amqp.rabbit.transaction.RabbitTransactionManager">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
<bean id="chainedTransactionManager" class="org.springframework.data.transaction.ChainedTransactionManager">
<constructor-arg name="transactionManagers">
<array>
<ref bean="rabbitTransactionManager"/>
<ref bean="jdbcTransactionManager"/>
</array>
</constructor-arg>
</bean>
@Retry
@Transactional("chainedTransactionManager")
public void myServiceOperation() {
if(workNotDone()) {
doDatabaseTransactionWork();
}
sendMessagesToRabbit();
}