配置文件

'default' => [
        'host' => 'redis://127.0.0.1:6379',
        'options' => [
            'auth'     => '',     // 密碼，可選參數(shù)
            'db' => 10,      // 數(shù)據(jù)庫
            'max_attempts'  => 5, // 消費(fèi)失敗后，重試次數(shù)
            'retry_seconds' => 5, // 重試間隔，單位秒
        ]
    ],
    'consumer' => [ //這個(gè)處理計(jì)算進(jìn)程
        'host' => 'redis://127.0.0.1:6379',
        'options' => [
            'auth'     => '',     // 密碼，可選參數(shù)
            'db' => 1,      // 數(shù)據(jù)庫
            'max_attempts'  => 5, // 消費(fèi)失敗后，重試次數(shù)
            'retry_seconds' => 5, // 重試間隔，單位秒
        ]
    ],

這是配置的兩個(gè)連接名 default 和 consumer

消息列表代碼

use Webman\RedisQueue\Consumer;

class Queue1 implements Consumer
{
    // 要消費(fèi)的隊(duì)列名
    public $queue = "QUEUE_1";

    // 連接名，對應(yīng) config/redis_queue.php 里的連接`
    public $connection = 'default';//default 能執(zhí)行,但改成 consumer 卻執(zhí)行不了，是什么原因？

    // 消費(fèi)
    function consume($job_data){
        var_dump("HELLO");
    }
}

調(diào)用代碼

$queue_name =   "QUEUE_1";
$data_list  =   ['a'=>'b'];
Client::send($queue_name, $data_list);

為什么只有 $connection="default"才會執(zhí)行consume方法？而改成consumer卻不行？謝謝