调用@PostPersist 时数据未保存在数据库中

Question

在数据库中创建对象后，我需要向其他微服务发送请求。我只发送对象 ID，因此其他微服务需要再次调用 db 以获取包含其他内容的信息。

但是，当其他微服务尝试使用接收到的 id 查找记录时，它无法在数据库中找到保存的记录。

即使@postPersist 被调用，我尝试调试似乎也不会保留记录。 它会在@PostPersist 被执行后保存。

有没有人可以为此提供解决方法。我真的需要再次查询数据库，因为这是自定义要求。我使用mysql和spring boot

public class EmployeeListener {

    @PostPersist
    public void sendData(Employee employee){
        Long id = employee.getEmployeeId();
        RestTemplate restTemplate = new RestTemplate();
        restTemplate.exchange("http://localhost:8081/service/employee"+id, HttpMethod.POST, null, String.class);

    }

}


@Entity
@EntityListeners(EmployeeListener.class)
public class Employee {
       //
}

Answer 1

问题在于 JPA 生命周期事件发生在与您的保存操作相同的事务中，但查找，因为它发生在不同的服务器上，必须仅在您的事务关闭后发生。

因此，我推荐以下设置：在Collection 中收集需要通知的 id，然后在事务完成时发送数据。

如果您想在一种方法中进行发送操作和保存操作，[TransactionTemplate][1] 可能比通过注释进行事务管理更好用。

您也可以考虑Domain Events。请注意，它们仅在实际调用 save 时触发。这些事件的好处是它们使用ApplicationEventPublisher 发布，其中侦听器是 Spring Bean，因此您可以注入任何您认为有帮助的 bean。他们仍然需要一种方法来打破如上所述的交易

Answer 2

@PostPersist 注解的方法在同一个事务中被调用，并且默认的 flash 模式是 AUTO，这就是你在数据库中看不到记录的原因。您需要强制刷新：

@Component
public class EmployeeListener {

    @PersistenceContext
    private EntityManager entityManager;

    @PostPersist
    public void sendData(Employee employee){
        // Send it to database
        entityManager.flush();
        Long id = employee.getEmployeeId();
        RestTemplate restTemplate = new RestTemplate();
        restTemplate.exchange("http://localhost:8081/service/employee"+id, HttpMethod.POST, null, String.class);

    }

}

注意EmployeeListener 需要是 Spring 托管的 bean。