使用webman的自定義進(jìn)程消費(fèi)redis的訂閱導(dǎo)致進(jìn)程64000
問題描述
這里詳細(xì)描述問題
程序代碼
這里粘代碼<?php
namespace process;
use support\Log;
use support\Redis;
class Async
{
/**
- 監(jiān)聽redis訂閱
*/
public function onWorkerStart()
{
Redis::subscribe('asyncpub',function ($data){
if(!empty($data)){
$data = json_decode($data, true);
switch ($data['datatype']){
case 'request':
$this->https_curl($data['url'], [], 'GET');
break;
case 'cmd':
exec($data['commend']['cli'].' '.implode(' ',$data['commend']['param']));
break;
default:
}
Log::info("訂閱消息接收參數(shù)",['data'=>$data]);
}
});
}
報(bào)錯(cuò)信息
這里粘貼報(bào)錯(cuò)worker[async:122068] exit with status 64000
RedisException: read error on connection to 127.0.0.1:6379 in webman/vendor/illuminate/redis/Connections/PhpRedisConnection.php:461
Stack trace:
webman/vendor/illuminate/redis/Connections/PhpRedisConnection.php(461): Redis->subscribe()
操作系統(tǒng)及workerman/webman等框架組件具體版本
這里寫具體的系統(tǒng)環(huán)境相關(guān)信息
4.2.1版本
1個(gè)回答
有沒有可能 127.0.0.1:6379 本地環(huán)境redis沒有啟動(dòng)
-
會(huì)飛的魚 2025-03-20肯定是啟動(dòng)了啊，但是由于是阻塞運(yùn)行導(dǎo)致長時(shí)間的連接超時(shí)了，后面換成new 對象來調(diào)用就正常了 ~
-
tanhongbin 2025-03-20new 對象和 使用靜態(tài)有啥區(qū)別嘛？ 是不是沒有設(shè)置 一直阻塞 導(dǎo)致的 阻塞也是有超時(shí)默認(rèn)時(shí)間的
-
會(huì)飛的魚 2025-03-20
不太清楚，用Redis::subscribe調(diào)用訂閱 就一直繁忙 然后框架拋出異常64000，我是換成
public function onWorkerStart()
{
$redis = new \Workerman\Redis\Client('redis://127.0.0.1:6379');
$redis->subscribe('asyncpub',function ($channel, $message){
if(!empty($message)){
$message = json_decode($message, true);
switch ($message['datatype']){
case 'request':
$this->https_curl($message['url'], [], 'GET');
break;
case 'cmd':
shell_exec($message['commend']['cli'].' '.implode(' ',$message['commend']['param']));
break;
default:
}
}
Log::info("訂閱消息接收參數(shù)",['message'=>$message]);
});
}
這種寫法
