为什么subscribe过不去呢??
$worker = new Worker();
$worker->count = 100;
$worker->onWorkerStart = function ($worker) {
$client = Test::getServer();
// 订阅
$id = $worker->id;
$client->subscribe("task-{$id}", function($data)use($id) {
var_dump(66666);
try {
$person = new ProcessPerson();
$person->step1($data);
} catch (\Exception $e) {
var_dump($e->getMessage());
}
});
};
Worker::runAll();
到这里就不往下走了晕死了
2084 2 0
2个回答
相似问题
年代过于久远，无法发表回答
赞助商
热门问答
发一个Webman AI 聊天源码 (赠送apikey)
🚀 将webman打包成二进制，PHP也可以打包成二进制了
webman 播放视频要等待很久，才能播放，原生PHP是秒放，要调整哪里才能达到效果
🚀 PHP静态文件下载-无需编译PHP环境
大佬们 能不能编译一个有xlswriter扩展的php静态文件啊，由于本人能力有限，望大佬们帮帮忙
请问下，我想给plugin下的所有应用添加一个全局中间件，来达到限制外部访问的目的，应该怎么做啊？
打二进制包后忽略的文件放在同目录不会引用?
🤔 做个小调研，大家用 webman 一般用哪个 ORM 呢？
webman的平滑重启可以重新加载一些东西吗？
webman/admin 发布0.5.0版
redis 扩展的subscribe是阻塞操作，后面的代码不会执行，除非subscribe返回。
如果你要非阻塞subscribe，可以用 workerman/redis，参见手册 http://doc.workerman.net/components/workerman-redis.html
用的 redis-queue
http://doc.workerman.net/components/workerman-redis-queue.html
你先按照示例来，不要封装，有问题再来发帖。
我调试跟踪到这里就不行了。