1. 程式人生 > >java 對 redis的簡單使用

java 對 redis的簡單使用

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"));
    }

}