stripe boot 连接redis
创建时间:2025-10-26 17:04
长度:2280
浏览:0
评论:0
jedis 是java 提供的一个连接redis 的库
管理依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>在applocation.yml 配置redis
spring:
redis:
database: 1 # Redis 数据库
host: localhost
port: 6379
timeout: 10000 # 连接超时时间
jedis: # jedis连接池配置
pool:
max-active: 200 # 连接池最大连接数(使用负值表示没有限制)
max-wait: -1 # 连接池最大阻塞等待时间(使用负值表示没有限制)
max-idle: 10 # 连接池中的最大空闲连接
min-idle: 0 # 连接池中的最小空闲连接
time-between-eviction-runs: -1 #逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
还需要写一个配置类
package com.example.demo.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* Jedis 连接池配置
* 获取Jedis连接, 控制Redis
*/
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
@Data
public class JedisConfig {
// Redis 相关连接参数
private int database;
private String host;
// private String password;
private int port;
// Jedis 连接池配置
@Value("${spring.redis.jedis.pool.max-active}")
private int maxActive;
@Value("${spring.redis.jedis.pool.max-idle}")
private int maxIdle;
@Value("${spring.redis.jedis.pool.min-idle}")
private int minIdle;
@Bean
public JedisPool jedisPool() {
// 连接池配置
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
// 读取配置
jedisPoolConfig.setMaxTotal(maxActive);
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMinIdle(minIdle);
JedisPool jedisPool = new JedisPool(jedisPoolConfig, host, port, 1000, null, database);
return jedisPool;
}
}
测试是否可以连接成功
or 使用
package com.example.demo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
@SpringBootTest
class DemoApplicationTests {
@Autowired
private JedisPool jedisPool;
@Test
void contextLoads() {
Jedis jedis = jedisPool.getResource();
System.out.println(jedis.ping());
}
}