使用 Spring JpaTransactionManager 时，Eclipse Link 中未处理并发

Question

我们正在使用多租户事务管理器，如上文所述，注册日期：2014 年 11 月。我们正在使用 Spring Data，并且我们正在根据用户 ID 和密码识别租户，即我们首先不知道租户。该应用程序运行良好。我们正在使用带有基本身份验证的弹簧安全性。并且应用程序通过 Rest API 公开。

当并发的不同租户同时使用事务管理器时会出现问题。我们使用 TenantResolver 类来查找租户

我们还有另外 2 个消息流，每分钟大约有 40 条消息和 10 条消息，它们使用连接管理器来查找租户并基于此执行事务。

这里的日志：

MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> ACTUAL_TENANT : vce 07:51:05,720 信息 [xxx.integration.jms.VehicleRepositoryListener] (vrMessageListenerContainer-1) [] VehicleRepositoryListener.onMessage()--> 处理成功 在 VehicleRepositoryListener 07:51:05,768 错误中完成 [xxx.integration.services.utils.TenantUtils] (vrMessageListenerContainer-1) [] TenantUtils.setTenantByProductClass -> 设置租户 org.springframework.orm.jpa.JpaSystemException 时出错：异常 [EclipseLink-28013]（Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）：org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：无法部署 PersistenceUnit [default] in 无效状态 [DeployFailed]。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28019] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：PersistenceUnit [默认] 的部署失败。 关闭此 PersistenceUnit 的所有工厂。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28009] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：试图重新部署一个名为 /file:/opt/jboss64/modules/system/layers/base/org/jboss/as/ejb3/main/timers/_default 不关闭它。嵌套异常是 javax.persistence.PersistenceException：异常 [EclipseLink-28013] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：无法部署 PersistenceUnit [default] in 无效状态 [DeployFailed]。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28019] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：PersistenceUnit [默认] 的部署失败。 关闭此 PersistenceUnit 的所有工厂。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28009] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：试图重新部署一个名为 /file:/opt/jboss64/modules/system/layers/base/org/jboss/as/ejb3/main/timers/_default 没有关闭它。 07:51:05,774 信息 [xxxintegration.services.XXXUpdateRequestProcessServiceImpl] (xxxMessageListenerContainer-1) [] 返回自 XXXUpdateRequestProcessServiceImpl.login() 07:51:05,775 信息 [xxx.integration.services.XXXUpdateRequestProcessServiceImpl] (xxxMessageListenerContainer-1) [] XXXUpdateRequestProcessServiceImpl.getUpdateTechToolResponseDTOs()-> 服务中的令牌：b3b00ab6-5c36-45af-8ec2-0b6f1710e888 07:51:05,777 信息 [xxx.integration.services.VehicleRepositoryService] (vrMessageListenerContainer-1) [] VehicleRepositoryService.parseVehicleRepositoryUpdate()-> 租户是 空 07:51:05,780 信息 [xxx.integration.jms.VehicleRepositoryListener] (vrMessageListenerContainer-1) [] VehicleRepositoryListener.onMessage()--> 处理成功 在 VehicleRepositoryListener 07:51:06,138 INFO 中完成 [xxx.application.VehicleActivationService] (http-/0.0.0.0:16780-71) [] VehicleActivationService.checkActivation() 内部 07:51:06,141 信息 [xxx.application.VehicleActivationService] (http-/0.0.0.0:16780-71) [] VehicleActivationService.getTenant() 内部 07:51:06,145 错误 [xxx.integration.rest.UpdateTechTool] (http-/0.0.0.0:16780-71) [] 检查激活方法中的异常：无法打开 JPA EntityManager 用于事务；嵌套异常是 javax.persistence.PersistenceException：异常 [EclipseLink-28013] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：无法部署 PersistenceUnit [default] in 无效状态 [DeployFailed]。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28019] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：PersistenceUnit [默认] 的部署失败。 关闭此 PersistenceUnit 的所有工厂。内部异常： javax.persistence.PersistenceException：异常 [EclipseLink-28009] （Eclipse 持久性服务 - 2.6.0.v20150309-bf26070）： org.eclipse.persistence.exceptions.EntityManagerSetupException 异常描述：试图重新部署一个名为 /file:/opt/jboss64/modules/system/layers/base/org/jboss/as/ejb3/main/timers/_default 没有关闭它。 07:51:06,148 信息 [xxx.application.XXXUpdateTechToolDTOService] (http-/0.0.0.0:16780-71) [] 内部 UpdateTechToolDTOService.update() 07:51:06,154 错误 [xxx.application.XXXUpdateTechToolDTOService] (http-/0.0.0.0:16780-71) [] XXXUpdateTechToolDTOService.update() -> 调用时出现异常 更新：java.lang.NullPointerException 07:51:06,166 信息 [xxx.integration.services.UpdateRequestProcessServiceImpl] (MessageListenerContainer-1) [] 里面 UpdateRequestProcessServiceImpl.createResponse() 07:51:06,883 信息 [stdout] (Finalizer) [] [EL Info]: 连接: 2017-04-17 07:51:06.882--ServerSession(1485077057)--/file:/opt/jboss64/modules/system/layers/base/org/jboss/as/ejb3/main/timers/_default 注销成功 07:51:06,885 INF

处理并发问题的任何帮助或方法。

类似于： EclipseLink - Error: Attempted to redeploy a session without closing it

使用的 MultiTenantJpaTransactionManager 类是：

公共类 MultiTenantJpaTransactionManager 扩展 JpaTransactionManager {

TenantResolver<Tenant> tenantResolver; 
SchemaProvider schemaProvider; 
@Autowired
public void setTenantResolver(TenantResolver<Tenant> tenantResolver) {
    this.tenantResolver = tenantResolver;
}

@Autowired(required = false)
public void setSchemaProvider(SchemaProvider schemaProvider) {
    this.schemaProvider = schemaProvider;
}

@Override
protected synchronized javax.persistence.EntityManager createEntityManagerForTransaction() {
    boolean refreshed = false;
    EntityManager em = super.createEntityManagerForTransaction();
    try {
        LOGGER.info("Entering createEntityManagerforTransaction()");
        if (schemaProvider != null) {
            TenantSessionCustomizer.setSchemaName(schemaProvider.getSchema());
        }
        ServerSession ss = ((EntityManagerImpl) em.getDelegate()).getServerSession();
        Map sessionProp = ss.getProperties();
        String actualTenant = (String) sessionProp.get(PersistenceUnitProperties.MULTITENANT_PROPERTY_DEFAULT);
        LOGGER.info("MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> ACTUAL_TENANT : " + actualTenant);

        if (tenantResolver != null && tenantResolver.getCurrentTenant() != null) {
            LOGGER.info("MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> CURRENT_TENANT : " + tenantResolver.getCurrentTenant());
            if ((actualTenant == null) || (actualTenant != null && !actualTenant.equals(tenantResolver.getCurrentTenant().getHandle()))) {
                sessionProp.put(PersistenceUnitProperties.MULTITENANT_PROPERTY_DEFAULT, tenantResolver.getCurrentTenant().getHandle());
                sessionProp.put(PersistenceUnitProperties.SESSION_CUSTOMIZER, TenantSessionCustomizer.class.getName());
                MetadataRefreshListener mrl = ((EntityManagerImpl) em.getDelegate()).getServerSession().getRefreshMetadataListener();
                if (mrl != null) {
                    Map<String, Object> prop = new HashMap<String, Object>();
                    mrl.triggerMetadataRefresh(prop);
                    refreshed = true;
                    LOGGER.info("createEntityManagerforTransaction()---->Metadata refreshed");
                }
            }
        }
    } catch (Exception ex) {
        LOGGER.error("MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> Exception while creating EntityManagerForTransaction " + ex.getMessage());
    }
    return refreshed ? super.createEntityManagerForTransaction() : em;
}

}

Answer 1

公共类 MultiTenantJpaTransactionManager 扩展 JpaTransactionManager { private static final Logger LOGGER = LoggerFactory.getLogger(MultiTenantJpaTransactionManager.class);

TenantResolver<Tenant> tenantResolver; 
SchemaProvider schemaProvider;

@Autowired
public void setTenantResolver(TenantResolver<Tenant> tenantResolver) {
    this.tenantResolver = tenantResolver;
}

@Autowired(required = false)
public void setSchemaProvider(SchemaProvider schemaProvider) {
    this.schemaProvider = schemaProvider;
}

@Override
protected synchronized javax.persistence.EntityManager createEntityManagerForTransaction() {
    boolean refreshed = false;
    EntityManagerFactory emf = getEntityManagerFactory();
    EntityManager em = super.createEntityManagerForTransaction();
    try {
        LOGGER.info("Entering createEntityManagerforTransaction()");
        if (schemaProvider != null) {
            TenantSessionCustomizer.setSchemaName(schemaProvider.getSchema());
        }
        ServerSession ss = ((EntityManagerImpl) em.getDelegate()).getServerSession();
        Map sessionProp = ss.getProperties();

        if (tenantResolver != null && tenantResolver.getCurrentTenant() != null) {
            sessionProp.put(PersistenceUnitProperties.MULTITENANT_PROPERTY_DEFAULT, tenantResolver.getCurrentTenant().getHandle());

            em = emf.createEntityManager(sessionProp);
        }
    } catch (Exception ex) {
        LOGGER.error("MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> Exception while creating EntityManagerForTransaction " + ex.getMessage());
    }
    return em;
}

}

目前使用上面的代码进行测试似乎已经解决了这个问题。

Answer 2

关注https://www.eclipse.org/eclipselink/documentation/2.5/solutions/multitenancy002.htm

这可能有效：

@Override
protected synchronized javax.persistence.EntityManager createEntityManagerForTransaction() {
    boolean refreshed = false;
    EntityManagerFactory emf = getEntityManagerFactory();
    EntityManager em = null;
    try {
        if (schemaProvider != null) {
            TenantSessionCustomizer.setSchemaName(schemaProvider.getSchema());
        }
        Map tenantProp = new HashMap();

        if (tenantResolver != null && tenantResolver.getCurrentTenant() != null) {
           tenantProp.put(PersistenceUnitProperties.MULTITENANT_PROPERTY_DEFAULT, tenantResolver.getCurrentTenant().getHandle());

             em = emf.createEntityManager(tenantProp);
        }
    } catch (Exception ex) {
        LOGGER.error("MultiTenantJpaTransactionManager.createEntityManagerForTransaction()-> Exception while creating EntityManagerForTransaction " + ex.getMessage());
    }
    return em;
}