LARAVEL 后端防连点，防并发间件

业务场景中可能遇到连点导致数据库记录有问题无法保证幂等性，这里简单写了一个中间件来防止连点或者并发请求导致数据库记录数据异常；

思路：利用redis锁机制，当前用户访问此url只能在访问结束后再进行访问

首先创建一个配置文件，在 config/ 文件下创建lock.php

1.  
   <?php
2.  
    
3.  
   return [
4.  
   "lock" => [
5.  
   "/url", //防止连点的url
6.  
   ],
7.  
    
8.  
   "default_set" => [
9.  
   "max_time" => 60,
10.  
    "request" => [
11.  
     
12.  
    ],
13.  
    "headers" => [
14.  
    'Authorization' //区分不同用户，如果是oauth2 令牌登录，已token信息为key值
15.  
    ],
16.  
    "message" => '正在处理中，请勿频繁操作',
17.  
    "callback" => [],
18.  
    ],
19.  
     
20.  
    ];

创建中间件：配合config可读取

$app->configure('lock');

 创建全局中间件：LockRouterMiddleware

1.  
   $app->middleware([
2.  
   \App\Http\Middleware\LockRouterMiddleware::class,
3.  
   ]);

在middleware文件夹下创建LockRouterMiddleware.php

1.  
   <?php
2.  
    
3.  
    
4.  
   namespace App\Http\Middleware;
5.  
    
6.  
   use Illuminate\Support\Facades\Redis;
7.  
   use Closure;
8.  
   use Illuminate\Http\Request;
9.  
    
10.  
    /**
11.  
    * 防止并发（频繁）访问 配置在 config/lock.php
12.  
    * Class LockRouterMiddleware
13.  
    * @package App\Http\Middleware
14.  
    */
15.  
    class LockRouterMiddleware
16.  
    {
17.  
    /**
18.  
    * @param Request $request
19.  
    * @param Closure $next
20.  
    * @return mixed
21.  
    */
22.  
    public function handle($request, Closure $next)
23.  
    {
24.  
    $judge = false;
25.  
    $lock = config('lock');
26.  
    $routeName = $request->path();
27.  
     
28.  
    if (in_array($routeName, $lock['lock'] ?? [], false)) {
29.  
    $judge = true;
30.  
    }
31.  
     
32.  
    if ($judge === true) {
33.  
    $set = $lock[$routeName] ?? $lock['default_set'];
34.  
    $message = $lock[$routeName]["message"] ?? $lock['default_set']["message"];
35.  
     
36.  
    $headerString = "headers:";
37.  
    if ($set["headers"]) {
38.  
    foreach ($set["headers"] as $value) {
39.  
    $headerString .= $value . "-" . $request->header($value, "") . ";";
40.  
    }
41.  
    } else {
42.  
    $headerString .= ";";
43.  
    }
44.  
     
45.  
    $requestString = "request:";
46.  
    if ($set["request"]) {
47.  
    foreach ($set["request"] as $value) {
48.  
    $requestString .= $value . "-" . $request->input($value, "") . ";";
49.  
    }
50.  
    } else {
51.  
    $requestString .= ";";
52.  
    }
53.  
     
54.  
    $key = "lock:" . $routeName . ":" . $headerString . ":" . $requestString . ":";
55.  
     
56.  
    if (Redis::setnx($key, 1)) {
57.  
    Redis::expire($key, $set["max_time"] ?? 60);
58.  
    } else {
59.  
    return response()->json([
60.  
    "code" => -1,
61.  
    "data" => [],
62.  
    "msg" => $message
63.  
    ]);
64.  
    }
65.  
    $response = $next($request);
66.  
    Redis::del($key);
67.  
    return $response;
68.  
    }
69.  
     
70.  
    return $next($request);
71.  
     
72.  
    }
73.  
    }

这篇好文章是转载于：学新通技术网