PHP+redis实现微博的拉模型案例详解-6ren

PHP+redis实现微博的拉模型案例详解

转载作者：qq735679552 更新时间：2022-09-29 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章PHP+redis实现微博的拉模型案例详解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

本文实例讲述了PHP+redis实现微博的拉模型。分享给大家供大家参考，具体如下:

上回写了一篇推模型的内容，这回分享一篇拉模型的内容.

拉模型。

拉模型就是展示微博的时候，获取自己的所有关注的人，然后从关注的人中拉取最新微博.

微博项目数据结构设计。

user表设计。

注册的时候将user数据写入redis中，key如下:

user数据的key 用户名=user:uesrid:$uesrid:username 密码=user:userid:$userid:password 。

还需要这样写一份，因为需要靠用户名来登录，这样就可以根据用户名来查询用户id.

 
    ? 
   
         user:username:userid: 
         $userid

关注的人和粉丝设计。

每个用户在产生关注的动作后，在redis中维护两个无序集合set,一个是following，一个是follower，following集合保存的是我关注的人，follower集合保存的是我的粉丝。注意是每个用户都要维护这样的两个集合，用userid来区别.

单条微博表设计。

每条微博的信息用hash结构来存储，根据不同的微博id来区分，每条微博有如下信息：发布人id，发布人昵称，发布时间，微博内容.

拉取关注者微博表设计。

每个用户发布微博后，维护20条最新微博，并保存到有序集合sorted set中，用不同的userid来区分.

注意：有序集合的score用微博id，集合保存的也是微博id.

个人微博表。

每个用户维护自己的微博，保存到链表中，只保存1000条，redis中只保存1000条微博数据，如果想查询更多，去数据库中查询.

个人已拉取表设计。

每个用户在拉取微博后，将微博保存到已经拉取的表中，这个表是一个链表结构，最多保存1000条微博.

发布微博。

