具有 Multi-Tenancy 的 Spring Data Redis

Question

我正在使用 Spring Data Redis，其中 spring 数据抽象没有直接使用 RedisTemplate。

我的数据模型如下:

@RedisHash(value = “products")
public class Product {

    @Id
    @Indexed
    private String id;
    private String description;
    private BigDecimal price;
    private String imageUrl;

   //Getter and Setter

}

我的带有 spring 数据抽象的存储库:

@Repository
public interface ProductRepository extends CrudRepository<Product,String> {
}

这是我的配置:

@Configuration
@EnableRedisRepositories(enableKeyspaceEvents = RedisKeyValueAdapter.EnableKeyspaceEvents.ON_STARTUP)
public class RedisConfig {

    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        JedisConnectionFactory jedisConFactory = new JedisConnectionFactory();
        jedisConFactory.setHostName("localhost");
        jedisConFactory.setPort(6379);
        return jedisConFactory;
    }
}

对于单个租户应用程序，我很满意。

现在我想实现一个 Multi-Tenancy 结构。

我认为为每个租户创建一个 Redis 实例是一个很好的解决方案。

我有一个 map ，其中包含专用于该租户的租户 ID 和 Redis 端点。

map 数据如下:

(Key : tenantId1, value: host1:port1) 
(Key : tenantId2, value: host2:port2)
(Key : tenantId3, value: host3:port3)

我脑海中的情景:
租户使用其租户 ID 进入应用程序，并将请求传递给带有租户 ID 的 redisRepository。 保存新产品的示例:productRepository.save(product,tenantId)。

但是无法想象如何实现这个路由。

我想为每个租户创建一个 RedisConnectionFactory。

但是我不知道如何在Spring数据抽象上选择相关的connectionFactory。

有人可以帮帮我吗？

Answer 1

为了实现 Multi-Tenancy 结构，您可以按以下步骤进行:

  @Bean(name = "JedisConnectionFactor" )
  public Map<String, JedisConnectionFactory> JedisConnectionFactor(){
    Map<String, DataSource> factories = new HashMap<>();
    //for (JedisProperties properties :  // better to import jedis config from for each single tenant
      //multiTenantJedisProperties.getListOfProperties()) { 

      JedisConnectionFactory jedisConFactory = new JedisConnectionFactory();
      jedisConFactory.setHostName("localhost");
      jedisConFactory.setPort(6379);
      result.put(jeditProperties.getTenantId(), jedisConFactory)
     // iterate ....
      JedisConnectionFactory jedisConFactory = new JedisConnectionFactory();
      jedisConFactory.setHostName("localhost");
      jedisConFactory.setPort(6379);
      result.put(jeditProperties.getTenantId(), jedisConFactory);
     // n times

    }
    return factories;
  }

你可以使用 Autowiring 工厂 map

@Autowired
   private Map<String, JedisConnectionFactory> JedisConnectionFactories;

   @Autowire
   protected DataSource selectJedisConnectionFactory(String tenantId) {
     return this.JedisConnectionFactories.get(tenantId);
   }

我希望这会有所帮助!