这里有新鲜出炉的 Redis 设计与实现(第一版),程序狗速度看过来!
Redis Key-Value 数据库
Redis 是一个开源的使用 ANSI C 语言编写,支持网络,可基于内存亦可持久化的日志型,Key-Value 数据库,并提供多种语言的 API.
Spring Boot 为 Redis, MongoDB, Elasticsearch, Solr 和 Gemfire 提供自动配置.本文详细介绍了 springboot 配置多个 redis 连接,有兴趣的可以了解一下.
一,springboot nosql 简介
Spring Data 提供其他项目,用来帮你使用各种各样的 NoSQL 技术,包括 MongoDB, Neo4J, Elasticsearch, Solr, Redis,Gemfire, Couchbase 和 Cassandra.Spring Boot 为 Redis, MongoDB, Elasticsearch, Solr 和 Gemfire 提供自动配置.你可以充分利用其他项目,但你需要自己配置它们.
1.1,Redis
Redis 是一个缓存,消息中间件及具有丰富特性的键值存储系统.Spring Boot 为 Jedis 客户端库和由 Spring Data Redis 提供的基于 Jedis 客户端的抽象提供自动配置. spring-boot-starter-redis 'Starter POM'为收集依赖提供一种便利的方式.
Redis 添加 maven 依赖
1.2 连接 Redis
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
<!-- <version>1.3.5.RELEASE</version> -->
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-commons -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-redis</artifactId>
<!-- <version>1.3.6.RELEASE</version> -->
</dependency>
你可以注入一个自动配置的 RedisConnectionFactory,StringRedisTemplate 或普通的跟其他 Spring Bean 相同的 RedisTemplate 实例.默认情况下,这个实例将尝试使用 localhost:6379 连接 Redis 服务器.
如果你添加一个你自己的任何自动配置类型的 @Bean,它将替换默认的(除了 RedisTemplate 的情况,它是根据 bean 的名称'redisTemplate'而不是它的类型进行排除的).如果在 classpath 路径下存在 commons-pool2,默认你会获得一个连接池工厂.
@Component
public class MyBean {
private StringRedisTemplate template;
@Autowired
public MyBean(StringRedisTemplate template) {
this.template = template;
}
// ...
}
1.3 建立多个 redis 连接
使用 redis 的默认配置可以连接到 redis 中的 0 库中,如果指定库连接需要配置 indexdb,同时如果需要连接多个 redis 服务,也需要同时配置多个数据源
1.3.1,application.yml 文件 中增加:
1.3.2,创建 redisconfiguration
@Component
public class MyBean {
private StringRedisTemplate template;
@Autowired
public MyBean(StringRedisTemplate template) {
this.template = template;
}
// ...
}
1.3.3,声明 redis 抽象基类,创建 redis 的操作方法
@Configuration
public class Redis137_11Configuration {
@Bean(name = "redis123Template")
public StringRedisTemplate redisTemplate(
@Value("${redis123.hostName}") String hostName,
@Value("${redis123.port}") int port,
@Value("${redis123.password}") String password,
@Value("${redis123.maxIdle}") int maxIdle,
@Value("${redis123.maxTotal}") int maxTotal,
@Value("${redis123.index}") int index,
@Value("${redis123.maxWaitMillis}") long maxWaitMillis,
@Value("${redis123.testOnBorrow}") boolean testOnBorrow) {
StringRedisTemplate temple = new StringRedisTemplate();
temple.setConnectionFactory(connectionFactory(hostName, port, password,
maxIdle, maxTotal, index, maxWaitMillis, testOnBorrow));
return temple;
}
public RedisConnectionFactory connectionFactory(String hostName, int port,
String password, int maxIdle, int maxTotal, int index,
long maxWaitMillis, boolean testOnBorrow) {
JedisConnectionFactory jedis = new JedisConnectionFactory();
jedis.setHostName(hostName);
jedis.setPort(port);
if (!StringUtils.isEmpty(password)) {
jedis.setPassword(password);
}
if (index != 0) {
jedis.setDatabase(index);
}
jedis.setPoolConfig(poolCofig(maxIdle, maxTotal, maxWaitMillis,
testOnBorrow));
// 初始化连接 pool
jedis.afterPropertiesSet();
RedisConnectionFactory factory = jedis;
return factory;
}
public JedisPoolConfig poolCofig(int maxIdle, int maxTotal,
long maxWaitMillis, boolean testOnBorrow) {
JedisPoolConfig poolCofig = new JedisPoolConfig();
poolCofig.setMaxIdle(maxIdle);
poolCofig.setMaxTotal(maxTotal);
poolCofig.setMaxWaitMillis(maxWaitMillis);
poolCofig.setTestOnBorrow(testOnBorrow);
return poolCofig;
}
}
1.3.4,根据数据源,创建不同的子类 @Component
public abstract class AbRedisConfiguration {
protected StringRedisTemplate temple;
public void setData(String key, String value) {
getTemple().opsForValue().set(key, value);
}
public String getData(String key) {
return getTemple().opsForValue().get(key);
}
public StringRedisTemplate getTemple() {
return temple;
}
}
ps: 类和子类中同时声明了 getTemple 方法和 StringRedisTemple 属性,子类通过重写父类的 getTeimple 方法,把子类的自己 StringRedisTemple 属性 传给 父类,父类通过子类传递过来的 StringRedisTemple 使用不通的数据链接来操作缓存.至此,父类完成所有的操作方法,而当需要创建一个数据库连接时,只需要在创建一个子类,被声明自己的 StringRedisTemple,并传给父类即可.
public class Redis123 extends AbRedisConfiguration {
@Resource(name = "redis123Template")
private StringRedisTemplate temple;
public StringRedisTemplate getTemple() {
return temple;
}
}
来源: http://www.phperz.com/article/18/0127/357532.html