[大数据]redis in action 读书记录01 redis的一些常用命令

Redis in action 读书记录01 redis的一些常用命令

Redis 数据结构

• String: 字符串
• Hash: 散列
• List: 列表
• Set: 集合
• Sorted Set: 有序集合

Redis常用命令

string字符串常用命令

字符串get、set、del命令

字符串中的自增命令和自减命令

当用户将一个值存储到 Redis 字符串里面的时候，如果这个值可以被解释（interpret）为十 进制整数或者浮点数，那么 Redis 会察觉到这一点，并允许用户对这个字符串执行各种 INCR和DECR操作。如果用户对一个不存在的键或者一个保存了空串的键执行自增或者自减操作，那么Redis 在执行操作时会将这个键的值当作是 0 来处理。如果用户尝试对一个值无法被解释为整数或者浮点数的字符串键执行自增或者自减操作，那么 Redis 将向用户返回一个错误。代码清单 3-1展示了对字符串执行自增操作和自减操作的一些例子。

字符串处理子串和二进制位的命令

list列表常用命令

set集合常用命令

hash散列常用命令

尽管有 HGETALL 存在，但 HKEYS 和 HVALS 也是非常有用的：如果散列包含的值非常大，那么用户可以先使用 HKEYS 取出散列包含的所有键，然后再使用 HGET 一个接一个地取出键的值，从而避免因为一次获取多个大体积的值而导致服务器阻塞。

zset有序集合常用命令

Chapter01.java

import redis.clients.jedis.Jedis;
import redis.clients.jedis.ZParams;

import java.util.*;

/**
 * @author DZHooo
 * @version 1.0
 * @date 2021/11/21 22:53
 * @description: TODO
 */

public class Chapter01 {

    /**
     * 一个有序集合 key：文章ID ， value：文章发布时间
     * 一个有序集合 key：文章ID ， value：文章的评分
     * 集合 key：文章ID ， value：已投票用户ID
     * 散列 key：文章ID ， value： (title: value, link: value,...)
     *
     */

    private static final int ONE_WEEK_IN_SECONDS = 7 * 86400;   //七天的秒数

    private  static final int VOTE_SCORE = 432;    //   86400 / 200 = 432 书中200票的原因

    private static final int ARTICLES_PER_PAGE = 25;

    public static void main(String[] args) {
        new Chapter01().run();
    }

    public void run() {
        Jedis conn = new Jedis("localhost");
        conn.select(15);

        String articleId = postArticle(
                conn, "username", "A title", "http://www.google.com");
        System.out.println("We posted a new article with id: " + articleId);
        System.out.println("Its HASH looks like:");
        Map<String,String> articleData = conn.hgetAll("article:" + articleId);
        for (Map.Entry<String,String> entry : articleData.entrySet()){
            System.out.println("  " + entry.getKey() + ": " + entry.getValue());
        }

        System.out.println();

        articleVote(conn, "other_user", "article:" + articleId);
        String votes = conn.hget("article:" + articleId, "votes");
        System.out.println("We voted for the article, it now has votes: " + votes);
        assert Integer.parseInt(votes) > 1;

        System.out.println("The currently highest-scoring articles are:");
        List<Map<String,String>> articles = getArticles(conn, 1);
        printArticles(articles);
        assert articles.size() >= 1;

        addGroups(conn, articleId, new String[]{"new-group"});
        System.out.println("We added the article to a new group, other articles include:");
        articles = getGroupArticles(conn, "new-group", 1);
        printArticles(articles);
        assert articles.size() >= 1;
    }

    //调用这个函数进行投票，投票限制日期，只能投一次
    public void articleVote(Jedis conn,String user,String article) {
        //用UTC时区1970年1月1日到现在为止经过的秒数 减去 七天的秒数
        long cutoff = (System.currentTimeMillis() / 1000) - ONE_WEEK_IN_SECONDS;
        //这个有序集合的成员为文章ID，分值为文章的发布时间  获取这个文章发布的时间秒数 如果大于cutoff，说明文章发布超过七天
        if(conn.zscore("time:",article) < cutoff) {
            return;
        }
        //获取字符串article中的文章ID，在':'之后
        String articleId = article.substring(article.indexOf(':') + 1);
        //投票在集合中报存，键名为voted:[文章ID]，值为用户名，用集合存可以让一个用户只能投同一个文章一次票
        if(conn.sadd("voted:" + articleId, user) == 1) {
            //在第二个有序集合中，分值为文章的评分，投一票让该文章评分自增
            conn.zincrby("score:",VOTE_SCORE,article);
            //投票数量自增   散列用来存文章内容，键名为文章ID，值为文章内容对应的键值
            conn.hincrBy(article,"votes",1);
        }
    }

    //发布文章
    public String postArticle(Jedis conn, String user, String title, String link) {
        //文章ID自增+1
        String articleId = String.valueOf(conn.incr("article:"));

        String voted = "voted:" + articleId;
        //为这篇文章新增一个键名为voted:文章ID的集合，先为集合加一个成员user
        conn.sadd(voted, user);
        //设置过期时间七天
        conn.expire(voted, ONE_WEEK_IN_SECONDS);

        long now = System.currentTimeMillis() / 1000;
        //文章ID
        String article = "article:" + articleId;
        //散列的值
        HashMap<String,String> articleData = new HashMap<>();
        articleData.put("title", title);
        articleData.put("link", link);
        articleData.put("user", user);
        articleData.put("now", String.valueOf(now));
        articleData.put("votes", "1");
        //文章数据 键为文章ID，值为文章数据
        conn.hmset(article,articleData);
        //评分有序集合
        conn.zadd("score:",now + VOTE_SCORE,article);
        //时间有序集合
        conn.zadd("time:",now,article);

        return articleId;
    }

    //这个只用与提取评分的有序集合
    public List<Map<String, String>> getArticles(Jedis conn, int page) {
        return getArticles(conn,page,"score:");
    }

    //这个可以通过order取发布时间或评分的有序集合  参数order也是有序集合的键名
    public List<Map<String, String>> getArticles(Jedis conn, int page, String order) {

        int start = (page - 1) * ARTICLES_PER_PAGE;
        int end = start + ARTICLES_PER_PAGE - 1;

        Set<String> ids = conn.zrevrange(order, start, end);
        List<Map<String,String>> articles = new ArrayList<>();
        for(String id : ids) {
            Map<String,String> articleData = conn.hgetAll(id);
            articleData.put("id", id);
            articles.add(articleData);
        }

        return articles;
    }


    public void addGroups(Jedis conn, String articleId, String[] toAdd) {
        String article = "article:" + articleId;
        for(String group : toAdd) {
            conn.sadd("group:" + group, article);
        }
    }


    //程序可以得到按照文章评分排序的群组文章
    public List<Map<String,String>> getGroupArticles(Jedis conn, String group, int page) {
        return getGroupArticles(conn, group, page,"score:");
    }


    public List<Map<String,String>> getGroupArticles(Jedis conn, String group, int page, String order) {
        String key = order + group;
        if(!conn.exists(key)) {
            ZParams params = new ZParams().aggregate(ZParams.Aggregate.MAX);
            conn.zinterstore(key, params, "group:" + group, order);
            conn.expire(key, 60);
        }
        return getArticles(conn, page, key);
    }

    private void printArticles(List<Map<String,String>> articles){
        for (Map<String,String> article : articles){
            System.out.println("  id: " + article.get("id"));
            for (Map.Entry<String,String> entry : article.entrySet()){
                if (entry.getKey().equals("id")){
                    continue;
                }
                System.out.println("    " + entry.getKey() + ": " + entry.getValue());
            }
        }
    }

}