3

我在我的 spring-boot 1.4 应用程序上使用 spring-data-redis。我有两个不同的 CrudRepositories。但是,我很难将它们与各自的 Connection 工厂联系起来。

底线是:我希望 PersonRedisRepository 使用 db #6 和 OtherPurposeRedisRepository 使用 db #3。老实说,我不能 100% 确定我处理此事的方式是否正确。


存储库

interface PersonRedisRepository extends CrudRepository<Person, String> {

}

interface OtherPurposeRedisRepository extends CrudRepository<OtherPurpose, String> {

}

人员存储库的配置

@EnableRedisRepositories(basePackageClasses = [PersonRedisRepository.class], redisTemplateRef = "personRedisTemplate")
class RedisConfigurationForPerson {

@Bean(name = "personFactory")
public RedisConnectionFactory personJedisConnectionFactory() {
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory()
    jedisConnectionFactory.usePool = true
    jedisConnectionFactory.hostName = "127.0.0.1"
    jedisConnectionFactory.database = 6

    return jedisConnectionFactory
}

@Bean(name = "personRedisTemplate")
public RedisTemplate<byte[], byte[]> availabilityCacheRedisTemplate() {
    RedisTemplate<byte[], byte[]> template = new RedisTemplate<byte[], byte[]>()
    template.setConnectionFactory(personJedisConnectionFactory())

    template
}
}

其他用途存储库的配置

@EnableRedisRepositories(basePackageClasses = [OtherPurpsoseRepository.class], redisTemplateRef = "otherPurposeRedisTemplate")
class RedisConfigurationForOtherPurpose {

@Bean(name = "otherPurposeFactory")
public RedisConnectionFactory otherPurposeJedisConnectionFactory() {
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory()
    jedisConnectionFactory.usePool = true
    jedisConnectionFactory.hostName = "127.0.0.1"
    jedisConnectionFactory.database = 3

    return jedisConnectionFactory
}

@Bean(name = "otherPurposeRedisTemplate")
public RedisTemplate<byte[], byte[]> otherPurposeRedisTemplate() {
    RedisTemplate<byte[], byte[]> template = new RedisTemplate<byte[], byte[]>()
    template.setConnectionFactory(otherPurposeJedisConnectionFactory())

    template
}
}

一切正常,我可以使用两个存储库进行读/写。但是,它们都在 db 6 上读/写。

4

1 回答 1

2

另一个人和你有同样的问题。即使这些示例是针对 jpa 存储库的,这些链接也应该对您有所帮助:

Spring Boot 配置和使用两个数据源

http://www.baeldung.com/spring-data-jpa-multiple-databases

您必须首先将配置数据源与 @Primay 注释绑定并指定您正在处理的数据源。这是第一部分。我已经快速浏览了第二部分,稍后我会更深入。完成后将更新我的 psot ;)

于 2017-04-11T08:18:08.630 回答