PHP系列 | PDO::prepare(): send of 68 bytes failed with errno=32 Broken pipe

[2019-11-20T14:33:25+08:00][ error ] [8]PDO::prepare(): send of 68 bytes failed with errno=32 Broken pipe
error

class RedisSubscribe
{
    public function subscribe()
    {
        $redis = BaseRedis::plocal();
        $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
        $redis->psubscribe(array(‘__keyevent@1__:expired‘), function ($redis, $pattern, $chan, $msg) {
            Log::info(‘[订阅事件] 过期KEY ‘ . $msg);
            $flag = strstr($msg,":");
            if(empty($flag)){
                Log::error(‘[订阅事件] 非法的消息类型 ‘.$msg);
                return false;
            }
            $originData = explode(‘:‘,$msg);
            $event_key = $originData[1]??‘0‘;
            $event_status = $originData[0]??‘0‘;
            if($event_status == RedisTaskQueue::ORDER_TIMEOUT_EVENT){
                Log::info(‘[订阅事件] 订单超时事件 ‘.$event_key);
                $order = PayOrderModel::get([‘order_no‘ => $event_key]);
                    Log::info(‘[订阅事件] 订单 ‘.$event_key);
                    if ($order[‘status‘] == 0) {
                        $updateData = [
                            ‘id‘ => $order[‘id‘],
                            ‘status‘ => 2,
                            ‘notify_status‘ => 0,
                            ‘pay_time‘ => time(),
                            ‘remark‘ => ‘超时队列事件‘
                        ];
                        $res = PayOrderModel::update($updateData);
                        Log::info(‘[订阅事件] 更新订单 ‘ . json_encode($res));
                    }
            }
        });
    }
}

$order = PayOrderModel::get([‘order_no‘ => $event_key]);　

// 是否需要断线重连
‘break_reconnect‘ => false,　　

$isPushed = redis_queue(RedisTaskQueue::QUEUE_EVENT, $data);