Skip to content

高并发调用push时报错redis链接被另一个协程占用。支持从think-swoole的连接池里获取连接吗?或者queue类增加一个设置redis的方法,用户在调用push之前自行设置redis实例 #190

@note-sun

Description

@note-sun

我看原始代码中,this里的redis是初始化queue的时候就设置了,导致高并发下会造成redis链接被占用。
支持从think-swoole的连接池里获取连接吗?或者queue类增加一个设置redis的方法,用户在调用push之前自行设置redis实例

 public function pushRaw($payload, $queue = null, array $options = [])
    {
        if ($this->redis->rPush($this->getQueue($queue), $payload)) {
            return json_decode($payload, true)['id'] ?? null;
        }
    }

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions