文档章节

Redis实现信息已读未读状态提示

清尘V
 清尘V
发布于 2016/04/14 21:04
字数 433
阅读 1785
收藏 50

前提:

假如现在有2个模块需要提示消息:只要存在用户在上个时间点之后没有看过的信息就提示用户有新的信息

思路如下:

使用hash存储用户上次看过的时间,使用sortedset存储每个模块的每个信息产生的时间


上代码:

Map<String, String> dataMap = new HashMap<>();

Jedis jedis=null;
String uid="1";//用户id
//分类数组
String []cagoryArray={"c1","c2"};
try {
    //连接池获取连接 jedis=
    //此处获取用户的操作时间集合
    Map<String, String> map = jedis.hgetAll("u-key-"+uid);
    if (map == null) {
        map = new HashMap<>();
    }
    for (String value : cagoryArray) {
        //获取某个分类下的上次操作时间
        String s = map.get(value);
        if (StringUtils.isBlank(s)) {
            //如果不存在,则设为有新信息
            dataMap.put(value, "1");
        } else {
            //计算从上次操作时间到现在的新的信息数量
            Long zcount = jedis.zcount("c-key-"+value, Double.parseDouble(s), System.currentTimeMillis());
            if (zcount == null || zcount <= 0) {
                //不存在或者小于等于0  则没有新的信息
                dataMap.put(value, "0");
            } else {
                dataMap.put(value, "1");
            }
        }

    }

}finally {
    if(jedis!=null){
        //归还连接
    }
}

当有新的信息产生,向相关模块添加时间:

Jedis jedis=null;
//c1模块有新的信息
String cid="c1";

try {
    //连接池获取连接 jedis=

    //添加到sortedset结果  权重为时间毫秒
    long currentTimeMillis = System.currentTimeMillis();
    jedis.zadd("c-key-"+cid, currentTimeMillis, String.valueOf(currentTimeMillis));

}finally {
    if(jedis!=null){
        //归还连接
    }
}



当用户点击某个模块时,更新用户查看该模块的上次时间

Jedis jedis=null;
//c1模块有新的信息
String cid="c1";
//用户id
String uid="1";

try {
    //连接池获取连接 jedis=

    //添加到sortedset结果  权重为时间毫秒
    jedis.hset("u-key-"+uid, cid, String.valueOf(System.currentTimeMillis()));

}finally {
    if(jedis!=null){
        //归还连接
    }
}


个人博客:http://www.whereta.com

© 著作权归作者所有

共有 人打赏支持
上一篇: HashMap源码理解
下一篇: Java SPI机制
清尘V
粉丝 41
博文 107
码字总数 47780
作品 0
青岛
程序员
私信 提问
我想了几天,我想知道在大量数据读写下怎么取出完整的用户未读消息

我在用netty做一个IM的东西,我对于大量数据的聊天消息我选择是用MQ做异步写入数据库,但是有个问题,我想实现未读已读功能,于是直接在消息表中加了个状态字段,表示未读已读,如果对方用户...

助哥的后花园
01/30
0
0
C# DataGridView 对指定行文字加粗实现阅读标记

在使用DataGridView控件放置通知等信息时,会遇到标记“已读”、“未读”的问题。通过SQL语句查询出的结果中,“已读”、“未读”会被放在一个专门的字段(DataGridView的列)中用来标记这个...

北风其凉
2015/07/29
613
0
用redis实现社交产品中计数器

用redis实现计数器 社交产品业务里有很多统计计数的功能,比如: 用户: 总点赞数,关注数,粉丝数 帖子: 点赞数,评论数,热度 消息: 已读,未读,红点消息数 话题: 阅读数,帖子数,收藏...

凯文加内特
2015/07/15
0
0
阿里云Redis混合存储典型场景:如何轻松搭建视频直播间系统

本文主要介绍视频直播间系统,以及如何使用阿里云Redis混合存储实例方便快捷的构建大数据量,低延迟的视频直播间服务。 背景 视频直播间作为直播系统对外的表现形式,在整个系统中处于核心地...

怀听
04/17
0
0
设计篇--站内信设计思路之己见(基于上百万用户)

大家都知道站内信,分为少量(10-999用户),中量(1000-99999用户),大量(100W用户)不同的站内信架构,消耗存储空间,和效率也是不同的。 本人基于最大的架构,来于大家共同讨论,站内信...

Yomut
2016/08/29
88
0

没有更多内容

加载失败,请刷新页面

加载更多

Win10:默认的图片打开应用,打开图片时速度明显很慢的解决办法

首先,我们随便地打开一张图片。然后,点击右上角的三个小点,最后点击弹出菜单最下面的“设置”。如下图: 在“设置”中找到下面的“人物”,把它关掉就好了。 原来,默认情况下,Win 10的图...

LivingInFHL
56分钟前
2
0
js代码激发onchange事件,兼容谷歌火狐IE

var el = document.getElementsByName('role')[0]; el.value = '3'; var evt = document.createEvent("HTMLEvents"); evt.initEvent("change", false, true); el.dispatchEvent(evt);......

我退而结网
今天
3
0
mysql客户端报错:libmysqlclient_16 not defined in file libmysqlclient.so.16

报错情况: 安装完mydumper之后(上一篇文章),登陆Mysql客户端报错:version libmysqlclient_16 not defined in file libmysqlclient.so.16 with link time reference 同样:mysql的其他客...

machogyb
今天
1
0
MySQL 数据库中间件 安装部署测试全过程

1、环境准备 1.1、操作系统环境 [root@MyCat conf]# uname -aLinux MyCat 2.6.32-431.el6.x86_64 #1 SMP Sun Nov 10 22:19:54 EST 2013 x86_64 x86_64 x86_64 GNU/Linux 1.2、关闭SELIN......

PeakFang-BOK
今天
6
0
Linux Mysql 安装

https://www.cnblogs.com/xinjing-jingxin/p/8025805.html

流氓兔-
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部