我们在项目中是有两个Redis源,有两个Redis Bean如下:
Bean1:dataRedisTemplate
@Bean(name = "dataRedisTemplate")
public RedisTemplate dataRedisTemplate() {
RedisTemplate template = new RedisTemplate();
template.setConnectionFactory(sessionLettuceConnectionFactory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(jackson2JsonRedisSerializer);
template.setHashKeySerializer(jackson2JsonRedisSerializer);
template.setHashValueSerializer(new StringRedisSerializer());
template.afterPropertiesSet();
return template;
}
// factory
@Resource
@Qualifier(value = "sessionLettuceConnectionFactory")
private RedisConnectionFactory sessionLettuceConnectionFactory;
// clusterNodes
@Value("${spring.session-redis.cluster.nodes}")
private String clusterNodes;
Bean2:redisTemplate
@Primary
@Bean(name = "redisTemplate")
public RedisTemplate<String, Object> redisTemplate() {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(lettuceConnectionFactory);
redisTemplate.setKeySerializer(new StringRedisSerializer());
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(new StringRedisSerializer());
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
// factory
@Resource
@Qualifier(value = "lettuceConnectionFactory")
private RedisConnectionFactory lettuceConnectionFactory;
// clusterNodes
@Value("${spring.redis.cluster.nodes}")
private String clusterNodes;
我在另一个应用中把数据放入到Bean2 redisTemplate对应的Redis中,于是我在这个应用中使用方式如下:
@Autowired
private RedisTemplate dataRedisTemplate;
// 根据key获取数据
Object obj = dataRedisTemplate.opsForValue().get(key);
最后结果是,我明明在key里面存放了数据(进入Redis客户端通过命令确定有这个key及数据),但是我在这里就是获取不到,obj一直为空。 一开始以为是key和value序列号的问题,通过排查确定不是这个问题。 最后发现Redis数据源调用不对导致的,也就是说我希望是使用dataRedisTemplate,实际上是一直在使用redisTemplate。 先说答案,我后面把@Autowired换成@Resource 注解解决了这个问题,即:
@Autowired
private RedisTemplate dataRedisTemplate;
换成》》》》
@Resource
private RedisTemplate dataRedisTemplate;
@Autowired和@Resource最大的区别就是:@Autowired 按 byType 自动注入,而 @Resource 则默认按 byName 自动注入。
这里还需要注意一个注解@Primary
,官方的说明如下:
Indicates that a bean should be given preference when multiple candidates are qualified to autowire a single-valued dependency. If exactly one 'primary' bean exists among the candidates, it will be the autowired value. @Primary 优先方案,被注解的实现,优先被注入
@Primary
其实我们可以自己写一个单侧来试试:
@RunWith(SpringRunner.class)
@SpringBootTest(classes=FotaOptionApplication.class)
public class TokenUtilTest {
@Resource
//@Autowired
private RedisTemplate dataRedisTemplate;
@Test
public void test(){
System.out.println(dataRedisTemplate.getClass().toString());
}
}
通常情况下@Autowired是通过byType的方法注入的,可是在多个实现类的时候,byType的方式不再是唯一,而需要通过byName的方式来注入,而这个name默认就是根据变量名来的。
也就是说,如果没有在redisTemplate()
上面增加@Primary
的话是没有问题的,因为有多个实现时,@Autowired是会通过byName的方式来注入的,但是按照上面说的,因为有了@Primary
,@Autowired
注解会优先使用Bean redisTemplate。
@Primary
@Bean(name = "redisTemplate")
public RedisTemplate<String, Object> redisTemplate() {
}
解决方案可以是把@Autowired
换成@Resource
,如下:
@Autowired
private RedisTemplate dataRedisTemplate;
换成》》》》
@Resource
private RedisTemplate dataRedisTemplate;
也可以是增加@Qualifier(value = "dataRedisTemplate")
,如下:
@Autowired
private RedisTemplate dataRedisTemplate;
换成》》》》
@Autowired
@Qualifier(value = "dataRedisTemplate")
private RedisTemplate dataRedisTemplate;
最后,祝大家都能好好看书,不要学我。