[无名弟子]姚远|2017年09月20日的日报-技能树.IT修真院

发表于： 2017-09-20 11:16:45

0 777

今天完成的事情：

redis

Redis是一个开源的key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，Redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是Redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

下载redis

官方只支持linux版的，但Microsoft在github有个win64的redis开源项目。32位的小伙伴呵呵一笑→_→

下载完解压到某个文件夹下，cmd进入文件夹

打开一个新的cmd，注意之前的不要关

一番操作，已经可以用了

还可以在redis.conf里修改端口号，密码什么的，修改完成后重启就行了

可视化redis桌面管理工具redis desktop manager

能看到存进去的键值对，还可以进行redis的常用操作，也可以打开命令行

把redis整合到项目里

pom文件添加

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>1.6.1.RELEASE</version>
</dependency>

看了看ssm整合redis，有点复杂慢慢弄

先来建个测试类

public class RedisTest {
    public static void main(String[] args) {
        Jedis jedis=new Jedis("127.0.0.1",6379);
        System.out.println("123");
        jedis.set("hello","world");
        System.out.println(jedis.get("hello"));
    }
}

注意此时cmd窗口还要开着。

然后据说需要两个工具类，嗯。。。

public class RedisUtil {
       //Redis服务器IP
    private static String ADDR = "127.0.0.1";

    //Redis端口号
    private static int PORT = 6379;

    //"admin";//访问密码
    private static String AUTH = null;

    //可用连接实例的最大数目，默认值为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;

    /**
     * 初始化Redis连接池
     */
    static {
        try {
            JedisPoolConfig config = new JedisPoolConfig();
            //config.setMaxActive(MAX_ACTIVE);
            config.setMaxIdle(MAX_IDLE);
            config.setMaxWaitMillis(MAX_WAIT);
            config.setTestOnBorrow(TEST_ON_BORROW);
            jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    /**
     * 获取Jedis实例
     * @return
     */
    public synchronized static Jedis getJedis(){
        try{
            if(jedisPool != null){
                Jedis resource =jedisPool.getResource();
                return resource;
            }else {
                return null;
            }
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }
    }

    /**
     * 释放Jedis资源
     * @param jedis
     */
    public static void close(final Jedis jedis){
        if(jedis != null){
            jedis.close();
        }
    }

}

public class SerializeUtil {
    public static byte[] serialize(Object object) {
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            // 序列化
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {

        }
        return null;
    }

    public static Object unserialize( byte[] bytes) {
        ByteArrayInputStream bais = null;
        try {
            // 反序列化
            bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
        } catch (Exception e) {

        }
        return null;
    }
}

东看看西看看，发现redis的spring配置可以有两种，xml和注解，再研究，我先用客户端做了再说吧

service实现类

    public List<User> userAll(){
//        List<User> users=userMapper.userAll();
//        MemcachedUtil.set("users",users);
//        System.out.println(MemcachedUtil.get("users"));
//        return userMapper.userAll();
        Jedis redis= new Jedis( "localhost", 6379);
        if(redis.get("users")==null) {
            List user = userMapper.userAll();
            redis.set("users".getBytes(), SerializeUtil. serialize(user));
            System.out.println("这是数据库");
            return user;
        }else{
            System.out.println("这是缓存");
            byte[] value = redis.get("users".getBytes());
            return (List)SerializeUtil. unserialize(value);
        }
    }