使用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的資源