Java使用Jedis操作Redis大全

Java操作Redis需要导入两个jar：

　　commons-pool2-2.4.2.jar
　　jedis-2.1.0.jar

package com.chinasofti.test;

import java.io.IOException;

import java.io.OutputStream;

import java.util.HashMap;

import java.util.Map;

import java.util.logging.Logger;

import org.junit.Before;

import org.junit.Test;

import redis.clients.jedis.Jedis;

/**

 * Java连接Redis测试

 * @author liuhl

 *

 */

public class ConnRedis {

    Jedis jedis;

    @Before

    public void init(){

        jedis = new Jedis("localhost", 6379, 30);

        jedis.auth("admin");

    }

    /**

     * 测试Redis对字符串的操作

     * set():添加一个新字符串

     * append():向已有的key所对应的value上面追加值

     * del():删除某个键

     * mset():设置多个键值对

     * incr(k):对该可以进行+1操作

     * @author liuhl

     */

    @Test

    public void testRedisString(){

        jedis.set("username", "sMith kevens");

        jedis.append("username", "是Redis开发者");

        System.out.println(jedis.get("username")+"------------");

        //删除某个键

        jedis.del("date");

        System.out.println(jedis.get("date")+"======");

        //设置多个键值对

        jedis.mset("nicheng","shubiao","QAge","3","QQnumber","906058683","sex","man");

        jedis.incr("QAge");//进行+1操作

        System.out.println(jedis.get("nicheng")+":"+jedis.get("QAge")+"："+jedis.get("QQnumber")+":"+jedis.get("sex"));

    }

    /**

     * Redis对List的操作

     * llen():获取列表size

     * lpush():向列表左侧插入元素

     * rpush()：向列表右侧插入元素

     * lrange("",0,-1):获取列表所有元素

     * @author liuhl

     */

    @Test

    public void testRedisList(){

        //开始前先移除所有的内容

        jedis.del("javaframe work");

        System.out.println(jedis.lrange("java framework", 0, -1));

        //定义列表frame work,并向其中添加三条数据

        jedis.lpush("javaframe work", "struts2");

        jedis.lpush("javaframe work", "spring");

        jedis.lpush("javaframe work", "hibernate");

        System.out.println(jedis.llen("javaframe work")+"个");

        System.out.println(jedis.lrange("javaframe work", 0, -1));

        //向列表右侧添加元素

        jedis.rpush("javaframe work", "ibatis");

        jedis.rpush("javaframe work", "mybatis");

        jedis.rpush("javaframe work", "springmvc");

        System.out.println(jedis.lrange("javaframe work", 0, -1));

    }

    /**

     *Jedis操作无序列表（Set）

     *sadd():向无序列表插入元素

     *smembers():获取所有加入的value

     *srem():移除

     *sismember():判断一个值是不是某个集合的元素，返回boolean

     *scard():返回集合元素的个数

     *srandmember():返回集合中的一个随机元素

     *@author liuhl

     *@return void

     *@category

     */

    @Test

    public void testRedisSet(){

        //向无序集合插入元素

        jedis.sadd("user", "yanbao");

        jedis.sadd("user", "chengyi");

        jedis.sadd("user", "fanwei");

        //移除

        jedis.srem("user", "chengyi");

        System.out.println(jedis.smembers("user"));

        System.err.println(jedis.sismember("user", "yunfei"));

        System.out.println(jedis.scard("user"));

        System.out.println(jedis.srandmember("user"));

    }

    /**

     * 测试列表排序sort

     * redis:Lists是双向链表

     * 排序前先清掉列表，后添加数据测试

     * @exception  InterruptedException：检查异常

     * @author liuhl

     */

    @Test

    public void testListSort() throws InterruptedException{

        jedis.del("arr");

        jedis.lpush("arr", "4");

        jedis.lpush("arr", "78");

        jedis.lpush("arr", "2");

        jedis.lpush("arr", "9");

        jedis.lpush("arr", "7");

        jedis.rpush("arr", "120");

        jedis.rpush("arr", "91");

        jedis.rpush("arr", "88");

        jedis.rpush("arr", "31");

        jedis.rpush("arr", "10");

        System.out.println("排序前："+jedis.lrange("arr", 0, -1));

        System.out.println("排序后："+jedis.sort("arr"));

    }

    /**

     *

     * 测试redis有序集合

     * com.chinasofti.test

     * 方法名：testRedisShortZset

     * 创建人：liuhl

     * 时间：2017-4-5-上午10:15:33

     * return: void

     * @exception

     * @since  1.0.0

     * zadd():向有序集合（sorts zsets）中插入一个元素

     * zrange():仅列出所有的元素值。

     */

    @Test

    public void testRedisShortZset(){

        //向有序集合sorts sets插入元素

        jedis.zadd("lhlzset", 6, "http://localhost:8080");

        jedis.zadd("lhlzset", 6, "sort");

        //只列出有序集合的元素

        System.out.println(jedis.zrange("lhlzset", 0, -1));

        System.out.println(jedis.zrangeByScore("lhlzset", 0, 6));

    }

    /**

     *

     * 测试hashs哈希

     * com.chinasofti.test

     * 方法名：testHashs

     * 创建人：liuhl

     * 时间：2017-4-6-上午9:46:04

     * return: void

     * @exception

     * @since  1.0.0

     * hmset():建立hashs并赋值

     * hmget():列出hashs相关

     */

    @Test

    public void testHashs(){

        //建立hashs并赋值

        Map<String, String> map = new HashMap<>();

        map.put("首都", "北京");map.put("河南", "洛阳");map.put("陕西", "西安");

        jedis.hmset("china", map);

        //列出hashs的内容

        System.out.println(jedis.hmget("china", "河南"));

    }

}

package com.chinasofti.test;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

/**

 * Redis连接池

 *

 * @author Administrator

 *

 */

public class RedisUtils {

    // Redis服务器IP

    private static String ADDR = "127.0.0.1";

    // redis端口号

    private static int PORT = 6379;

    // 访问密码

    private static String AUTH = "admin";

    /**

     * 可用连接实例的最大数目，默认为8，如果赋值为-1，则表示不限制，

     * 如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。

     */

    private static int MAX_ACTIVE = 1024;

    // 控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。

    private static int MAX_IDLE = 200;

    // 等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；

    private static int MAX_WAIT = 10000;

    private static int TIMEOUT = 10000;

    // 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；

    private static boolean TEST_ON_BORROW = true;

    private static JedisPool jedisPool = null;

    // 初始化连接池

    static {

        try {

            JedisPoolConfig config = new JedisPoolConfig();

            config.setMaxActive(MAX_ACTIVE);

            config.setMaxIdle(MAX_IDLE);

            // config.setMaxWait(MAX_WAIT);

            config.setTestOnBorrow(TEST_ON_BORROW);

            // jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);

            // 注释的这两行为jdk版本问题导致，可忽略

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    /**

     * 获取redis实例

     */

    public synchronized static Jedis getJedis() {

        try {

            if (jedisPool != null) {

                Jedis jedis = jedisPool.getResource();

                return jedis;

            } else {

                return null;

            }

        } catch (Exception e) {

            e.printStackTrace();

            return null;

        }

    }

    /**

     *

     * @param jedis

     */

    public static void returnResource(final Jedis jedis) {

        if (jedis != null) {

            jedisPool.returnResource(jedis);// 关闭操作已经在此处处理了

        }

    }

}

巴特西

Java使用Jedis操作Redis大全

最新文章

热门文章