集成方式
使用Jedis
Jedis是Redis官方推薦的面向Java的操作Redis的客戶端，是對服務端直連后進行操作。如果直接使用Jedis進行連接，多線程環境下是非線程安全的，正式生產環境一般使用連接池進行連接。
dependency>
groupId>redis.clients/groupId>
artifactId>jedis/artifactId>
version>2.9.0/version>
/dependency>
使用spring-data-redis
由Spring 框架提供，是對Redis客戶端的進一步封裝，屏蔽了不同客戶端的不同實現方式，讓服務端和客戶端進一步解耦；也就是你可以切換不同的客戶端實現，比如Jedis或Lettuce（Redis客戶端實現之一），而不影響你的業務邏輯。
類似于的SpringCloud的服務治理框架對不同服務治理組件的適配，或是AMQP
它利用RedisTemplate對JedisApi進行高度封裝。使用的依賴如下：
dependency>
groupId>org.springframework.boot/groupId>
artifactId>spring-boot-starter-data-redis/artifactId>
/dependency>
Redis的安裝
收先要安裝Redis服務端，Redis官方提供的是Linux安裝包。網上有很多詳細的安裝教程，這里不做展開。關于Windows下的安裝，可參考我的另一篇博文windows下Redis的安裝和使用
綁定配置
完成Redis服務端的安裝之后，我們開始在項目中進行集成。這里我們先介紹使用Jedis的方式進行的集成。先按上面的提及的方式進行依賴的引入。然后將Redis的相關信息配置到配置文件中去。我們可以的新建一個配置文件redis.properties，內容如下：
# Redis數據庫索引（默認為0）
spring.redis.database=0
# Redis服務器地址
spring.redis.host=127.0.0.1
# Redis服務器連接端口
spring.redis.port=6379
# Redis服務器連接密碼（默認為空）
spring.redis.password=
# 連接超時時間（毫秒）
spring.redis.timeout=0
接下來我們要為Redis客戶端連接綁定上面的配置，創建出來的客戶端實例才能夠連接到我們的想連的Redis服務端。你可以使用@Value注解或@ConfigurationProperties注解的方式，本文采用的是后者，如果還不清楚的該注解的用法，可以移步我的另一篇博文@ConfigurationProperties實現自定義配置綁定查看，這里不做展開。
以下是Redis服務端信息配置的接收類：MyRedisProperties.java
@ConfigurationProperties(
prefix = "spring.redis"
)
@Component
@Data
@PropertySource("classpath:/redis.properties")
public class MyRedisProperties {
private String database;
private String host;
private Integer port;
private String password;
private Integer timeOut;
}
由于我們正式生產環境一般都是采用連接池方式實現，所以我們還需要關于連接池的配置如下：
# 連接池最大連接數（使用負值表示沒有限制）
spring.redis.pool.max-active=8
# 連接池最大阻塞等待時間（使用負值表示沒有限制）
spring.redis.pool.max-wait=-1
# 連接池中的最大空閑連接
spring.redis.pool.max-idle=8
# 連接池中的最小空閑連接
spring.redis.pool.min-idle=0
對應的接收類如下：
@ConfigurationProperties(
prefix = "spring.redis.pool"
)
@Data
@Component
@PropertySource("classpath:/redis.properties")
public class RedisPoolProperties {
private Integer maxActive;
private Integer maxWait;
private Integer maxIdle;
private Integer minIdle;
}
然后向Spring容器裝配客戶端實例，分為單個客戶端和連接池兩種實現，如下代碼：
@Configuration
public class RedisConfig {
@Autowired
private RedisPoolProperties redisPoolProperties;
@Autowired
private MyRedisProperties myRedisProperties;
@Bean
public Jedis singleJedis(){
return new Jedis(myRedisProperties.getHost(),myRedisProperties.getPort());
}
@Bean
public JedisPool jedisPool(){
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(redisPoolProperties.getMaxIdle());
poolConfig.setMaxTotal(redisPoolProperties.getMaxActive());
poolConfig.setMaxWaitMillis(redisPoolProperties.getMaxWait() * 1000);
JedisPool jp = new JedisPool(poolConfig, myRedisProperties.getHost(), myRedisProperties.getPort(),
myRedisProperties.getTimeOut()*1000, myRedisProperties.getPassword(), 0);
return jp;
}
}
獲取Redis客戶端
進行相關配置的綁定之后，意味著我們程序可以拿到Redis和連接池的相關信息，然后進行客戶端的創建和連接了。所以我們要向Spring容器裝配客戶端實例，分為單個客戶端和連接池兩種實現，如下代碼：
@Configuration
public class RedisConfig {
@Autowired
private RedisPoolProperties redisPoolProperties;
@Autowired
private MyRedisProperties myRedisProperties;
@Bean
public Jedis singleJedis(){
return new Jedis(myRedisProperties.getHost(),myRedisProperties.getPort());
}
@Bean
public JedisPool jedisPool(){
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(redisPoolProperties.getMaxIdle());
poolConfig.setMaxTotal(redisPoolProperties.getMaxActive());
poolConfig.setMaxWaitMillis(redisPoolProperties.getMaxWait() * 1000);
JedisPool jp = new JedisPool(poolConfig, myRedisProperties.getHost(), myRedisProperties.getPort(),
myRedisProperties.getTimeOut()*1000, myRedisProperties.getPassword(), 0);
return jp;
}
}
Redis工具的編寫
裝配好客戶端實例后，我們就可以通過@Autowired的方式進行注入使用了。我們都知道，Redis有5中數據類型，分別是：
- string（字符串）
- hash（哈希）
- list（列表）
- set（集合）
- zset(sorted set：有序集合)
所以的有必要的封裝一個操作者5種數據列表的工具類，由于篇幅的關系，我們以Redis最基本的數據類型String為例，簡單封裝幾個操作方法作為示例如下，更詳細的封裝，可參考java操作Redis數據庫的redis工具,RedisUtil,jedis工具JedisUtil,JedisPoolUtil這一博文
@Service
public class RedisService {
@Autowired
private JedisPool jedisPool; // 連接池方式
@Autowired
private Jedis myJedis; // 單個客戶端
public T> T get(String key, ClassT> clazz) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
String str = jedis.get(key);
return stringToBean(str,clazz);
} finally {
close(jedis);
}
}
public T> void set(String key, T value) {
try {
String str = value.toString();
if (str == null || str.length() = 0) {
return;
}
myJedis.set(key, str);
} finally {
close(myJedis);
}
}
private void close(Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}
/**
* 把一個字符串轉換成bean對象
* @param str
* @param T>
* @return
*/
public static T> T stringToBean(String str, ClassT> clazz) {
if(str == null || str.length() = 0 || clazz == null) {
return null;
}
if(clazz == int.class || clazz == Integer.class) {
return (T)Integer.valueOf(str);
}else if(clazz == String.class) {
return (T)str;
}else if(clazz == long.class || clazz == Long.class) {
return (T)Long.valueOf(str);
}else {
return JSON.toJavaObject(JSON.parseObject(str), clazz);
}
}
}
其中get方法使用連接池中的客戶端實例，set方法用到的是非連接池的實例，以區分兩種不同的使用方式
使用
封裝好的Redis的操作工具類后，我們就可以直接使用該工具類來進行對Redis的各種操作 。如下，直接注入即可。
@RestController
public class TestController {
@Autowired
private RedisService redisService;
......
}
到此這篇關于Spring Boot 項目集成Redis的文章就介紹到這了,更多相關Spring Boot 項目集成Redis內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- 使用SpringBoot集成redis的方法
- SpringBoot集成Redis實現消息隊列的方法
- Spring boot集成redis lettuce代碼實例
- 基于SpringBoot集成測試遠程連接Redis服務的教程詳解
- springboot集成redis實現簡單秒殺系統
- SpringBoot集成Redisson實現分布式鎖的方法示例
- springBoot集成redis的key,value序列化的相關問題
