package org.zln.utils;import org.apache.commons.lang3.StringUtils;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig;/** * Created by sherry on 16/9/13. */public class JedisUtils {    private static Logger logger = LogManager.getLogger();    private static JedisPool pool = null;    private static final String URL = "127.0.0.1";    private static final int PORT = 6379;    private static Jedis jedis = null;    static {        pool = new JedisPool(new JedisPoolConfig(), URL,PORT);    }    public static Jedis getRedisCon(String password){        jedis = pool.getResource();        if (StringUtils.isNotEmpty(password)){            logger.info("以密码:"+password+" 登陆 redis");            jedis.auth(password);        }        logger.info(jedis.ping());        return jedis;    }    public static void closeRedisCon(Jedis jedis){        if (jedis!=null){            jedis.close();        }    }    public static void closeApp(){        //关闭应用程序的时候执行        pool.destroy();    }}

package org.zln.main;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.zln.utils.JedisUtils;import redis.clients.jedis.Jedis;import java.io.*;import java.util.*;/** * Created by sherry on 16/9/13. */public class JedisMain {    private static Logger logger = LogManager.getLogger();    public static void main(String[] args) {        Jedis jedis = JedisUtils.getRedisCon("");//        stringTest(jedis);////        listTest(jedis);////        mapTest(jedis);////        objTest(jedis);        objListTest(jedis);//        将这个Jedis实例归还给JedisPool。        JedisUtils.closeRedisCon(jedis);    }    /**     * 对象列表     * @param jedis     */    private static void objListTest(Jedis jedis) {        Person person1 = new Person("name1",1);        Person person2 = new Person("name2",2);        Person person3 = new Person("name3",3);        Person person4 = new Person("name4",4);        List<Person> persons = new ArrayList<>();        persons.add(person1);        persons.add(person2);        persons.add(person3);        persons.add(person4);        try {            for (Person person:persons){                ByteArrayOutputStream bos =  new ByteArrayOutputStream();                ObjectOutputStream oos =  new ObjectOutputStream(bos);                oos.writeObject(person);                byte [] byteArray = bos.toByteArray();                oos.close();                bos.close();                logger.info("写入对象:"+person);                jedis.lpush("persons".getBytes(),byteArray);            }            List<byte[]> personsBytes = jedis.lrange("persons".getBytes(),0,10);            for (byte[] bs:personsBytes){                ByteArrayInputStream bis =  new ByteArrayInputStream(bs);                ObjectInputStream inputStream =  new ObjectInputStream(bis);                Person readObject = (Person) inputStream.readObject();                logger.info( " 读取对象 \t" + readObject.toString());                inputStream.close();                bis.close();            }        } catch (IOException|ClassNotFoundException e) {            e.printStackTrace();        }        jedis.del("persons".getBytes());    }    /**     * 存储对象     * @param jedis     */    private static void objTest(Jedis jedis) {        Person person = new Person();        person.setAge(27);        person.setName("卡卡卡");        ByteArrayOutputStream bos =  new ByteArrayOutputStream();        try {            ObjectOutputStream oos =  new ObjectOutputStream(bos);            oos.writeObject(person);            byte [] byteArray = bos.toByteArray();            oos.close();            bos.close();            String setObjectRet = jedis.set(person.getName().getBytes(), byteArray);            logger.info( " set object return \t" + setObjectRet);            byte [] bs = jedis.get( person.getName().getBytes());            ByteArrayInputStream bis =  new ByteArrayInputStream(bs);            ObjectInputStream inputStream =  new ObjectInputStream(bis);            Person readObject = (Person) inputStream.readObject();            logger.info( " read object \t" + readObject.toString());            inputStream.close();            bis.close();        } catch (IOException|ClassNotFoundException e) {            e.printStackTrace();        }        jedis.del(person.getName());    }    /**     * 存储 Map     * @param jedis     */    private static void mapTest(Jedis jedis) {        Map<String,String> user =  new HashMap<String,String>();        user.put( "name" ,  "cd" );        user.put( "password" ,  "123456" );        jedis.hmset("user",user);        // mapkey 个数        System.out.println(String.format ( "len:%d" , jedis.hlen( "user" )));//map中的所有键值        System.out.println(String.format ( "keys: %s" , jedis.hkeys( "user" ) ));//map中的所有value        System.out.println(String.format ( "values: %s" , jedis.hvals( "user" ) ));//取出map中的name字段值        List<String> rsmap = jedis.hmget( "user" ,  "name" , "password" );        System.out.println(rsmap);//删除map中的某一个键值 password        jedis.hdel( "user" ,  "password" );        System.out.println(jedis.hmget( "user" ,  "name" ,  "password" ));        jedis.del("user");    }    /**     * 存储列表     * @param jedis     */    private static void listTest(Jedis jedis) {        jedis.lpush("tutorial-list", "Redis");        jedis.lpush("tutorial-list", "Mongodb");        jedis.lpush("tutorial-list", "Mysql");        // 获取存储的数据并输出        List<String> list = jedis.lrange("tutorial-list", 0 ,5);        for(int i=0; i<list.size(); i++) {            System.out.println("Stored string in redis:: "+list.get(i));        }        jedis.del("tutorial-list");    }    /**     * 存储字符串     * @param jedis     */    private static void stringTest(Jedis jedis) {        //一次次添加        jedis.set("string1","一号字符串");        jedis.set("string2","二号字符串");        jedis.set("string3","三号字符串");        jedis.set("string4","四号字符串");        logger.info("获取string1:"+jedis.get("string1"));        //在已有 key 上,对 value 进行新增        jedis.append("string1","添加新字符串");        logger.info("获取string1:"+jedis.get("string1"));        //一次性添加多个键值对        jedis.mset("s1","v1","s2","v2","s3","v3");        logger.info("获取s1:"+jedis.get("s1"));        for (Iterator<String> iterator = jedis.keys("*").iterator();iterator.hasNext();){            String key = iterator.next();            logger.info(key+":"+jedis.get(key));            jedis.del(key);        }    }}