关于 Laravel Redis 多个进程同时取队列问题详解

深藏阁楼爱情的钟 2023-10-17 17:42 32阅读 0赞

这篇文章主要给大家介绍了关于 Laravel Redis 多个进程同时取队列问题的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或工作具有一定的参考学习价值，需要的朋友下面来一起学习学习吧。

**前言**

最近在工作中遇到了一个问题，开启多个进程处理队列会重复读取 Redis 中队列吗？是否因此导致重复执行任务？下面就来通过示例代码详细介绍下。

**使用 Supervisor 监听 Laravel 队列任务，其中 Supervisor 的配置如下：**

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>[program:laravel-worker]</code> 
     </div> 
     <div> 
      <code>process_name=%(program_name)s_%(process_num)02d</code> 
     </div> 
     <div> 
      <code>command=php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>autostart=true</code> 
     </div> 
     <div> 
      <code>autorestart=true</code> 
     </div> 
     <div> 
      <code>numprocs=8</code> 
     </div> 
     <div> 
      <code>redirect_stderr=true</code> 
     </div> 
     <div> 
      <code>stdout_logfile=/</code> 
      <code>var</code> 
      <code>/www/xxx.cn/worker.log</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

**注意：** `numprocs = 8`，代表开启 8 个进程来执行 command 中的命令。

**如下：**

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>PS C:\Users\tanteng\website\laradock&gt; docker-compose </code> 
      <code>exec</code> 
      <code>php-worker sh</code> 
     </div> 
     <div> 
      <code>/etc/supervisor/conf.d # ps -ef | grep php</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>7 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>8 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>9 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>10 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>11 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>12 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>13 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>14 root&nbsp; 0:00 php /</code> 
      <code>var</code> 
      <code>/www/xxx.cn/artisan queue:work --queue=sendfile --tries=3 --daemon</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>44 root&nbsp; 0:00 grep php</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

**Laravel 多进程读取队列内容是否会重复**

在 Laravel 的某个控制器方法，一次放入多个任务队列：

[?][Link 1]

在队列处理的方法打印日志，打印处理的队列的 ID：

