redis-queue
redis-queue copied to clipboard
webman-php
Message queue system written in PHP for webman.
throw new \Excption('异常'); 这样异常给redis弄了一堆报错打印 ======================== 尝试以下操作 ### 1. config/app.php ```php debug=>false error_reporting=>1024 ``` 这个是webman的错误打印配置 ### 2.尝试使用`trigger_error("超时重试2",E_USER_NOTICE)` 还是会打印错误堆栈 找寻源码 `webman/queue` 是对 `workerman/redis-queue`的优雅封装，搞不定 因为我已经选择主动抛出异常重试，堆栈信息是否保存到redis起码可选的吧~ redis - fail表体积爆炸
Creation of dynamic property Workerman\Redis\Client::$brPoping is deprecated
vendor/webman/redis-queue/src/Redis.php /** * Class RedisQueue * @package support * * Strings methods * @method static void send($queue, $data, $delay=0) */
This update enhances the Consumer class in the Webman\RedisQueue\Process namespace to support loading consumer classes from multiple directories. Previously, the class was limited to a single consumer directory, but now...
``` public function onConsumeFailure(\Throwable $e, $package) { echo "consume failure\n"; echo $e->getFile().':'.$e->getLine().':'.$e->getMessage() . "\n"; // 无需反序列化 var_export($package); } ``` 队列里自定义消费事件无法触发。 似乎是 Webman\RedisQueue\Process\Consumer 这里没有判断。
大约在218行，增加第3个参数，$package['id']，因为该队列没有ack，如果想自己处理的ack的话，有个id就更好了，目前我是在data里自行增加了job_id，但是会有些影响。 当然了，如果增加的话，那么Webman\RedisQueue\Consumer的consume方法，也需要增加第二个参数jobId，同时可能implements该接口类的消费队列，都需增加第2个参数，影响较大，作者可以评估下
