Redis 应用场景简介

Jastar Wang2018/8/16大约 8 分钟

Redis 应用场景简介

1、发布与订阅

在更新中保持用户对数据的映射是系统中的一个普遍任务。Redis 的 pub/sub 功能使用了 SUBSCRIBE、UNSUBSCRIBE 和 PUBLISH 命令，让这个变得更加容易。

// 订阅频道数据
public static void testSubscribe() {
    //连接Redis数据库
    Jedis jedis = new Jedis("192.168.33.130", 6379);
    JedisPubSub jedisPubSub = new JedisPubSub() {
        // 当向监听的频道发送数据时，这个方法会被触发
        @Override
        public void onMessage(String channel, String message) {
            System.out.println("收到消息" + message);
            //当收到 "unsubscribe" 消息时，调用取消订阅方法
            if ("unsubscribe".equals(message)) {
                this.unsubscribe();
            }
        }
        // 当取消订阅指定频道的时候，这个方法会被触发
        @Override
        public void onUnsubscribe(String channel, int subscribedChannels) {
            System.out.println("取消订阅频道" + channel);
        }
    };
    // 订阅之后，当前进程一致处于监听状态，当被取消订阅之后，当前进程会结束
    jedis.subscribe(jedisPubSub, "ch1");
}
 
// 发布频道数据
public static void testPubSub() throws Exception {
    //链接Redis数据库
    Jedis jedis = new Jedis("192.168.33.130", 6379);
    //发布频道 "ch1" 和消息 "hello redis"
    jedis.publish("ch1", "hello redis");
    //关闭连接
    jedis.close();
}

打印结果：

收到消息hello redis

2、限制网站访客访问频率

进行各种数据统计的用途是非常广泛的，比如想知道什么时候封锁一个 IP 地址。INCRBY 命令让这些变得很容易，通过原子递增保持计数；GETSET 用来重置计数器；过期属性 expire 用来确认一个关键字什么时候应该删除。

//指定Redis数据库连接的IP和端口
String host = "192.168.33.130";
int port = 6379;
Jedis jedis = new Jedis(host, port);
/**
 * 限制网站访客访问频率 一分钟之内最多访问10次
 *
 * @throws Exception
 */
@Test
public void test3() throws Exception {
    // 模拟用户的频繁请求
    for (int i = 0; i < 10; i++) {
        boolean result = testLogin("127.0.0.1");
        if (result) {
            System.out.println("正常访问");
        } else {
            System.err.println("访问受限");
        }
    }
}
/**
 * 判断用户是否可以访问网站
 *
 * @param ip
 * @return
 */
public boolean testLogin(String ip) {
    String value = jedis.get(ip);
    if (value == null) {
        //初始化时设置IP访问次数为1
        jedis.set(ip, "1");
        //设置IP的生存时间为60秒，60秒内IP的访问次数由程序控制
        jedis.expire(ip, 60);
    } else {
        int parseInt = Integer.parseInt(value);
        //如果60秒内IP的访问次数超过5，返回false,实现了超过5次禁止分的功能
        if (parseInt > 5) {
            return false;
        } else {
            //如果没有5次，可以自增
            jedis.incr(ip);
        }
    }
    return true;
}

打印结果：

正常访问
正常访问
正常访问
正常访问
正常访问
访问受限
访问受限
访问受限
访问受限
访问受限

3、监控变量在事务执行时是否被修改

// 指定Redis数据库连接的IP和端口
String host = "192.168.33.130";
int port = 6379;
Jedis jedis = new Jedis(host, port);
/**
 * 监控变量a在一段时间内是否被修改，若没有，则执行事务，若被修改，则事务不执行
 *
 * @throws Exception
 */
@Test
public void test4() throws Exception {
    //监控变量a，在事务执行后watch功能也结束
    jedis.watch("a");
    //需要数据库中先有a，并且a的值为字符串数字
    String value = jedis.get("a");
    int parseInt = Integer.parseInt(value);
    parseInt++;
    System.out.println("线程开始休息。。。");
    Thread.sleep(5000);
    //开启事务
    Transaction transaction = jedis.multi();
    transaction.set("a", parseInt + "");
    //执行事务
    List<Object> exec = transaction.exec();
    if (exec == null) {
        System.out.println("事务没有执行.....");
    } else {
        System.out.println("正常执行......");
    }
}

打印结果：

变量a没有被修改时：

线程开始休息。。。
正常执行......

变量a被修改时：

线程开始休息。。。
事务没有执行.....

4、各种计数

商品维度计数（喜欢数，评论数，鉴定数，浏览数,etc）

采用Redis 的类型: Hash. 如果你对redis数据类型不太熟悉，可以参考 http://redis.io/topics/data-types-intro

为product定义个key product:，为每种数值定义hashkey, 譬如喜欢数xihuan

用户维度计数（动态数、关注数、粉丝数、喜欢商品数、发帖数等）

用户维度计数同商品维度计数都采用 Hash. 为User定义个key user:，为每种数值定义hashkey, 譬如关注数follow

5、存储社交关系

譬如将用戶的好友/粉丝/关注，可以存在一个sorted set中，score可以是timestamp，这样求两个人的共同好友的操作，可能就只需要用求交集命令即可。

6、用作缓存代替 memcached

缓存内容示例：（商品列表，评论列表，@提示列表，etc）

相对memcached 简单的key-value存储来说，redis众多的数据结构（list,set,sorted set,hash, etc）可以更方便cache各种业务数据，性能也不亚于memcached。

例如：

RPUSH pagewviews.user: EXPIRE pagewviews.user: 60  //注意要update timeout

作为一个电商网站被各种spam攻击是少不免（垃圾评论、发布垃圾商品、广告、刷自家商品排名等），针对这些spam制定一系列anti-spam规则，其中有些规则可以利用redis做实时分析，譬如：1分钟评论不得超过2次、5分钟评论少于5次等（更多机制/规则需要结合drools ）。采用sorted set将最近一天用户操作记录起来（为什么不全部记录？节省memory，全部操作会记录到log，后续利用hadoop进行更全面分析统计），通过：

redis> RANGEBYSCORE user:200000:operation:comment 61307510405600 +inf    //获得1分钟内的操作记录 
redis> ZADD user:200000:operation:comment 61307510402300 "这是一条评论"  //score 为timestamp (integer) 1 
redis> ZRANGEBYSCORE user:200000:operation:comment 61307510405600 +inf   //获得1分钟内的操作记录

打印结果：

"这是一条评论"

本文来自：技术团队=>技术分享=>Redis应用场景简介

Redis 应用场景简介

Redis 应用场景简介

1、发布与订阅

2、限制网站访客访问频率

3、监控变量在事务执行时是否被修改

4、各种计数

5、存储社交关系

6、用作缓存代替 memcached

7、反 spam 系统

8、用户 Timeline/Feeds

9、消息通知

10、消息队列

11、显示最新的项目列表

12、删除和过滤。

13、排行榜及相关问题

14、按照用户投票和时间排序

15、过期项目处理

16、特定时间内的特定项目

17、实时分析

18、队列

19、缓存

20、手机验证码