使用java代码操作Redis

一、在pom.xml里添加依赖

      <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
      </dependency>

二、连接Redis

Jedis jedis =new Jedis("192.168.124.129",6379);
        jedis.auth("123456");
        //测试连接（打印pong就算连接成功）
        System.out.println(jedis.ping());

三、操作数据

//操作字符串
        //插入数据
//        jedis.set("aaa", "zs");
        //获取数据
//        System.out.println(jedis.get("aaa"));

     //操作哈希
        //插入数据
//        jedis.hset("user1  ","uname","ls");
//        jedis.hset("useq r1","sex","女");
        //获取数据
//        System.out.println(jedis.hget("user1", "sex"));
//        System.out.println(jedis.hgetAll("user1"));

    //操作列表(堆栈结构)
     jedis.lpush("hobby","a","b","c","d");
     //从栈顶开始取值
        System.out.println(jedis.lpop("hobby"));
     //从栈底开始取值
        System.out.println(jedis.rpop("hobby"));

四、运用

@Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

        //首页第一次是读取数据库，后面读取缓存（在没有增删改的情况下）
        Jedis jedis =new Jedis("192.168.124.129",6379);
        jedis.auth("123456");
        //从缓存中获取当前登录的用户信息
        Map<String,String> currentUser =jedis.hgetAll("currentUser");
        if (currentUser !=null && currentUser.size()>0){
            req.setAttribute("msg","从缓存中获取数据");
            req.setAttribute("currentUser",currentUser);
        }
        else {
            //第一次登录，第一次访问首页数据
            req.setAttribute("msg","从数据库中获取数据");
            String uname ="tianqi";
            String upass ="123456";
            //接下来把数据中的对应对象存储到缓存中
            jedis.hset("currentUser","uname","tianqi");
            jedis.hset("currentUser","upass","123456");
            //此时能获取到值，原因是上面已经将数据存储到缓存中
            currentUser = jedis.hgetAll("currentUser");
            req.setAttribute("currentUser",currentUser);

        }
        req.getRequestDispatcher("/home.jsp").forward(req,resp);
    }

五、实战

  1.首页第一次是读取数据库，后面读取缓存（在没有增删改的情况）：

 // 从Redis中获取数据
    String bolgListALL =jedis.get("blogList");
                if(bolgListALL != null && bolgListALL.length()>0) {
        System.out.println("使用Redis查询");
        request.setAttribute("blogList", JSON.parse(bolgListALL));
    }else {
// 从数据库中查询数据
        List<Map<String, Object>> blogList = this.blogDao.freemarker_list(title, null);
// 放入缓存
        jedis.set("blogList", JSON.toJSONString(blogList));
        //传到jsp页面
        request.setAttribute("blogList", blogList);
        System.out.println("从缓存中拿数据");

  2.增删改的时候，要顺带更新缓存，下一次再次访问首页要保证redis中数据跟mysql数据是一致：

public String add() {
        HttpServletRequest request = ServletActionContext.getRequest();
        Map parameterMap = request.getParameterMap();
        try {
            // 将博客添加到数据库中 
            this.blogDao.add(parameterMap);
            //清除Redis缓存
            jedis.del("blogList");
            // 获取当前博客的id
            int maxId = (int) this.blogDao.maxId();
            // 添加到lucene 中
            addIndex(maxId + "", parameterMap);
            // 进行网页静态化
            addStaticPage(maxId + "", parameterMap);
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }
        return "blogList";
    }