java 對 redis的簡單使用
阿新 • • 發佈:2018-11-19
1.首先我們需要用到redis資料庫和使用redis的一系列jar包。
這些資源通常網上都有,這裡我把整理了一下的資源放在網盤裡,供大家下載。連結:https://pan.baidu.com/s/1aRryznAHVZbeQ5gni9KCOQ 提取碼:zn01
2.啟動和驗證redis是否可以使用。
參考博文:https://blog.csdn.net/qq_36850813/article/details/80635380
3.建立java專案,匯入jar包。
專案目錄如下:
對jar包進行build path->add to build path,把jar包新增進專案,現在我們就可以使用redis了。
關於對jar包commons-pool的博文說明:https://blog.csdn.net/u011784767/article/details/78337448
jedis就是redis在java環境下連線redis必須jar包。
4.redisClient.java
package com.redis; import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Set; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.ShardedJedis; import redis.clients.jedis.ShardedJedisPool; import redis.clients.jedis.SortingParams; public class redisClient { private Jedis jedis;//非切片額客戶端連線 private JedisPool jedisPool;//非切片連線池 private ShardedJedis shardedJedis;//切片額客戶端連線 private ShardedJedisPool shardedJedisPool;//切片連線池 public redisClient() { initialPool(); initialShardedPool(); shardedJedis = shardedJedisPool.getResource(); jedis = jedisPool.getResource(); } /** * 初始化非切片池 */ private void initialPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxActive(20); config.setMaxIdle(5); config.setMaxWait(1000l); config.setTestOnBorrow(false); jedisPool = new JedisPool(config,"127.0.0.1",6379); } /** * 初始化切片池 */ private void initialShardedPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxActive(20); config.setMaxIdle(5); config.setMaxWait(1000l); config.setTestOnBorrow(false); // slave連結 List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(); shards.add(new JedisShardInfo("127.0.0.1", 6379, "master")); // 構造池 shardedJedisPool = new ShardedJedisPool(config, shards); } public void saveToRedis(String key,String obj) { jedis.set(key, obj); } public String getFromRedis(String key) { String obj = jedis.get(key); return obj; } }
Main.java
package com.redis;
public class Main {
public static void main(String[] args) {
// TODO Auto-generated method stub
redisClient client = new redisClient();
client.saveToRedis("1","aaaa");
System.out.println(client.getFromRedis("1"));
}
}