Redis在Laravel项目中的应用实例详解

lxw1844912514 发表于 2022/03/28 00:31:59 2022/03/28
【摘要】 https://mp.weixin.qq.com/s/axIgNPZLJDh9VFGVk7oYYA 正文内容 在初步了解Redis在Laravel中的应用 那么我们试想这样的一个应用场景 一个文章或者帖子的浏览次数的统计 如果只是每次增加一个浏览量 就到数据库新增一个数据 如果请求来那个太大这对数据库的消耗也就不言而喻...

https://mp.weixin.qq.com/s/axIgNPZLJDh9VFGVk7oYYA

正文内容

在初步了解Redis在Laravel中的应用 那么我们试想这样的一个应用场景 一个文章或者帖子的浏览次数的统计 如果只是每次增加一个浏览量

就到数据库新增一个数据 如果请求来那个太大这对数据库的消耗也就不言而喻了吧 那我们是不是可以有其他的解决方案

这里的解决方案就是 即使你的网站的请求量很大 那么每次增加一个访问量就在缓存中去进行更改 至于刷新Mysql数据库可以自定义为

多少分钟进行刷新一次或者访问量达到一定数量再去刷新数据库 这样数据也是准确的 效率也比直接每次刷新数据库要高出许多了

既然给出了相应的解决方案 我们就开始实施

我们以一篇帖子的浏览为例 我们先去创建对应的控制器

$ php artisan make:controller PostController

再去生成需要用到的 Model

$ php artisan make:model Post -m

填写posts的迁移表的字段内容

Schema::create('posts', function (Blueprint $table) {
 $table->increments('id');
 $table->string("title");
 $table->string("content");
 $table->integer('view_count')->unsigned();
 $table->timestamps();
});

还有就是我们测试的数据的Seeder填充数据

$factory->define(App\Post::class, function (Faker\Generator $faker) {
 return [
 'title' => $faker->sentence,
 'content' => $faker->paragraph,
 'view_count' => 0
 ];
});

定义帖子的访问路由

Route::get('/post/{id}', 'PostController@showPost');

当然我们还是需要去写我们访问也就是浏览事件的(在app/providers/EventServiceProvider中定义)


    
  1. protected $listen = [
  2. 'App\Events\PostViewEvent' => [
  3. // 'App\Listeners\EventListener',
  4. 'App\Listeners\PostEventListener',
  5. ],
  6. ];

执行事件生成监听

$ php artisan event:generate

之前定义了相关的路由方法 现在去实现一下:

 


    
  1. public function showPost(Request $request,$id)
  2. {
  3. //Redis缓存中没有该post,则从数据库中取值,并存入Redis中,该键值key='post:cache'.$id生命时间5分钟
  4. $post = Cache::remember('post:cache:'.$id, $this->cacheExpires, function () use ($id) {
  5. return Post::whereId($id)->first();
  6. });
  7. //获取客户端请求的IP
  8. $ip = $request->ip();
  9. //触发浏览次数统计时间
  10. event(new PostViewEvent($post, $ip));
  11. return view('posts.show', compact('post'));
  12. }

 

 
  

 

这里看的出来就是以Redis作为缓存驱动 同样的 会获取获取的ip目的是防止同一个ip多次刷新来增加浏览量

同样的每次浏览会触发我们之前定义的事件 传入我们的post和id参数

Redis的key的命名以:分割 这样可以理解为一个层级目录 在可视化工具里就可以看的很明显了

接下来就是给出我们的posts.show的视图文件


    
  1. <html lang="en">
  2. <head>
  3. <meta charset="utf-8">
  4. <meta http-equiv="X-UA-Compatible" content="IE=edge">
  5. <meta name="viewport" content="width=device-width, initial-scale=1">
  6. <title>Bootstrap Template</title>
  7. <!-- 新 Bootstrap 核心 CSS 文件 -->
  8. <link rel="stylesheet" href="//cdn.bootcss.com/bootstrap/3.3.5/css/bootstrap.min.css" rel="external nofollow" >
  9. <style>
  10. html,body{
  11. width: 100%;
  12. height: 100%;
  13. }
  14. *{
  15. margin: 0;
  16. border: 0;
  17. }
  18. .jumbotron{
  19. margin-top: 10%;
  20. }
  21. .jumbotron>span{
  22. margin: 10px;
  23. }
  24. </style>
  25. </head>
  26. <body>
  27. <div class="container">
  28. <div class="row">
  29. <div class="col-xs-12 col-md-12">
  30. <div class="jumbotron">
  31. <h1>Title:{{$post->title}}</h1>
  32. <span class="glyphicon glyphicon-eye-open" aria-hidden="true"> {{$post->view_count}} views</span>
  33. <p>Content:{{$post->content}}</p>
  34. </div>
  35. </div>
  36. </div>
  37. </div>
  38. <!-- jQuery文件-->
  39. <script src="//cdn.bootcss.com/jquery/1.11.3/jquery.min.js"></script>
  40. <!-- 最新的 Bootstrap 核心 JavaScript 文件 -->
  41. <script src="//cdn.bootcss.com/bootstrap/3.3.5/js/bootstrap.min.js"></script>
  42. <script>
  43. </script>
  44. </body>
  45. </html>

 

 
  

 