首先将微博保存成hash结构，然后将微博保存到拉取表，还保存到个人微博表.

 
    ? 
   
 
     
       
       
         //1、保存微博 
        
 
         $conn 
         = connredis(); 
        
 
         $postid 
         =  
         $conn 
         ->incr( 
         'global:postid' 
         ); 
        
 
         $conn 
         ->hmset( 
         'post:postid:' 
         . 
         $postid 
         ,[ 
         'userid' 
         => 
         $user 
         [ 
         'userid' 
         ], 
         'username' 
         => 
         $user 
         [ 
         'username' 
         ], 
         'time' 
         =>time(), 
         'content' 
         => 
         $content 
         ]); 
        
 
         //2、每个人维护20条最新微博，保存到有序集合中 
        
 
         $conn 
         ->zadd( 
         'starpost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ], 
         $postid 
         , 
         $postid 
         ); 
        
 
         if 
         ( 
         $conn 
         ->zcard( 
         'starpost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ]) > 20){ 
        
 
            
         $conn 
         ->zremrangebyrank( 
         'starpost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ],0,0); 
        
 
         } 
        
 
         //3、维护个人的1000条微博，保存到链表中 
        
 
         $conn 
         ->lpush( 
         'mypost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ], 
         $postid 
         ); 
        
 
         if 
         ( 
         $conn 
         ->llen( 
         'mypost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ]) > 1000){ 
        
 
            
         $conn 
         ->rpoplpush( 
         'mypost:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ], 
         'global:post' 
         ); 
        
 
         } 
        
 
     
 
   

展示微博。

首先获取所有关注的人，获取上次拉取微博的位置，根据上次拉取的微博位置来拉取数据。然后给微博排序，设置新的拉取的位置，写入到已拉取表中，获取微博的详细内容，最后获取粉丝和关注数。进行展示即可.

 
    ? 
   
 
     
       
       
         //1、获取拉取对象 
        
 
         $stars 
         =  
         $conn 
         ->smembers( 
         'following:' 
         . 
         $user 
         [ 
         'userid' 
         ]); 
         //获取所有关注的人 
        
 
         $stars 
         [] =  
         $user 
         [ 
         'userid' 
         ]; 
         //需要拉取自己的微博 
        
 
         //2、获取上次拉取的位置 
        
 
         $lastpull 
         =  
         $conn 
         ->get( 
         'lastpull:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ]); 
        
 
         if 
         (! 
         $lastpull 
         ){ 
        
 
         $lastpull 
         = 0; 
        
 
         } 
        
 
         //3、拉取微博  
        
 
         $latest 
         = []; 
        
 
         foreach 
         ( 
         $stars 
         as 
         $star 
         ){ 
        
 
         $latest 
         =  
         array_merge 
         ( 
         $latest 
         , 
         $conn 
         ->zrangebyscore( 
         'starpost:userid:' 
         . 
         $star 
         , 
         $lastpull 
         +1,1<<32-1)); 
        
 
         } 
        
 
         //4、给微博排序 
        
 
         sort( 
         $latest 
         ,SORT_NUMERIC); 
        
 
         //5、设置拉取的位置 
        
 
         if 
         (! 
         empty 
         ( 
         $latest 
         )){ 
        
 
            
         $conn 
         ->set( 
         'lastpull:userid:' 
         . 
         $user 
         [ 
         'userid' 
         ], 
         end 
         ( 
         $latest 
         )); 
        
 
         } 
        
 
         //6、写入到已拉取表中 
        
 
         foreach 
         ( 
         $latest 
         as 
         $l 
         ){ 
        
 
            
         $conn 
         ->lpush( 
         'receivepost:' 
         . 
         $user 
         [ 
         'userid' 
         ], 
         $l 
         ); 
        
 
         } 
        
 
         $conn 
         ->ltrim( 
         'receivepost:' 
         . 
         $user 
         [ 
         'userid' 
         ],0,999); 
         //至多显示1000条微博 
        
 
         //7、获取微博的详细内容 
        
 
         $postids 
         =  
         $conn 
         ->sort( 
         'receivepost:' 
         . 
         $user 
         [ 
         'userid' 
         ],[ 
         'sort' 
         => 
         'desc' 
         ]); 
        
 
         $posts 
         = []; 
        
 
         foreach 
         ( 
         $postids 
         as 
         $postid 
         ){ 
        
 
            
         $posts 
         [] =  
         $conn 
         ->hmget( 
         'post:postid:' 
         . 
         $postid 
         ,[ 
         'userid' 
         , 
         'username' 
         , 
         'time' 
         , 
         'content' 
         ]); 
        
 
         } 
        
 
         //8、获取粉丝和关注数 
        
 
         $fansnum 
         =  
         $conn 
         ->scard( 
         'follower:' 
         . 
         $user 
         [ 
         'userid' 
         ]); 
        
 
         $follownum 
         =  
         $conn 
         ->scard( 
         'following:' 
         . 
         $user 
         [ 
         'userid' 
         ]); 
        
 
     
 
   

Q&A 。

如何保证拉取的数据时最新的?

在拉取的时候，将最近拉取的微博id保存到redis中，然后下次我们只需要去拉取比这次保存的微博id大的微博，就可以保证拉取的数据是之前没有拉取的.

如何拉取所有关注者的数据?

遍历关注者，然后拉取数据。

假设拉取A关注者的微博1,4,5 B关注者2,3,但是他们的发布时间交错，怎么展示数据?

将所有关注者的最新微博都取出来，然后根据微博id进行排序.

希望本文所述对大家PHP程序设计有所帮助.

原文链接：https://blog.csdn.net/baochao95/article/details/73183753 。

最后此篇关于PHP+redis实现微博的拉模型案例详解的文章就讲到这里了,如果你想了解更多关于PHP+redis实现微博的拉模型案例详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐： Swoole 5将移除自动添加Event::wait()特性详解

文章推荐：浅议NetMQ常见模式和消息加密机制

文章推荐：搜索算法，一触即达：GitHub上有个规模最大的开源算法库

文章推荐： php解压缩zip和rar压缩包文件的方法

jstat 详解
全称“Java Virtual Machine statistics monitoring tool”（statistics 统计；monitoring 监控；tool 工具）用于监控虚拟机的各种运
MongoDB索引操作和执行计划Explain()详解
主要是讲下Mongodb的索引的查看、创建、删除、类型说明，还有就是Explain执行计划的解释说明。可以转载，但请注明出处。
Linux下几种并发服务器的实现模式(详解)
1>单线程或者单进程相当于短链接，当accept之后，就开始数据的接收和数据的发送，不接受新的连接，即一个server，一个client 不存在并发。 2>循环服务器和并发服务器
详解 Linux中的关机和重启命令
详解 linux中的关机和重启命令一 shutdown命令 shutdown [选项] 时间选项： ?
用Newtonsoft将json串转为对象的方法(详解)
首先，将json串转为一个JObject对象： ? 1
Python画图常用命令大全(详解)
matplotlib官网 matplotlib库默认英文字体添加黑体（‘SimHei'）为绘图字体代码： plt.rcParams['font.sans-serif']=['SimHei'
Java中的关键字synchronized 详解
在并发编程中，synchronized关键字是常出现的角色。之前我们都称呼synchronized关键字为重量锁，但是在jdk1.6中对synchronized进行了优化，引入了偏向锁、轻量锁。本篇
详解.NET数据库连接池
一般我们的项目中会使用1到2个数据库连接配置，同程艺龙的数据库连接配置被收拢到统一的配置中心，由DBA统一配置和维护，业务方通过某个字符串配置拿到的是Connection对象。
linux下gettimeofday函数windows替换方法(详解)
实例如下： ? 1
详解.Net缓存之MemoryCahe
1. MemoryCahe NetCore中的缓存和System.Runtime.Caching很相似，但是在功能上做了增强，缓存的key支持object类型；提供了泛型支持；可以读缓存和单个缓存
Javascript基础教程之argument 详解
argument是javascript中函数的一个特殊参数，例如下文，利用argument访问函数参数，判断函数是否执行复制代码代码如下: <script
linux中了minerd之后的完全清理过程(详解)
一不小心装了一个Redis服务，开了一个全网的默认端口，一开始以为这台服务器没有公网ip，结果发现之后悔之莫及啊某天发现cpu load高的出奇，发现一个minerd进程占了大量cpu，googl
基于php编程规范(详解)
今天写这个是为了提醒自己编程过程不仅要有逻辑思想还有要规范代码这样可读性 1、PHP 编程规范与编码习惯最主要的有以下几点： 1 文件说明 2 funct
使用yum查看工具lspci所在包并安装的方法(详解)
摘要：虚拟机安装时一般都采用最小化安装，默认没有lspci工具。一台测试虚拟网卡性能的虚拟机，需要lspci工具来查看网卡的类型。本文描述了在一个虚拟机中安装lspci工具的具体步骤。由于要测试
Linux下高并发socket最大连接数所受的各种限制(详解)
1、修改用户进程可打开文件数限制在Linux平台上，无论编写客户端程序还是服务端程序，在进行高并发TCP连接处理时，最高的并发数量都要受到系统对用户单一进程同时可打开文件数量的限制(这是因为系统
一篇文章带你入门java运算符(详解)
目录算术运算符基本四则运算符增量赋值运算符自增/自减运算符关系运算符逻
PHP面向对象之事务脚本模式(详解)
如下所示： ? 1
详解 MapperScannerConfigurer之sqlSessionFactory注入方式
MapperScannerConfigurer之sqlSessionFactory注入方式讲解首先，Mybatis中的有一段配置非常方便，省去我们去写DaoImpl（Dao层实现类）的时间，这个
详解：Linux网络虚拟化技术
Linux的网络虚拟化是LXC项目中的一个子项目，LXC包括文件系统虚拟化，进程空间虚拟化，用户虚拟化，网络虚拟化，等等，这里使用LXC的网络虚拟化来模拟多个网络环境。本文从基本的网络设备讲
highchart数据源纵轴json内的值必须是int(详解)
? 1

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

PHP+redis实现微博的拉模型案例详解