java - 使用 Spring 和 Hibernate 在 Multi-Tenancy 环境中访问数据的策略

Question

我在一个 Multi-Tenancy 环境中工作，在该环境中，可以使用 Web 应用程序(休息)前端从大约 10 个不同的数据源(和实体管理器)访问数据。

要使用的 entitymanager 取决于 rest api 中的 URL 参数，例如。 api/订单/1/1000003.

我需要使用 entitymanager "1"来获取数据。目前，在创建 hibernate session 并通过 hibernate 条件创建查询之前，我在调用 setDistrict(1) 的存储库层中使用了一个方法。

一切正常，但我担心该方法需要同步以避免从错误的实体管理器获取数据。 当我同步存储库方法时，我担心性能会很差..

实现这种 Multi-Tenancy 访问的好策略是什么，以便性能良好并且在重负载下也能返回正确的数据？

感谢您的建议。

Answer 1

Hibernate 的 SessionFactory 允许使用 tenancy behavior :

• SCHEMA Correlates to the separate schema approach. It is an error to attempt to open a session without a tenant identifier using this strategy. Additionally, a org.hibernate.service.jdbc.connections.spi.MultiTenantConnectionProvider must be specified.

• DATABASE Correlates to the separate database approach. It is an error to attempt to open a session without a tenant identifier using this strategy. Additionally, a org.hibernate.service.jdbc.connections.spi.MultiTenantConnectionProvider must be specified.

• DISCRIMINATOR Correlates to the partitioned (discriminator) approach. It is an error to attempt to open a session without a tenant identifier using this strategy. This strategy is not yet implemented in Hibernate as of 4.0 and 4.1. Its support is planned for 5.0.

在您的情况下，我认为您需要SCHEMA 或DATABASE 并且必须实现MultiTenantConnectionProvider ( source )。

/**
 * Simplisitc implementation for illustration purposes supporting 2 hard coded providers (pools) and leveraging
 * the support class {@link org.hibernate.service.jdbc.connections.spi.AbstractMultiTenantConnectionProvider}
 */
public class MultiTenantConnectionProviderImpl extends AbstractMultiTenantConnectionProvider {
    private final ConnectionProvider acmeProvider = ConnectionProviderUtils.buildConnectionProvider( "acme" );
    private final ConnectionProvider jbossProvider = ConnectionProviderUtils.buildConnectionProvider( "jboss" );

    @Override
    protected ConnectionProvider getAnyConnectionProvider() {
        return acmeProvider;
    }

    @Override
    protected ConnectionProvider selectConnectionProvider(String tenantIdentifier) {
        if ( "acme".equals( tenantIdentifier ) ) {
            return acmeProvider;
        }
        else if ( "jboss".equals( tenantIdentifier ) ) {
            return jbossProvider;
        }
        throw new HibernateException( "Unknown tenant identifier" );
    }
}

有关详细信息，请参阅链接的文档。