PHP+Redis 实例【一】点赞 + 热度 上篇
本文内容纲要：
-前言
-直接写入Mysql
-缺点
-redis存储随后批量刷回数据库
-优点
-缺点
这次的开篇，算是总结下这段时间来的积累吧，废话不多说，直接干！
前言
点赞其实是一个很有意思的功能。基本的设计思路有大致两种，一种自然是用mysql（写了几百行的代码都还没写完，有毒）啦
数据库直接落地存储，另外一种就是利用点赞的业务特征来扔到redis(或memcache)中，然后离线刷回mysql等。
我这里所讲的功能都是基于我之前的项目去说的，所以有些地方可以不用管的，我主要是记录这个功能的实现思路，当你理解了，基本想用什么鬼语言写都一样的。
直接写入Mysql
直接写入Mysql是最简单的做法。
做三个表即可，
-
comment_info
记录文章的主要内容，主要有like_count,hate_count,score这三个字段是我们本次功能的主要字段。
-
comment_like
记录文章被赞的次数，已有多少人赞过这种数据就可以直接从表中查到;
-
user_like_comment
记录用户赞过了哪些文章，当打开文章列表时，显示的有没有赞过的数据就在这里面;
缺点
-
数据库读写压力大
热门文章会有很多用户点赞，甚至是短时间内被大量点赞，直接操作数据库从长久来看不是很理想的做法
redis存储随后批量刷回数据库
redis主要的特点就是快，毕竟主要数据都在内存嘛;
另外为啥我选择redis而不是memcache的主要原因在于redis支持更多的数据类型，例如hash,set,zset等。
下面具体的会用到这几个类型。
优点
-
性能高
-
缓解数据库读写压力
其实我更多的在于缓解写压力，真的读压力，通过mysql主从甚至通过加入redis对热点数据做缓存都可以解决，
写压力对于前面的方案确实是不大好使。
缺点
-
开发复杂
这个比直接写mysql的方案要复杂很多，需要考虑的地方也很多;
-
不能保证数据安全性
redis挂掉的时候会丢失数据，同时不及时同步redis中的数据，可能会在redis内存置换的时候被淘汰掉;
不过对于我们点赞而已，稍微丢失一点数据问题不大;
其实上面第二点缺点是可以避免的，这就涉及到redis的一些设计模式，不懂没关系，我尽量详细的写，后面我会给出如何解决这个缺点。
设计功能前知识准备
**1.将要用到的redis数据类型（具体的类型说明，请看底部链接，有详细说明）：**
-
zset这个类型主要用来做排序或者数字的增减，这里被用作like和hate的数字记录，以及热度的记录。
-
set这个是无序集合，主要用来记录今天需不需要更新，将今天被点赞（包括点讨厌）过的文章id记录下来，方便晚上或者有时间对这部分数据更新。
-
hash这个是散列，主要用来存储数据以及索引。这里被用来记录用户对哪个文章点了什么，方便下次判断（我看过一些网上的介绍使用set来记录，那个也可以，但是本人觉得这样做更省空间，以及方便管理，再有就是hash的速度快）。
-
list这个是队列大佬，我们的数据能不能安全回到mysql就靠它了。
2.关于热度如何去判断：
****大家都知道，文章获得点赞数越高，文章的热度就越高，那么怎么判断呢？不就直接记录点赞数就行啦，但是对于最新的文章怎么办？例如有一篇文章一年前发布的，获得50个赞，有篇最新文章获得49个赞，但是按照上面所说的一年前的文章热度还比最新的高，这就不合理了，文章都是时效性，谁都想看最新最热的。
so！我们要换个方法去处理这个时效性，绝大部分语言都有时间戳生成的方法，时间戳随着时间越新，数字越大，直接将时间戳初始化赋值给文章的score，这样最新的文章相比以前的文章就会靠前了。接着是点赞对score的影响，我们假设一天得到20个赞算是一天最热，一天60*60*24=86400秒，然后得到一个赞就是得到86400/20=4320分。具体数字看自己的业务需求定，我只是举例子而已。点hate当然也会减去相应的数字。
激动时刻！直接上代码了！里面有详细注释！
1<?php
2
3classGood
4{
5public$redis=null;
6
7//60*60*24/20=4320,每个点赞得到的分数，反之即之。
8public$score=4320;
9
10//点赞增加数，或者点hate增加数
11public$num=1;
12
13//initredis
14public$redis_host="127.0.0.1";
15public$redis_port="6379";
16public$redis_pass="";
17
18publicfunction__construct()
19{
20$this->redis=newRedis();
21$this->redis->connect($this->redis_host,$this->redis_port);
22$this->redis->auth($this->redis_pass);
23}
24
25/**
26*@paramint$user_id用户id
27*@paramint$type点击的类型1.点like，2.点hate
28*@paramint$comment_id文章id
29*@returnstringjson;
30*/
31publicfunctionclick($user_id,$type,$comment_id)
32{
33//判断redis是否已经缓存了该文章数据
34//使用：分隔符对redis管理是友好的
35//这里使用rediszset->zscore()方法
36if($this->redis->zscore("comment:like",$comment_id))
37{
38//已经存在
39//判断点的是什么
40if($type==1)
41{
42//判断以前是否点过，点的是什么？
43//redishash->hget()
44$rel=$this->redis->hget("comment:record",$user_id.":".$comment_id);
45if(!$rel)
46{
47//什么都没点过
48//点赞加1
49$this->redis->zincrby("comment:like",$this->num,$comment_id);
50//增加分数
51$this->redis->zincrby("comment:score",$this->score,$comment_id);
52//记录上次操作
53$this->redis->hset("comment:record",$user_id.":".$comment_id,$type);
54
55$data=array(
56"state"=>1,
57"status"=>200,
58"msg"=>"like+1",
59);
60}
61elseif($rel==$type)
62{
63//点过赞了
64//点赞减1
65$this->redis->zincrby("comment:like",-($this->num),$comment_id);
66//增加分数
67$this->redis->zincrby("comment:score",-($this->score),$comment_id);
68$data=array(
69"state"=>2,
70"status"=>200,
71"msg"=>"like-1",
72);
73}
74elseif($rel==2)
75{
76//点过hate
77//hate减1
78$this->redis->zincrby("comment:hate",-($this->num),$comment_id);
79//增加分数
80$this->redis->zincrby("comment:score",$this->score+$this->score,$comment_id);
81//点赞加1
82$this->redis->zincrby("comment:like",$this->num,$comment_id);
83//记录上次操作
84$this->redis->hset("comment:record",$user_id.":".$comment_id,$type);
85
86$data=array(
87"state"=>3,
88"status"=>200,
89"msg"=>"like+1",
90);
91}
92}
93elseif($type==2)
94{
95//点hate和点赞的逻辑是一样的。参看上面的点赞
96$rel=$this->redis->hget("comment:record",$user_id.":".$comment_id);
97if(!$rel)
98{
99//什么都没点过
100//点hate加1
101$this->redis->zincrby("comment:hate",$this->num,$comment_id);
102//减分数
103$this->redis->zincrby("comment:score",-($this->score),$comment_id);
104//记录上次操作
105$this->redis->hset("comment:record",$user_id.":".$comment_id,$type);
106
107$data=array(
108"state"=>4,
109"status"=>200,
110"msg"=>"hate+1",
111);
112}
113elseif($rel==$type)
114{
115//点过hate了
116//点hate减1
117$this->redis->zincrby("comment:hate",-($this->num),$comment_id);
118//增加分数
119$this->redis->zincrby("comment:score",$this->score,$comment_id);
120
121$data=array(
122"state"=>5,
123"status"=>200,
124"msg"=>"hate-1",
125);
126return$data;
127}
128elseif($rel==2)
129{
130//点过like
131//like减1
132$this->redis->zincrby("comment:like",-($this->num),$comment_id);
133//增加分数
134$this->redis->zincrby("comment:score",-($this->score+$this->score),$comment_id);
135//点hate加1
136$this->redis->zincrby("comment:hate",$this->num,$comment_id);
137
138$data=array(
139"state"=>6,
140"status"=>200,
141"msg"=>"hate+1",
142);
143return$data;
144}
145}
146}
147else
148{
149//未存在
150if($type==1)
151{
152//点赞加一
153$this->redis->zincrby("comment:like",$this->num,$comment_id);
154//分数增加
155$this->redis->zincrby("comment:score",$this->score,$comment_id);
156$data=array(
157"state"=>7,
158"status"=>200,
159"msg"=>"like+1",
160);
161}
162elseif($type==2)
163{
164//点hate加一
165$this->redis->zincrby("comment:hate",$this->num,$comment_id);
166//分数减少
167$this->redis->zincrby("comment:score",-($this->score),$comment_id);
168
169$data=array(
170"state"=>8,
171"status"=>200,
172"msg"=>"hate+1",
173);
174}
175//记录
176$this->redis->hset("comment:record",$user_id.":".$comment_id,$type);
177}
178
179//判断是否需要更新数据
180$this->ifUploadList($comment_id);
181
182return$data;
183}
184
185publicfunctionifUploadList($comment_id)
186{
187date_default_timezone_set("Asia/Shanghai");
188$time=strtotime(date('Y-m-dH:i:s'));
189
190if(!$this->redis->sismember("comment:uploadset",$comment_id))
191{
192//文章不存在集合里，需要更新
193$this->redis->sadd("comment:uploadset",$comment_id);
194//更新到队列
195$data=array(
196"id"=>$comment_id,
197"time"=>$time,
198);
199$json=json_encode($data);
200$this->redis->lpush("comment:uploadlist",$json);
201}
202}
203}
204
205//调用
206$user_id=100;
207$type=1;
208$comment_id=99;
209$good=newGood();
210$rel=$good->click($user_id,$type,$comment_id);
211var_dump($rel);
温馨提示：
1.上面代码只是一个实现的方法之一，里面的代码没精分过，适合大部分小伙伴阅读。用心看总有收获。
2.对于第三方接口，应该在外面包装多一层的，但是边幅有限，我就不做这么详细，提示，大家可以作为参考。
3.剩下的将数据返回数据的方法，等下篇再继续了。欢迎大家来交流心得。
redis手册中文版传送门：http://www.cnblogs.com/zcy_soft/archive/2012/09/21/2697006.html#string_INCR；
本文内容总结：前言，直接写入Mysql，缺点，redis存储随后批量刷回数据库，优点，缺点，
原文链接：https://www.cnblogs.com/sunshine-H/p/7922285.html