搜索

首页  >  问答  >  正文

flask - web消息通知中,如何用轮询redis来代替轮询数据库?

我想在自己的flask应用中实现简单的消息通知功能,例如管理员向全体用户发公告,或者想某个用户发出提醒等功能。

可是在实现过程中遇到了一个难题,情况具体描述如下:

我使用sse机制来使服务器向客户端发送消息,可是这里出现了问题,就是发送消息的模块并不知道什么时候应该发送消息,例如当用户A评论了用户B的博客时,这时就需要通知用户B,我们此时需要通知发送模块:“你该向B发送消息了”,如何通知发送模块呢?

我想到的就是轮询数据库,但是感觉这样太考验服务器的抗压了,百度到说:每当对应的数据表更新,就产生一个消息到Redis中,然后轮询Redis。

这样听起来挺好,可是在实现中遇到了很多问题:

例如:(1)redis是key-value存储,当管理员既要给A发消息,又要给B,C等发消息,此时用key该如何区分?

    (2)假设现在要给用户B发消息,那么会产生对应的消息存储在redis中,如果此刻
    用户B并未登录呢,难道用户B一周不登录,该消息就会在redis中一周吗?
    【我对redis不太了解,知道是在缓存中存储,所以感觉不可能在缓存中能存储一周】

思考两三天了,望各位前辈能够指点一二

曾经蜡笔没有小新曾经蜡笔没有小新2758 天前1344

全部回复(2)我来回复

  • 阿神

    阿神2017-04-27 09:05:46

    redis pub/sub 订阅/推送 ,是否考虑过使用这样或者更高级的消息队列中间件呢。

    基本逻辑是这样的,消息是需要缓存在数据库或者其他nosql的。
    拆分出消息中心,使用redis的pub/sub体系或者list,其他需要发送消息的通过redis通知消息中心发送消息。
    消息中心检查用户是否在线,在线直接发送消息给用户(通过websocket之类的,sse也可以),并标记已读
    用户在线是拉取全部未读消息
    无论在不在线消息都要入库。。。
    由于redis的value是字符串,要区分用户,你只要、value是个json字符串就好了。

    {
        "target":["a","b"],
        "message":"我是要发送给用户a和b的消息"
    }

    回复
    0
  • phpcn_u1582

    phpcn_u15822017-04-27 09:05:46

    key 放消息类型
    value放业务数据,比如序列化以后的dict,想要什么放什么,放多少都行,到时候取出来反序列化就可以直接用了

    回复
    0
  • 取消回复