初始化我们的事件就是接收一下这些参数即可


    
  1. class PostViewEvent
  2. {
  3. use Dispatchable, InteractsWithSockets, SerializesModels;
  4. public $ip;
  5. public $post;
  6. /**
  7. * PostViewEvent constructor.
  8. * @param Post $post
  9. * @param $ip
  10. */
  11. public function __construct(Post $post, $ip)
  12. {
  13. $this->post = $post;
  14. $this->ip = $ip;
  15. }
  16. /**
  17. * Get the channels the event should broadcast on.
  18. *
  19. * @return Channel|array
  20. */
  21. public function broadcastOn()
  22. {
  23. return new PrivateChannel('channel-name');
  24. }
  25. }

最主要的还是编写我们的监听事件:

 


    
  1. class PostEventListener
  2. {
  3. /**
  4. * 一个帖子的最大访问数
  5. */
  6. const postViewLimit = 20;
  7. /**
  8. * 同一用户浏览同一个帖子的过期时间
  9. */
  10. const ipExpireSec = 200;
  11. /**
  12. * Create the event listener.
  13. *
  14. */
  15. public function __construct()
  16. {
  17. }
  18. /**
  19. * @param PostViewEvent $event
  20. */
  21. public function handle(PostViewEvent $event)
  22. {
  23. $post = $event->post;
  24. $ip = $event->ip;
  25. $id = $post->id;
  26. //首先判断下ipExpireSec = 200秒时间内,同一IP访问多次,仅仅作为1次访问量
  27. if($this->ipViewLimit($id, $ip)){
  28. //一个IP在300秒时间内访问第一次时,刷新下该篇post的浏览量
  29. $this->updateCacheViewCount($id, $ip);
  30. }
  31. }
  32. /**
  33. * 限制同一IP一段时间内得访问,防止增加无效浏览次数
  34. * @param $id
  35. * @param $ip
  36. * @return bool
  37. */
  38. public function ipViewLimit($id, $ip)
  39. {
  40. $ipPostViewKey = 'post:ip:limit:'.$id;
  41. //Redis命令SISMEMBER检查集合类型Set中有没有该键,Set集合类型中值都是唯一
  42. $existsInRedisSet = Redis::command('SISMEMBER', [$ipPostViewKey, $ip]);
  43. //如果集合中不存在这个建 那么新建一个并设置过期时间
  44. if(!$existsInRedisSet){
  45. //SADD,集合类型指令,向ipPostViewKey键中加一个值ip
  46. Redis::command('SADD', [$ipPostViewKey, $ip]);
  47. //并给该键设置生命时间,这里设置300秒,300秒后同一IP访问就当做是新的浏览量了
  48. Redis::command('EXPIRE', [$ipPostViewKey, self::ipExpireSec]);
  49. return true;
  50. }
  51. return false;
  52. }
  53. /**
  54. * 达到要求更新数据库的浏览量
  55. * @param $id
  56. * @param $count
  57. */
  58. public function updateModelViewCount($id, $count)
  59. {
  60. //访问量达到300,再进行一次SQL更新
  61. $post = Post::find($id);
  62. $post->view_count += $count;
  63. $post->save();
  64. }
  65. /**
  66. * 不同用户访问,更新缓存中浏览次数
  67. * @param $id
  68. * @param $ip
  69. */
  70. public function updateCacheViewCount($id, $ip)
  71. {
  72. $cacheKey = 'post:view:'.$id;
  73. //这里以Redis哈希类型存储键,就和数组类似,$cacheKey就类似数组名 如果这个key存在
  74. if(Redis::command('HEXISTS', [$cacheKey, $ip])){
  75. //哈希类型指令HINCRBY,就是给$cacheKey[$ip]加上一个值,这里一次访问就是1
  76. $save_count = Redis::command('HINCRBY', [$cacheKey, $ip, 1]);
  77. //redis中这个存储浏览量的值达到30后,就去刷新一次数据库
  78. if($save_count == self::postViewLimit){
  79. $this->updateModelViewCount($id, $save_count);
  80. //本篇post,redis中浏览量刷进MySQL后,就把该篇post的浏览量清空,重新开始计数
  81. Redis::command('HDEL', [$cacheKey, $ip]);
  82. Redis::command('DEL', ['laravel:post:cache:'.$id]);
  83. }
  84. }else{
  85. //哈希类型指令HSET,和数组类似,就像$cacheKey[$ip] = 1;
  86. Redis::command('HSET', [$cacheKey, $ip, '1']);
  87. }
  88. }
  89. }

文章来源: blog.csdn.net,作者:lxw1844912514,版权归原作者所有,如需转载,请联系作者。

原文链接:blog.csdn.net/lxw1844912514/article/details/100028829

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:cloudbbs@huaweicloud.com进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。