微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

前言

本文主要给大家介绍了关于Redis在Laravel项目中的应用实例,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍:

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

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

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

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

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

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

rush:PHP;"> $ PHP artisan make:controller PostController

再去生成需要用到的 Model

rush:PHP;"> $ PHP artisan make:model Post -m

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

increments('id'); $table->string("title"); $table->string("content"); $table->integer('view_count')->unsigned(); $table->timestamps(); });

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

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

定义帖子的访问路由

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

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

[ // 'App\Listeners\EventListener','App\Listeners\PostEventListener',],];

执行事件生成监听

rush:PHP;"> $ PHP artisan event:generate

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

cacheExpires,function () use ($id) { return Post::whereId($id)->first(); });

//获取客户端请求的IP
$ip = $request->ip();

//触发浏览次数统计时间
event(new PostViewEvent($post,$ip));

return view('posts.show',compact('post'));
}

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

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

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

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

rush:xhtml;"> <Meta charset="utf-8"> <Meta http-equiv="X-UA-Compatible" content="IE=edge"> <Meta name="viewport" content="width=device-width,initial-scale=1"> Bootstrap Template
Title:{{$post->title}}

Content:{{$post->content}}

<script src="//cdn.bootcss.com/jquery/1.11.3/jquery.min.js">

<script src="//cdn.bootcss.com/bootstrap/3.3.5/js/bootstrap.min.js">

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

public $ip;
public $post;

/**

  • PostViewEvent constructor.
  • @param Post $post
  • @param $ip
    */
    public function __construct(Post $post,$ip)
    {
    $this->post = $post;
    $this->ip = $ip;
    }

/**

  • Get the channels the event should broadcast on.
  • @return Channel|array
    */
    public function broadcastOn()
    {
    return new PrivateChannel('channel-name');
    }
    }

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

  • 一个帖子的最大访问数
    */
    const postViewLimit = 20;
  • /**

    • 同一用户浏览同一个帖子的过期时间
      */
      const ipExpireSec = 200;

    /**

    • Create the event listener.
    • */
      public function __construct()
      {

    }

    /**

    • @param PostViewEvent $event
      */
      public function handle(PostViewEvent $event)
      {
      $post = $event->post;
      $ip = $event->ip;
      $id = $post->id;
      //首先判断下ipExpireSec = 200秒时间内,同一IP访问多次,仅仅作为1次访问量
      if($this->ipViewLimit($id,$ip)){
      //一个IP在300秒时间内访问第一次时,刷新下该篇post的浏览量
      $this->updateCacheViewCount($id,$ip);
      }
      }

    /**

    • 限制同一IP一段时间内得访问,防止增加无效浏览次数
    • @param $id
    • @param $ip
    • @return bool
      */
      public function ipViewLimit($id,$ip)
      {
      $ipPostViewKey = 'post:ip:limit:'.$id;
      //Redis命令SISMEMBER检查集合类型Set中有没有该键,Set集合类型中值都是唯一
      $existsInRedisSet = Redis::command('SISMEMBER',[$ipPostViewKey,$ip]);
      //如果集合中不存在这个建 那么新建一个并设置过期时间
      if(!$existsInRedisSet){
      //SADD,集合类型指令,向ipPostViewKey键中加一个值ip
      Redis::command('SADD',$ip]);
      //并给该键设置生命时间,这里设置300秒,300秒后同一IP访问就当做是新的浏览量了
      Redis::command('EXPIRE',self::ipExpireSec]);
      return true;
      }
      return false;
      }

    /**

    • 达到要求更新数据库的浏览量
    • @param $id
    • @param $count
      */
      public function updateModelViewCount($id,$count)
      {
      //访问量达到300,再进行一次sql更新
      $post = Post::find($id);
      $post->view_count += $count;
      $post->save();
      }

    /**

    • 不同用户访问,更新缓存中浏览次数
    • @param $id
    • @param $ip
      */
      public function updateCacheViewCount($id,$ip)
      {
      $cacheKey = 'post:view:'.$id;
      //这里以Redis哈希类型存储键,就和数组类似,$cacheKey就类似数组名 如果这个key存在
      if(Redis::command('HEXISTS',[$cacheKey,$ip])){
      //哈希类型指令HINCRBY,就是给$cacheKey[$ip]加上一个值,这里一次访问就是1
      $save_count = Redis::command('HINCRBY',$ip,1]);
      //redis中这个存储浏览量的值达到30后,就去刷新一次数据库
      if($save_count == self::postViewLimit){
      $this->updateModelViewCount($id,$save_count);
      //本篇post,redis中浏览量刷进MysqL后,就把该篇post的浏览量清空,重新开始计数
      Redis::command('HDEL',$ip]);
      Redis::command('DEL',['laravel:post:cache:'.$id]);
      }
      }else{
      //哈希类型指令HSET,和数组类似,就像$cacheKey[$ip] = 1;
      Redis::command('HSET','1']);
      }
      }
      }

    最后可以通过我们的工具查看具体效果

    总结

    以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对编程之家的支持

    相关链接

    dis 命令

    版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。