溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
怎么在Laravel項目中使用Redis？針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
$ 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中定義)
protected $listen = [ 'App\Events\PostViewEvent' => [ // 'App\Listeners\EventListener', 'App\Listeners\PostEventListener', ], ];
執行事件生成監聽
$ php artisan event:generate
之前定義了相關的路由方法 現在去實現一下:
public function showPost(Request $request,$id)
{
//Redis緩存中沒有該post,則從數據庫中取值,并存入Redis中,該鍵值key='post:cache'.$id生命時間5分鐘
$post = Cache::remember('post:cache:'.$id, $this->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的視圖文件
<html lang="en"> <head> <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> <title>Bootstrap Template</title> <!-- 新 Bootstrap 核心 CSS 文件 --> <link rel="stylesheet" href="//cdn.bootcss.com/bootstrap/3.3.5/css/bootstrap.min.css" rel="external nofollow" > <style> html,body{ width: 100%; height: 100%; } *{ margin: 0; border: 0; } .jumbotron{ margin-top: 10%; } .jumbotron>span{ margin: 10px; } </style> </head> <body> <div class="container"> <div class="row"> <div class="col-xs-12 col-md-12"> <div class="jumbotron"> <h2>Title:{{$post->title}}</h2> <span class="glyphicon glyphicon-eye-open" aria-hidden="true"> {{$post->view_count}} views</span> <p>Content:{{$post->content}}</p> </div> </div> </div> </div> <!-- jQuery文件--> <script src="//cdn.bootcss.com/jquery/1.11.3/jquery.min.js"></script> <!-- 最新的 Bootstrap 核心 JavaScript 文件 --> <script src="//cdn.bootcss.com/bootstrap/3.3.5/js/bootstrap.min.js"></script> <script> </script> </body> </html>
初始化我們的事件就是接收一下這些參數即可
class PostViewEvent
{
use Dispatchable, InteractsWithSockets, SerializesModels;
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');
}
}最主要的還是編寫我們的監聽事件:
class PostEventListener
{
/**
* 一個帖子的最大訪問數
*/
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', [$ipPostViewKey, $ip]);
//并給該鍵設置生命時間,這里設置300秒,300秒后同一IP訪問就當做是新的瀏覽量了
Redis::command('EXPIRE', [$ipPostViewKey, 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', [$cacheKey, $ip, 1]);
//redis中這個存儲瀏覽量的值達到30后,就去刷新一次數據庫
if($save_count == self::postViewLimit){
$this->updateModelViewCount($id, $save_count);
//本篇post,redis中瀏覽量刷進MySQL后,就把該篇post的瀏覽量清空,重新開始計數
Redis::command('HDEL', [$cacheKey, $ip]);
Redis::command('DEL', ['laravel:post:cache:'.$id]);
}
}else{
//哈希類型指令HSET,和數組類似,就像$cacheKey[$ip] = 1;
Redis::command('HSET', [$cacheKey, $ip, '1']);
}
}
}最后可以通過我們的工具查看具體效果
關于怎么在Laravel項目中使用Redis問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注億速云行業資訊頻道了解更多相關知識。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
