首页 > 代码库 > java使用redis数据库
java使用redis数据库
使用maven管理jar,添加依赖:
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.7.0</version>
</dependency>//需要的jar
使用redis数据库的配置(设置属性的值,可以根据具体需要),存数据
JedisPool jedisPool = null;
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(10);
poolConfig.setMaxTotal(100);
poolConfig.setMaxWaitMillis(10000);
poolConfig.setTestOnBorrow(true);
jedisPool = new JedisPool(poolConfig, "192.168.0.109", 6379); //配置Jedis的配置,端口,服务器地址
存储过程
List<String> lines = Files.readAllLines(Paths.get("E:/oooooooo/task.txt"));//要存储的数据源,数据格式多为json形式的字符串
Jedis jedis = jedisPool.getResource();
jedis.select(3);// 3是指在把数据库上的分区,可以自由设置
Pipeline pipelined = jedis.pipelined();
lines.forEach(l -> {
pipelined.lpush(数据库名, l);
});
pipelined.sync(); //这段代码的作用是通过管道(Pipeline)批量存储到redis数据库
通过java获取redis上的数据
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxIdle(10);
poolConfig.setMaxTotal(500);
poolConfig.setMaxWaitMillis(100000);
poolConfig.setTestOnBorrow(true);
jedisPool = new JedisPool(poolConfig, 服务器地址, 端口, timeout, 数据库密码);
Jedis jedis = jedisPool.getResource();
jedis.select(3);// 3是指在把数据库上的分区,可以自由设置
String targetString = jedis.lpop(数据库名);;//targetString就是取出来的目标数据
jedisPool.returnResourceObject(jedis); //一顿操作之后,记得释放jedis的资源
java使用redis数据库