我正在使用 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。
有人可以帮帮我吗?
最佳答案
为了实现 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);
}
我希望这会有所帮助!
关于具有 Multi-Tenancy 的 Spring Data Redis,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51545572/