Redis在项目中的几种使用

今天来讲一讲项目中使用redis的几种用法

实现赞踩

可以使用集合或者哈希表来完成赞踩
使用集合的sadd和srem来完成时，首先我们需要创建两个集合，一个赞集合，一个踩集合

• 点赞时：向赞集合添加该用户，删除踩集合中的该用户
• 踩时：向踩集合添加该用户，删除赞集合中的该用户
• demo:

public class JedisDemo {

    private static Jedis jedis = new Jedis("127.0.0.1", 6379);
    private static String  like = "like:entity1";
    private static String disLike = "disLike:entity1";

    public static void main(String[] args) {
        System.out.println("like: " + like("user1"));
        System.out.println("disLike: " + disLike("user1"));
    }

    public static long like(String userId) {
        jedis.sadd(like, userId);
        jedis.srem(disLike, userId);
        return jedis.scard(like);
    }

    public static long disLike(String userId) {
        jedis.sadd(disLike, userId);
        jedis.srem(like, userId);
        return jedis.scard(disLike);
    }
}

实现生产者消费者模式

可以使用列表的lpush,brpop来实现，如果要实现安全模式，则使用rpoplpush

• 生产者使用lpush将消息放入列表中
• 消费者使用brpop阻塞的从列表中取出消息
• demo

public class JedisDemo {

    private static ExecutorService executor = Executors.newCachedThreadPool();

    public static void main(String[] args) {

        executor.execute(() -> {
            try {
                for (int i = 1; i <= 10; i++) {
                    publish("message: " + i);
                    Thread.sleep(100);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        });

        executor.execute(() -> {
            while (true) {
                subscribe();
            }
        });

    }

    public static void publish(String message) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        jedis.lpush("test", message);
    }

    public static void subscribe() {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        List<String> test = jedis.brpop(1, "test");
        if (test.isEmpty()) {
            return;
        }
        System.out.println(test);
    }
}

计数器的使用

我们可以使用incr作为计数器来统计访问次数等操作

• demo：

public class JedisDemo {

    private static Jedis jedis = new Jedis("127.0.0.1", 6379);

    public static void main(String[] args) {
        jedis.set("people", "1");
        for (int i = 0; i < 10; i++) {
            view();
        }
        System.out.println(jedis.get("people"));
    }

    public static void view() {
        jedis.incr("people");
    }

}

统计用户一段时间内的上线次数

可以使用setbit和bitcount来进行统计上线次数

• 使用setbit在指定的天将该位置为1
• 使用bitcount统计登录天数
• demo：

public class JedisDemo {

    private static Jedis jedis = new Jedis("127.0.0.1", 6379);

    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            if (i % 2 == 0) {
                login(i);
            }
        }
        System.out.println(jedis.bitcount("login"));
    }

    public static void login(long day) {
        jedis.setbit("login", day, true);
    }

}

RDB和AOF持久化的区别

• RDB：定期提交save进行备份
  • 优点：
    • 文件紧凑，体积较小
    • 适合灾难恢复
    • 可最大化redis的性能
    • 恢复数据速度比aof快
  • 缺点：
    • 有可能会丢失数据(未到保存点时，发生故障)
    • 每次保存时需要fork出一个子进程，数据较大时，停止时间较长
• AOF：持续用日志记录些操作，crash后利用日志进行恢复
  • 优点：
    • 使redis变得更加耐久，不会丢失数据
    • 对日志是追加操作，不需要seek
    • 可以在提交较大时自动在后台进行重写
    • 有序的保证了所有写入操作
  • 缺点：
    • 体积大于rdb
    • 在处理巨大的写入载入时，RDB 可以提供更有保证的最大延迟时间
    • 重新载入时，可能无法将数据集恢复成保存时的原样

今天的分享到这里就结束了，愿我们每一天都不会忘记自己的梦想，每天都会明白我们所想要的是什么

曾经我们梦想离乡，而当那天真正到来时，我们却无尽的思乡