app/Jobs/SendFile3.php

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>public</code> 
      <code> function</code> 
      <code>handle()</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>info(</code> 
      <code>'invoke SendFile3'</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>dump(</code> 
      <code>'invoke handle'</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>$rawbody</code> 
      <code>= </code> 
      <code>$this</code> 
      <code>-&gt;job-&gt;getRawBody();</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>$info</code> 
      <code>= json_decode(</code> 
      <code>$rawbody</code> 
      <code>, true);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>info(</code> 
      <code>'queue id:'</code> 
      <code>. </code> 
      <code>$info</code> 
      <code>[</code> 
      <code>'id'</code> 
      <code>]);</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

Laravel 使用 Redis 的 list 作为队列的数据结构，并会为每个队列分配一个 ID，数据结构如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"job"</code> 
      <code>: </code> 
      <code>"Illuminate\\Queue\\CallQueuedHandler@call"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"data"</code> 
      <code>: { </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"commandName"</code> 
      <code>: </code> 
      <code>"App\\Jobs\\SendFile3"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"command"</code> 
      <code>: </code> 
      <code>"O:18:\"App\\Jobs\\SendFile3\":4:{s:6:\"\u0000*\u0000job\";N;s:10:\"connection\";N;s:5:\"queue\";s:8:\"sendfile\";s:5:\"delay\";N;}"</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>},</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"id"</code> 
      <code>: </code> 
      <code>"hadBcy3IpNsnOofQQdHohsa451OkQs88"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>"attempts"</code> 
      <code>: 1</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

请求这个控制器路由（或者命令行方式），就可以看到 Redis 中多了很多队列任务了，如图：

[![2017122594148581.png_2017112594158][]][2017122594148581.png_2017112594158]

这个时候开启 Supervisor 处理队列任务，并查看日志：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div> 
    <div>
      31 
    </div> 
    <div>
      32 
    </div> 
    <div>
      33 
    </div> 
    <div>
      34 
    </div> 
    <div>
      35 
    </div> 
    <div>
      36 
    </div> 
    <div>
      37 
    </div> 
    <div>
      38 
    </div> 
    <div>
      39 
    </div> 
    <div>
      40 
    </div> 
    <div>
      41 
    </div> 
    <div>
      42 
    </div> 
    <div>
      43 
    </div> 
    <div>
      44 
    </div> 
    <div>
      45 
    </div> 
    <div>
      46 
    </div> 
    <div>
      47 
    </div> 
    <div>
      48 
    </div> 
    <div>
      49 
    </div> 
    <div>
      50 
    </div> 
    <div>
      51 
    </div> 
    <div>
      52 
    </div> 
    <div>
      53 
    </div> 
    <div>
      54 
    </div> 
    <div>
      55 
    </div> 
    <div>
      56 
    </div> 
    <div>
      57 
    </div> 
    <div>
      58 
    </div> 
    <div>
      59 
    </div> 
    <div>
      60 
    </div> 
    <div>
      61 
    </div> 
    <div>
      62 
    </div> 
    <div>
      63 
    </div> 
    <div>
      64 
    </div> 
    <div>
      65 
    </div> 
    <div>
      66 
    </div> 
    <div>
      67 
    </div> 
    <div>
      68 
    </div> 
    <div>
      69 
    </div> 
    <div>
      70 
    </div> 
    <div>
      71 
    </div> 
    <div>
      72 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:JaClJzhDEvntzLCRIz6uRQkCVLbE8Y9C</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:ukHv0Li4P2VgPa55qU6yEOJM27Mo5YwJ</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:ObMpwDTmnaveBUkU7aan5abt3Agyt90l</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:fo2qZn2ftSdQtdnKOciMK7iJb4qlhRGE</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:uLjFMoOU7Wk7bOAd4zpHb3ccRMJHBtR6</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:87ULqPBObFmGr16nl5wxFVOi71zGCeRM</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:9UVl0muQLzBqlRI99rChGW2ElXwVEMIE</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:a0vgyZuz9HtmH7DGHEpXqesFTcQU3QAF</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:2cXuXxopPkgYiV4WO8gv9CJ6CwXeKtYL</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:9acTAYa8cxpJX6Q3Gb1sULokotP8reqZ</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:BPHQvBboChlv4gr2I0vyLVyw9bijtTYJ</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:Fm6tNajdxYKtdQbDMYDmwWJFLnNikRyg</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:nyAbcvSkBVPbaH3e2ItQkoLJlP1ficib</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:WBHsSVZtP43569UoPXxfLLJcvYmPW7cP</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:bliPnKcRSDApwVmKLNxEhaKelhm0RDEY</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:eOAoQucEIwRz9uZ64xm6IDKgiqj9Xc3W</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:lzise9EiqQqINrhALbmAI4qNg7qylpb2</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:WXYKvcfOhS1pPnwOwUTsenoMv5l5EUXe</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:XtH5JiwLgnrwWzI02Oyi70pihAOkuJUD</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:9ehmE5HImlpNubpY0xWN8UVrOzxeMqws</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:C1sK87cpZl47edLA0zhfo7PJ9MIEcoyx</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:2kwl51oH4lyyRrljCReGUCkNiJRDl7oe</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:ObRpoqrYTPYiyv2delMlOXu3sAPpWJlN</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:6qgu6W3TapLjSrt688yv9HRXvDDLxntz</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:wiTlERhwn7s9cQkfUF9lLlNADpXjKncI</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:ZSLW0VLFBDpL4wjTJzu3Yb3V45pNe807</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:qhZlXLGfGWRluIeNm7VbllmTJZYb2h5n</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:LUx1IByD3L2psNl9BZwHhk2knXyRPzW6</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:M2RESPjyo5hpAFxxL0EQbWwsUq4jpmWn</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:hUsGaiIAOO6ZfGQc5kGHGpsv5RpoRPYO</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:cEHJsOy6bLeZ4NbncPziaHqlarMeyyEF</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:w4bkFiJKMU5saqG2xKN3ZRL5BYXGATMk</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:0zBuwbxlrEhhxKfYBkVyTY4z35f154sI</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:mvoZvyDPvq4tcPjEy9G7PMtH3MwPkPik</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: invoke SendFile3</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:TLvF74eeidECWKtjZqWvW03UJTRPTL9r</code> 
     </div> 
     <div> 
      <code>[2017-12-23 19:01:01] local.INFO: queue id:me8wyPfgcz0nf9xvcXz0hf2xVxqa1FFS</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

这 8 个进程并发处理队列，但从打印的日志看，没有出现同样的 ID. 我们再看一下 Laravel 如何使用 Redis 处理队列的。

**分析一下 Laravel 队列的处理**

Laravel 中入队列方法

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>public</code> 
      <code> function</code> 
      <code>pushRaw(</code> 
      <code>$payload</code> 
      <code>, </code> 
      <code>$queue</code> 
      <code>= null, </code> 
      <code>array</code> 
      <code>$options</code> 
      <code>= [])</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>$this</code> 
      <code>-&gt;getConnection()-&gt;rpush(</code> 
      <code>$this</code> 
      <code>-&gt;getQueue(</code> 
      <code>$queue</code> 
      <code>), </code> 
      <code>$payload</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>&nbsp;</code>&nbsp; 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>return</code> 
      <code>Arr::get(json_decode(</code> 
      <code>$payload</code> 
      <code>, true), </code> 
      <code>'id'</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

用的是 Redis 的 rpush 命令。

Laravel 中取队列方法

[?][Link 1]

这里用的是 lua 脚本取队列，如下：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>public</code> 
      <code> static</code> 
      <code>function</code> 
      <code>pop()</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>&nbsp;</code> 
      <code>return</code> 
      <code>&lt;&lt;&lt;</code> 
      <code>'LUA'</code> 
     </div> 
     <div> 
      <code>local job = redis.call(</code> 
      <code>'lpop'</code> 
      <code>, KEYS[1])</code> 
     </div> 
     <div> 
      <code>local reserved = false</code> 
     </div> 
     <div> 
      <code>if</code> 
      <code>(job ~= false) then</code> 
     </div> 
     <div> 
      <code>reserved = cjson.decode(job)</code> 
     </div> 
     <div> 
      <code>reserved[</code> 
      <code>'attempts'</code> 
      <code>] = reserved[</code> 
      <code>'attempts'</code> 
      <code>] + 1</code> 
     </div> 
     <div> 
      <code>reserved = cjson.encode(reserved)</code> 
     </div> 
     <div> 
      <code>redis.call(</code> 
      <code>'zadd'</code> 
      <code>, KEYS[2], ARGV[1], reserved)</code> 
     </div> 
     <div> 
      <code>end</code> 
     </div> 
     <div> 
      <code>return</code> 
      <code> {job, reserved}</code> 
     </div> 
     <div> 
      <code>LUA;</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

那么结论是：从 Laravel 的处理方式和打印的日志结果看，即使多个进程读取同一个队列，也不会读取到一样的数据。

**总结**

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

原文链接：https://blog.tanteng.me/2017/12/laravel-supervisor-queue/

来源:http://www.jb51.net/article/131419.htm

[Link 1]: http://www.jb51.net/article/131419.htm#
[2017122594148581.png_2017112594158]: http://files.jb51.net/file_images/article/201712/2017122594148581.png?2017112594158